Add config section for asset.manager

Currently only contains retry configuration.

Signed-off-by: Andrew Richardson <[email protected]>

internal/assets/manager.go

@@ -68,9 +68,9 @@ func NewAssetManager(ctx context.Context, di database.Plugin, ii identity.Plugin
 		syncasync: sa,
 		tokens:    ti,
 		retry: retry.Retry{
-			InitialDelay: config.GetDuration(config.EventAggregatorRetryInitDelay),
-			MaximumDelay: config.GetDuration(config.EventAggregatorRetryMaxDelay),
-			Factor:       config.GetFloat64(config.EventAggregatorRetryFactor),
+			InitialDelay: config.GetDuration(config.AssetManagerRetryInitialDelay),
+			MaximumDelay: config.GetDuration(config.AssetManagerRetryMaxDelay),
+			Factor:       config.GetFloat64(config.AssetManagerRetryFactor),
 		},
 		txhelper: txcommon.NewTransactionHelper(di),
 	}

internal/config/config.go

@@ -200,7 +200,13 @@ var (
 	// SubscriptionsRetryMaxDelay is the initial retry delay
 	SubscriptionsRetryMaxDelay = rootKey("subscription.retry.maxDelay")
 	// SubscriptionsRetryFactor the backoff factor to use for retry of database operations
-	SubscriptionsRetryFactor = rootKey("event.dispatcher.retry.factor")
+	SubscriptionsRetryFactor = rootKey("subscription.retry.factor")
+	// AssetManagerRetryInitialDelay is the initial retry delay
+	AssetManagerRetryInitialDelay = rootKey("asset.manager.retry.initDelay")
+	// AssetManagerRetryMaxDelay is the initial retry delay
+	AssetManagerRetryMaxDelay = rootKey("asset.manager.retry.maxDelay")
+	// AssetManagerRetryFactor the backoff factor to use for retry of database operations
+	AssetManagerRetryFactor = rootKey("asset.manager.retry.factor")
 	// UIEnabled set to false to disable the UI (default is true, so UI will be enabled if ui.path is valid)
 	UIEnabled = rootKey("ui.enabled")
 	// UIPath the path on which to serve the UI
@@ -322,6 +328,9 @@ func Reset() {
 	viper.SetDefault(string(SubscriptionsRetryInitialDelay), "250ms")
 	viper.SetDefault(string(SubscriptionsRetryMaxDelay), "30s")
 	viper.SetDefault(string(SubscriptionsRetryFactor), 2.0)
+	viper.SetDefault(string(AssetManagerRetryInitialDelay), "250ms")
+	viper.SetDefault(string(AssetManagerRetryMaxDelay), "30s")
+	viper.SetDefault(string(AssetManagerRetryFactor), 2.0)
 	viper.SetDefault(string(UIEnabled), true)
 	viper.SetDefault(string(ValidatorCacheSize), "1Mb")
 	viper.SetDefault(string(ValidatorCacheTTL), "1h")