Skip to content

Commit

Permalink
add tfcallasync to gearsCmdable
Browse files Browse the repository at this point in the history
  • Loading branch information
ofekshenawa committed Aug 16, 2023
1 parent e3adf82 commit 6c9e0cd
Showing 1 changed file with 11 additions and 9 deletions.
20 changes: 11 additions & 9 deletions redis_gears.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@ type gearsCmdable interface {
TFunctionListArgs(ctx context.Context, options *TFunctionListOptions) *MapStringInterfaceSliceCmd
TFCall(ctx context.Context, libName string, funcName string, numKeys int) *Cmd
TFCallArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd
TFCallASYNC(ctx context.Context, libName string, funcName string, numKeys int) *Cmd
TFCallASYNCArgs(ctx context.Context, libName string, funcName string, numKeys int, options *TFCallOptions) *Cmd
}
type TFunctionLoadOptions struct {
Replace bool
Expand All @@ -36,7 +38,7 @@ type TFCallOptions struct {
func (c cmdable) TFunctionLoad(ctx context.Context, lib string) *StatusCmd {
args := []interface{}{"TFUNCTION", "LOAD", lib}
cmd := NewStatusCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -52,7 +54,7 @@ func (c cmdable) TFunctionLoadArgs(ctx context.Context, lib string, options *TFu
}
args = append(args, lib)
cmd := NewStatusCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -61,7 +63,7 @@ func (c cmdable) TFunctionLoadArgs(ctx context.Context, lib string, options *TFu
func (c cmdable) TFunctionDelete(ctx context.Context, libName string) *StatusCmd {
args := []interface{}{"TFUNCTION", "DELETE", libName}
cmd := NewStatusCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -70,7 +72,7 @@ func (c cmdable) TFunctionDelete(ctx context.Context, libName string) *StatusCmd
func (c cmdable) TFunctionList(ctx context.Context) *MapStringInterfaceSliceCmd {
args := []interface{}{"TFUNCTION", "LIST"}
cmd := NewMapStringInterfaceSliceCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -90,7 +92,7 @@ func (c cmdable) TFunctionListArgs(ctx context.Context, options *TFunctionListOp
}
}
cmd := NewMapStringInterfaceSliceCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -100,7 +102,7 @@ func (c cmdable) TFCall(ctx context.Context, libName string, funcName string, nu
lf := libName + "." + funcName
args := []interface{}{"TFCALL", lf, numKeys}
cmd := NewCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -122,7 +124,7 @@ func (c cmdable) TFCallArgs(ctx context.Context, libName string, funcName string
}
}
cmd := NewCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -132,7 +134,7 @@ func (c cmdable) TFCallASYNC(ctx context.Context, libName string, funcName strin
lf := fmt.Sprintf("%s.%s", libName, funcName)
args := []interface{}{"TFCALLASYNC", lf, numKeys}
cmd := NewCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

Expand All @@ -154,6 +156,6 @@ func (c cmdable) TFCallASYNCArgs(ctx context.Context, libName string, funcName s
}
}
cmd := NewCmd(ctx, args...)
c(ctx, cmd)
_ = c(ctx, cmd)
return cmd
}

0 comments on commit 6c9e0cd

Please sign in to comment.