Skip to content

Commit 329d87f

Browse files
authored
Merge pull request #1906 from Stavrospanakakis/master
feat: add SetVal method for each command
2 parents afd8445 + 168981d commit 329d87f

File tree

1 file changed

+143
-0
lines changed

1 file changed

+143
-0
lines changed

command.go

Lines changed: 143 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -200,6 +200,10 @@ func (cmd *Cmd) String() string {
200200
return cmdString(cmd, cmd.val)
201201
}
202202

203+
func (cmd *Cmd) SetVal(val interface{}) {
204+
cmd.val = val
205+
}
206+
203207
func (cmd *Cmd) Val() interface{} {
204208
return cmd.val
205209
}
@@ -372,6 +376,10 @@ func NewSliceCmd(ctx context.Context, args ...interface{}) *SliceCmd {
372376
}
373377
}
374378

379+
func (cmd *SliceCmd) SetVal(val []interface{}) {
380+
cmd.val = val
381+
}
382+
375383
func (cmd *SliceCmd) Val() []interface{} {
376384
return cmd.val
377385
}
@@ -432,6 +440,10 @@ func NewStatusCmd(ctx context.Context, args ...interface{}) *StatusCmd {
432440
}
433441
}
434442

443+
func (cmd *StatusCmd) SetVal(val string) {
444+
cmd.val = val
445+
}
446+
435447
func (cmd *StatusCmd) Val() string {
436448
return cmd.val
437449
}
@@ -468,6 +480,10 @@ func NewIntCmd(ctx context.Context, args ...interface{}) *IntCmd {
468480
}
469481
}
470482

483+
func (cmd *IntCmd) SetVal(val int64) {
484+
cmd.val = val
485+
}
486+
471487
func (cmd *IntCmd) Val() int64 {
472488
return cmd.val
473489
}
@@ -508,6 +524,10 @@ func NewIntSliceCmd(ctx context.Context, args ...interface{}) *IntSliceCmd {
508524
}
509525
}
510526

527+
func (cmd *IntSliceCmd) SetVal(val []int64) {
528+
cmd.val = val
529+
}
530+
511531
func (cmd *IntSliceCmd) Val() []int64 {
512532
return cmd.val
513533
}
@@ -556,6 +576,10 @@ func NewDurationCmd(ctx context.Context, precision time.Duration, args ...interf
556576
}
557577
}
558578

579+
func (cmd *DurationCmd) SetVal(val time.Duration) {
580+
cmd.val = val
581+
}
582+
559583
func (cmd *DurationCmd) Val() time.Duration {
560584
return cmd.val
561585
}
@@ -603,6 +627,10 @@ func NewTimeCmd(ctx context.Context, args ...interface{}) *TimeCmd {
603627
}
604628
}
605629

630+
func (cmd *TimeCmd) SetVal(val time.Time) {
631+
cmd.val = val
632+
}
633+
606634
func (cmd *TimeCmd) Val() time.Time {
607635
return cmd.val
608636
}
@@ -656,6 +684,10 @@ func NewBoolCmd(ctx context.Context, args ...interface{}) *BoolCmd {
656684
}
657685
}
658686

687+
func (cmd *BoolCmd) SetVal(val bool) {
688+
cmd.val = val
689+
}
690+
659691
func (cmd *BoolCmd) Val() bool {
660692
return cmd.val
661693
}
@@ -710,6 +742,10 @@ func NewStringCmd(ctx context.Context, args ...interface{}) *StringCmd {
710742
}
711743
}
712744

745+
func (cmd *StringCmd) SetVal(val string) {
746+
cmd.val = val
747+
}
748+
713749
func (cmd *StringCmd) Val() string {
714750
return cmd.val
715751
}
@@ -810,6 +846,10 @@ func NewFloatCmd(ctx context.Context, args ...interface{}) *FloatCmd {
810846
}
811847
}
812848

