twap: rename constructor

c9s · Aug 20, 2024 · a06b63c · a06b63c
1 parent ebaf3a3
commit a06b63c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pkg/cmd/execute_order.go b/pkg/cmd/execute_order.go
@@ -161,7 +161,7 @@ var executeOrderCmd = &cobra.Command{
 			return fmt.Errorf("market %s not found", symbol)
 		}
 
-		executor := twap.NewStreamExecutor(session.Exchange, symbol, market, side, targetQuantity, sliceQuantity)
+		executor := twap.NewFixedQuantityExecutor(session.Exchange, symbol, market, side, targetQuantity, sliceQuantity)
 
 		if updateInterval > 0 {
 			executor.SetUpdateInterval(updateInterval)

diff --git a/pkg/twap/v2/stream_executor.go b/pkg/twap/v2/stream_executor.go
@@ -74,7 +74,7 @@ type FixedQuantityExecutor struct {
 	done                     *DoneSignal
 }
 
-func NewStreamExecutor(
+func NewFixedQuantityExecutor(
 	exchange types.Exchange,
 	symbol string,
 	market types.Market,

diff --git a/pkg/twap/v2/stream_executor_test.go b/pkg/twap/v2/stream_executor_test.go
@@ -170,7 +170,7 @@ func TestNewStreamExecutor(t *testing.T) {
 	}
 	mockEx.EXPECT().SubmitOrder(gomock.AssignableToTypeOf(ctx), firstSubmitOrder).Return(&firstOrder, nil)
 
-	executor := NewStreamExecutor(mockEx, symbol, market, types.SideTypeBuy, targetQuantity, sliceQuantity)
+	executor := NewFixedQuantityExecutor(mockEx, symbol, market, types.SideTypeBuy, targetQuantity, sliceQuantity)
 	executor.SetUpdateInterval(200 * time.Millisecond)
 
 	go func() {