added varibles to config

cmd/connector/config/config.toml

@@ -30,7 +30,9 @@
 
 [DataPool]
     # Should be smaller then PruningWindow
-    MaxDelta = 100
+    MaxDelta = 50
+
+    # Defines the number of block that will be added until a new persister will be created
     PruningWindow = 1000
 
     # Defines the number of active persisters to keep open
@@ -39,11 +41,17 @@
     # Defines the first commitable meta block round
     # If it is set to 0, it will try to get last rounds info from storage,
     # otherwise, it will try to sync from observers
-    FirstCommitableBlock = 30
+    FirstCommitableBlock = 0
+
+[Publisher]
+    # RetryDurationInMiliseconds defines the retry duration for common publisher
+    # handler when there is an error on publish
+    RetryDurationInMiliseconds = 1000
 
 [OutportBlocksStorage]
     [OutportBlocksStorage.Cache]
         Name = "OutportBlocksStorage"
+        # Cache capacity and size has to be higher than max allowed deltas per shards in total
         Capacity = 100
         Type = "SizeLRU"
         SizeInBytes = 209715200 # 200MB

cmd/connector/flags.go

@@ -38,7 +38,7 @@ var (
 	dbMode = cli.StringFlag{
 		Name:  "db-mode",
 		Usage: "Option for specifying db mode. Available options: `full-persister`, `import-db`, `optimized-persister`",
-		Value: "full-persister",
+		Value: "optimized-persister",
 	}
 
 	enableGrpcServer = cli.BoolFlag{

config/config.go

@@ -6,6 +6,7 @@ type Config struct {
 	DataPool             DataPoolConfig
 	OutportBlocksStorage StorageConfig
 	GRPC                 GRPCConfig
+	Publisher            PublisherConfig
 }
 
 // WebSocketConfig holds web sockets config
@@ -29,6 +30,11 @@ type DataPoolConfig struct {
 	FirstCommitableBlock uint64
 }
 
+// PublisherConfig will map publisher configuration
+type PublisherConfig struct {
+	RetryDurationInMiliseconds uint64
+}
+
 // StorageConfig will map the storage unit configuration
 type StorageConfig struct {
 	Cache CacheConfig

connector/connectorRunner.go

@@ -91,12 +91,11 @@ func (cr *connectorRunner) Run() error {
 		return fmt.Errorf("cannot create publisher: %w", err)
 	}
 
-	retryDurationInMiliseconds := int64(1000)
 	publisherHandler, err := process.NewPublisherHandler(
 		hyperBlockPublisher,
 		outportBlocksPool,
 		dataAggregator,
-		retryDurationInMiliseconds,
+		cr.config.Publisher.RetryDurationInMiliseconds,
 		cr.config.DataPool.FirstCommitableBlock,
 	)
 	if err != nil {

process/publisherHandler.go

@@ -28,7 +28,7 @@ func NewPublisherHandler(
 	handler HyperBlockPublisher,
 	outportBlocksPool HyperBlocksPool,
 	dataAggregator DataAggregator,
-	retryDurationInMiliseconds int64,
+	retryDurationInMiliseconds uint64,
 	firstCommitableBlock uint64,
 ) (*publisherHandler, error) {
 	if check.IfNil(handler) {