849+
func (cmd *FloatCmd) SetVal(val float64) {
850+
cmd.val = val
851+
}
852+
813853
func (cmd *FloatCmd) Val() float64 {
814854
return cmd.val
815855
}
@@ -846,6 +886,10 @@ func NewFloatSliceCmd(ctx context.Context, args ...interface{}) *FloatSliceCmd {
846886
}
847887
}
848888

889+
func (cmd *FloatSliceCmd) SetVal(val []float64) {
890+
cmd.val = val
891+
}
892+
849893
func (cmd *FloatSliceCmd) Val() []float64 {
850894
return cmd.val
851895
}
@@ -895,6 +939,10 @@ func NewStringSliceCmd(ctx context.Context, args ...interface{}) *StringSliceCmd
895939
}
896940
}
897941

942+
func (cmd *StringSliceCmd) SetVal(val []string) {
943+
cmd.val = val
944+
}
945+
898946
func (cmd *StringSliceCmd) Val() []string {
899947
return cmd.val
900948
}
@@ -948,6 +996,10 @@ func NewBoolSliceCmd(ctx context.Context, args ...interface{}) *BoolSliceCmd {
948996
}
949997
}
950998

999+
func (cmd *BoolSliceCmd) SetVal(val []bool) {
1000+
cmd.val = val
1001+
}
1002+
9511003
func (cmd *BoolSliceCmd) Val() []bool {
9521004
return cmd.val
9531005
}
@@ -994,6 +1046,10 @@ func NewStringStringMapCmd(ctx context.Context, args ...interface{}) *StringStri
9941046
}
9951047
}
9961048

1049+
func (cmd *StringStringMapCmd) SetVal(val map[string]string) {
1050+
cmd.val = val
1051+
}
1052+
9971053
func (cmd *StringStringMapCmd) Val() map[string]string {
9981054
return cmd.val
9991055
}
@@ -1067,6 +1123,10 @@ func NewStringIntMapCmd(ctx context.Context, args ...interface{}) *StringIntMapC
10671123
}
10681124
}
10691125

1126+
func (cmd *StringIntMapCmd) SetVal(val map[string]int64) {
1127+
cmd.val = val
1128+
}
1129+
10701130
func (cmd *StringIntMapCmd) Val() map[string]int64 {
10711131
return cmd.val
10721132
}
@@ -1119,6 +1179,10 @@ func NewStringStructMapCmd(ctx context.Context, args ...interface{}) *StringStru
11191179
}
11201180
}
11211181

1182+
func (cmd *StringStructMapCmd) SetVal(val map[string]struct{}) {
1183+
cmd.val = val
1184+
}
1185+
11221186
func (cmd *StringStructMapCmd) Val() map[string]struct{} {
11231187
return cmd.val
11241188
}
@@ -1170,6 +1234,10 @@ func NewXMessageSliceCmd(ctx context.Context, args ...interface{}) *XMessageSlic
11701234
}
11711235
}
11721236

1237+
func (cmd *XMessageSliceCmd) SetVal(val []XMessage) {
1238+
cmd.val = val
1239+
}
1240+
11731241
func (cmd *XMessageSliceCmd) Val() []XMessage {
11741242
return cmd.val
11751243
}
@@ -1279,6 +1347,10 @@ func NewXStreamSliceCmd(ctx context.Context, args ...interface{}) *XStreamSliceC
12791347
}
12801348
}
12811349

1350+
func (cmd *XStreamSliceCmd) SetVal(val []XStream) {
1351+
cmd.val = val
1352+
}
1353+
12821354
func (cmd *XStreamSliceCmd) Val() []XStream {
12831355
return cmd.val
12841356
}
@@ -1351,6 +1423,10 @@ func NewXPendingCmd(ctx context.Context, args ...interface{}) *XPendingCmd {
13511423
}
13521424
}
13531425

