Skip to content

Commit

Permalink
enhance: Rename duplicated compaction task command
Browse files Browse the repository at this point in the history
Duplicated method name from different embed struct causing command
failed to work

Signed-off-by: Congqi Xia <[email protected]>
  • Loading branch information
congqixia committed Sep 30, 2024
1 parent a729223 commit fc01e0e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
1 change: 1 addition & 0 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -121,6 +121,7 @@ require (
github.com/rs/xid v1.2.1 // indirect
github.com/sirupsen/logrus v1.8.1 // indirect
github.com/soheilhy/cmux v0.1.5 // indirect
github.com/stretchr/objx v0.5.0 // indirect
github.com/tmc/grpc-websocket-proxy v0.0.0-20201229170055-e5319fda7802 // indirect
github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
github.com/ugorji/go/codec v1.2.11 // indirect
Expand Down
4 changes: 2 additions & 2 deletions states/etcd/remove/compaction_task.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ type CompactionTaskParam struct {
Run bool `name:"run" default:"false" desc:"flag to control actually run or dry"`
}

// CompactionTaskCommand is the command function to remove compaction task.
func (c *ComponentRemove) CompactionTaskCommand(ctx context.Context, p *CompactionTaskParam) error {
// RemoveCompactionTaskCommand is the command function to remove compaction task.
func (c *ComponentRemove) RemoveCompactionTaskCommand(ctx context.Context, p *CompactionTaskParam) error {
compactionTasks, err := common.ListCompactionTask(ctx, c.client, c.basePath, func(task *models.CompactionTask) bool {
if p.CompactionType != task.GetType().String() {
return false
Expand Down

0 comments on commit fc01e0e

Please sign in to comment.