Merge pull request #3370 from kobergj/MultiConsumerPostprocessing

[tests-only] Multi Consumer Postprocessing
cs3org · Oct 19, 2022 · f476949 · f476949
2 parents b55836d + 5f5d147
commit f476949
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/pkg/storage/utils/decomposedfs/decomposedfs.go b/pkg/storage/utils/decomposedfs/decomposedfs.go
@@ -201,7 +201,13 @@ func New(o *options.Options, lu *lookup.Lookup, p PermissionsChecker, tp Tree, p
 			return nil, err
 		}
 
-		go fs.Postprocessing(ch)
+		if o.Events.NumConsumers <= 0 {
+			o.Events.NumConsumers = 1
+		}
+
+		for i := 0; i < o.Events.NumConsumers; i++ {
+			go fs.Postprocessing(ch)
+		}
 	}
 
 	return fs, nil

diff --git a/pkg/storage/utils/decomposedfs/options/options.go b/pkg/storage/utils/decomposedfs/options/options.go
@@ -67,6 +67,7 @@ type EventOptions struct {
 	NatsClusterID        string `mapstructure:"natsclusterid"`
 	TLSInsecure          bool   `mapstructure:"tlsinsecure"`
 	TLSRootCACertificate string `mapstructure:"tlsrootcacertificate"`
+	NumConsumers         int    `mapstructure:"numconsumers"`
 }
 
 // TokenOptions are the configurable option for tokens