1426+
func (cmd *XPendingCmd) SetVal(val *XPending) {
1427+
cmd.val = val
1428+
}
1429+
13541430
func (cmd *XPendingCmd) Val() *XPending {
13551431
return cmd.val
13561432
}
@@ -1453,6 +1529,10 @@ func NewXPendingExtCmd(ctx context.Context, args ...interface{}) *XPendingExtCmd
14531529
}
14541530
}
14551531

1532+
func (cmd *XPendingExtCmd) SetVal(val []XPendingExt) {
1533+
cmd.val = val
1534+
}
1535+
14561536
func (cmd *XPendingExtCmd) Val() []XPendingExt {
14571537
return cmd.val
14581538
}
@@ -1531,6 +1611,11 @@ func NewXAutoClaimCmd(ctx context.Context, args ...interface{}) *XAutoClaimCmd {
15311611
}
15321612
}
15331613

1614+
func (cmd *XAutoClaimCmd) SetVal(val []XMessage, start string) {
1615+
cmd.val = val
1616+
cmd.start = start
1617+
}
1618+
15341619
func (cmd *XAutoClaimCmd) Val() (messages []XMessage, start string) {
15351620
return cmd.val, cmd.start
15361621
}
@@ -1585,6 +1670,11 @@ func NewXAutoClaimJustIDCmd(ctx context.Context, args ...interface{}) *XAutoClai
15851670
}
15861671
}
15871672

1673+
func (cmd *XAutoClaimJustIDCmd) SetVal(val []string, start string) {
1674+
cmd.val = val
1675+
cmd.start = start
1676+
}
1677+
15881678
func (cmd *XAutoClaimJustIDCmd) Val() (ids []string, start string) {
15891679
return cmd.val, cmd.start
15901680
}
@@ -1651,6 +1741,10 @@ func NewXInfoConsumersCmd(ctx context.Context, stream string, group string) *XIn
16511741
}
16521742
}
16531743

1744+
func (cmd *XInfoConsumersCmd) SetVal(val []XInfoConsumer) {
1745+
cmd.val = val
1746+
}
1747+
16541748
func (cmd *XInfoConsumersCmd) Val() []XInfoConsumer {
16551749
return cmd.val
16561750
}
@@ -1749,6 +1843,10 @@ func NewXInfoGroupsCmd(ctx context.Context, stream string) *XInfoGroupsCmd {
17491843
}
17501844
}
17511845

1846+
func (cmd *XInfoGroupsCmd) SetVal(val []XInfoGroup) {
1847+
cmd.val = val
1848+
}
1849+
17521850
func (cmd *XInfoGroupsCmd) Val() []XInfoGroup {
17531851
return cmd.val
17541852
}
@@ -1852,6 +1950,10 @@ func NewXInfoStreamCmd(ctx context.Context, stream string) *XInfoStreamCmd {
18521950
}
18531951
}
18541952

1953+
func (cmd *XInfoStreamCmd) SetVal(val *XInfoStream) {
1954+
cmd.val = val
1955+
}
1956+
18551957
func (cmd *XInfoStreamCmd) Val() *XInfoStream {
18561958
return cmd.val
18571959
}
@@ -1971,6 +2073,10 @@ func NewXInfoStreamFullCmd(ctx context.Context, args ...interface{}) *XInfoStrea
19712073
}
19722074
}
19732075

2076+
func (cmd *XInfoStreamFullCmd) SetVal(val *XInfoStreamFull) {
2077+
cmd.val = val
2078+
}
2079+
19742080
func (cmd *XInfoStreamFullCmd) Val() *XInfoStreamFull {
19752081
return cmd.val
19762082
}
@@ -2231,6 +2337,10 @@ func NewZSliceCmd(ctx context.Context, args ...interface{}) *ZSliceCmd {
22312337
}
22322338
}
22332339

