set the default max batch values from 2000 to 10000

dydxprotocol · Oct 16, 2024 · c2717e7 · c2717e7
1 parent a976ade
commit c2717e7
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/protocol/app/flags/flags.go b/protocol/app/flags/flags.go
@@ -72,8 +72,8 @@ const (
 
 	DefaultGrpcStreamingEnabled              = false
 	DefaultGrpcStreamingFlushIntervalMs      = 50
-	DefaultGrpcStreamingMaxBatchSize         = 2000
-	DefaultGrpcStreamingMaxChannelBufferSize = 2000
+	DefaultGrpcStreamingMaxBatchSize         = 10000
+	DefaultGrpcStreamingMaxChannelBufferSize = 10000
 	DefaultWebsocketStreamingEnabled         = false
 	DefaultWebsocketStreamingPort            = 9092
 	DefaultFullNodeStreamingSnapshotInterval = 0

diff --git a/protocol/app/flags/flags_test.go b/protocol/app/flags/flags_test.go
@@ -89,8 +89,8 @@ func TestValidate(t *testing.T) {
 				GrpcEnable:                        true,
 				GrpcStreamingEnabled:              true,
 				GrpcStreamingFlushIntervalMs:      100,
-				GrpcStreamingMaxBatchSize:         2000,
-				GrpcStreamingMaxChannelBufferSize: 2000,
+				GrpcStreamingMaxBatchSize:         10000,
+				GrpcStreamingMaxChannelBufferSize: 10000,
 				WebsocketStreamingEnabled:         false,
 			},
 		},
@@ -100,8 +100,8 @@ func TestValidate(t *testing.T) {
 				GrpcEnable:                        true,
 				GrpcStreamingEnabled:              true,
 				GrpcStreamingFlushIntervalMs:      100,
-				GrpcStreamingMaxBatchSize:         2000,
-				GrpcStreamingMaxChannelBufferSize: 2000,
+				GrpcStreamingMaxBatchSize:         10000,
+				GrpcStreamingMaxChannelBufferSize: 10000,
 				WebsocketStreamingEnabled:         true,
 				WebsocketStreamingPort:            8989,
 			},
@@ -119,9 +119,9 @@ func TestValidate(t *testing.T) {
 				GrpcEnable:                        true,
 				GrpcStreamingEnabled:              true,
 				OptimisticExecutionEnabled:        true,
-				GrpcStreamingMaxBatchSize:         2000,
+				GrpcStreamingMaxBatchSize:         10000,
 				GrpcStreamingFlushIntervalMs:      100,
-				GrpcStreamingMaxChannelBufferSize: 2000,
+				GrpcStreamingMaxChannelBufferSize: 10000,
 				WebsocketStreamingPort:            8989,
 			},
 		},
@@ -257,8 +257,8 @@ func TestGetFlagValuesFromOptions(t *testing.T) {
 			expectedGrpcEnable:                        true,
 			expectedGrpcStreamingEnable:               false,
 			expectedGrpcStreamingFlushMs:              50,
-			expectedGrpcStreamingBatchSize:            2000,
-			expectedGrpcStreamingMaxChannelBufferSize: 2000,
+			expectedGrpcStreamingBatchSize:            10000,
+			expectedGrpcStreamingMaxChannelBufferSize: 10000,
 			expectedWebsocketEnabled:                  false,
 			expectedWebsocketPort:                     9092,
 			expectedFullNodeStreamingSnapshotInterval: 0,