From 5f5d1471296e746b72ab3cf7830dcc54887d9256 Mon Sep 17 00:00:00 2001 From: jkoberg Date: Tue, 18 Oct 2022 15:32:31 +0200 Subject: [PATCH] make numer of event consumers configurable in dcfs Signed-off-by: jkoberg --- pkg/storage/utils/decomposedfs/decomposedfs.go | 8 +++++++- pkg/storage/utils/decomposedfs/options/options.go | 1 + 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/pkg/storage/utils/decomposedfs/decomposedfs.go b/pkg/storage/utils/decomposedfs/decomposedfs.go index 591d6a2a7f..9497cb8b9b 100644 --- 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 index dabf2a815f..bf727c8900 100644 --- 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