2340+
func (cmd *ZSliceCmd) SetVal(val []Z) {
2341+
cmd.val = val
2342+
}
2343+
22342344
func (cmd *ZSliceCmd) Val() []Z {
22352345
return cmd.val
22362346
}
@@ -2286,6 +2396,10 @@ func NewZWithKeyCmd(ctx context.Context, args ...interface{}) *ZWithKeyCmd {
22862396
}
22872397
}
22882398

2399+
func (cmd *ZWithKeyCmd) SetVal(val *ZWithKey) {
2400+
cmd.val = val
2401+
}
2402+
22892403
func (cmd *ZWithKeyCmd) Val() *ZWithKey {
22902404
return cmd.val
22912405
}
@@ -2350,6 +2464,11 @@ func NewScanCmd(ctx context.Context, process cmdable, args ...interface{}) *Scan
23502464
}
23512465
}
23522466

2467+
func (cmd *ScanCmd) SetVal(page []string, cursor uint64) {
2468+
cmd.page = page
2469+
cmd.cursor = cursor
2470+
}
2471+
23532472
func (cmd *ScanCmd) Val() (keys []string, cursor uint64) {
23542473
return cmd.page, cmd.cursor
23552474
}
@@ -2404,6 +2523,10 @@ func NewClusterSlotsCmd(ctx context.Context, args ...interface{}) *ClusterSlotsC
24042523
}
24052524
}
24062525

2526+
func (cmd *ClusterSlotsCmd) SetVal(val []ClusterSlot) {
2527+
cmd.val = val
2528+
}
2529+
24072530
func (cmd *ClusterSlotsCmd) Val() []ClusterSlot {
24082531
return cmd.val
24092532
}
@@ -2558,6 +2681,10 @@ func geoLocationArgs(q *GeoRadiusQuery, args ...interface{}) []interface{} {
25582681
return args
25592682
}
25602683

2684+
func (cmd *GeoLocationCmd) SetVal(locations []GeoLocation) {
2685+
cmd.locations = locations
2686+
}
2687+
25612688
func (cmd *GeoLocationCmd) Val() []GeoLocation {
25622689
return cmd.locations
25632690
}
@@ -2761,6 +2888,10 @@ func NewGeoSearchLocationCmd(
27612888
}
27622889
}
27632890

2891+
func (cmd *GeoSearchLocationCmd) SetVal(val []GeoLocation) {
2892+
cmd.val = val
2893+
}
2894+
27642895
func (cmd *GeoSearchLocationCmd) Val() []GeoLocation {
27652896
return cmd.val
27662897
}
@@ -2852,6 +2983,10 @@ func NewGeoPosCmd(ctx context.Context, args ...interface{}) *GeoPosCmd {
28522983
}
28532984
}
28542985

2986+
func (cmd *GeoPosCmd) SetVal(val []*GeoPos) {
2987+
cmd.val = val
2988+
}
2989+
28552990
func (cmd *GeoPosCmd) Val() []*GeoPos {
28562991
return cmd.val
28572992
}
@@ -2929,6 +3064,10 @@ func NewCommandsInfoCmd(ctx context.Context, args ...interface{}) *CommandsInfoC
29293064
}
29303065
}
29313066

3067+
func (cmd *CommandsInfoCmd) SetVal(val map[string]*CommandInfo) {
3068+
cmd.val = val
3069+
}
3070+
29323071
func (cmd *CommandsInfoCmd) Val() map[string]*CommandInfo {
29333072
return cmd.val
29343073
}
@@ -3116,6 +3255,10 @@ func NewSlowLogCmd(ctx context.Context, args ...interface{}) *SlowLogCmd {
31163255
}
31173256
}
31183257

3258+
func (cmd *SlowLogCmd) SetVal(val []SlowLog) {
3259+
cmd.val = val
3260+
}
3261+
31193262
func (cmd *SlowLogCmd) Val() []SlowLog {
31203263
return cmd.val
31213264
}

0 commit comments

Comments
 (0)