Skip to content

Commit 157a7f4

Browse files
DOC-4232 added remaining examples
1 parent a023106 commit 157a7f4

File tree

1 file changed

+220
-1
lines changed

1 file changed

+220
-1
lines changed

doctests/stream_tutorial_test.go

Lines changed: 220 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -840,8 +840,147 @@ func ExampleClient_raceitaly() {
840840
// >>> [{1692632647899-0 map[rider:Royce]}]
841841
// STEP_END
842842

843+
// STEP_START xautoclaim
844+
res30, res30a, err := rdb.XAutoClaim(ctx, &redis.XAutoClaimArgs{
845+
Stream: "race:italy",
846+
Group: "italy_riders",
847+
Consumer: "Alice",
848+
Start: "0-0",
849+
Count: 1,
850+
}).Result()
851+
852+
if err != nil {
853+
panic(err)
854+
}
855+
856+
fmt.Println(res30) // >>> [{1692632647899-0 map[rider:Royce]}]
857+
fmt.Println(res30a) // >>> 1692632662819-0
858+
// STEP_END
859+
860+
// STEP_START xautoclaim_cursor
861+
res31, res31a, err := rdb.XAutoClaim(ctx, &redis.XAutoClaimArgs{
862+
Stream: "race:italy",
863+
Group: "italy_riders",
864+
Consumer: "Lora",
865+
Start: "(1692632662819-0",
866+
Count: 1,
867+
}).Result()
868+
869+
if err != nil {
870+
panic(err)
871+
}
872+
873+
fmt.Println(res31)
874+
fmt.Println(res31a)
875+
// STEP_END
876+
877+
// STEP_START xinfo
878+
res32, err := rdb.XInfoStream(ctx, "race:italy").Result()
879+
880+
if err != nil {
881+
panic(err)
882+
}
883+
884+
fmt.Println(res32)
885+
// >>> &{5 1 2 1 1692632678249-0 0-0 5 {1692632639151-0 map[rider:Castilla]} {1692632678249-0 map[rider:Norem]} 1692632639151-0}
886+
// STEP_END
887+
888+
// STEP_START xinfo_groups
889+
res33, err := rdb.XInfoGroups(ctx, "race:italy").Result()
890+
891+
if err != nil {
892+
panic(err)
893+
}
894+
895+
fmt.Println(res33)
896+
// >>> [{italy_riders 3 2 1692632662819-0 3 2}]
897+
// STEP_END
898+
899+
// STEP_START xinfo_consumers
900+
res34, err := rdb.XInfoConsumers(ctx, "race:italy", "italy_riders").Result()
901+
902+
if err != nil {
903+
panic(err)
904+
}
905+
906+
// fmt.Println(res34)
907+
// >>> [{Alice 1 1ms 1ms} {Bob 1 2ms 2ms} {Lora 0 1ms -1ms}]
908+
// STEP_END
909+
910+
// STEP_START maxlen
911+
_, err = rdb.XAdd(ctx, &redis.XAddArgs{
912+
Stream: "race:italy",
913+
MaxLen: 2,
914+
Values: map[string]interface{}{"rider": "Jones"},
915+
},
916+
).Result()
917+
918+
if err != nil {
919+
panic(err)
920+
}
921+
922+
_, err = rdb.XAdd(ctx, &redis.XAddArgs{
923+
Stream: "race:italy",
924+
MaxLen: 2,
925+
Values: map[string]interface{}{"rider": "Wood"},
926+
},
927+
).Result()
928+
929+
if err != nil {
930+
panic(err)
931+
}
932+
933+
_, err = rdb.XAdd(ctx, &redis.XAddArgs{
934+
Stream: "race:italy",
935+
MaxLen: 2,
936+
Values: map[string]interface{}{"rider": "Henshaw"},
937+
},
938+
).Result()
939+
940+
if err != nil {
941+
panic(err)
942+
}
943+
944+
res35, err := rdb.XLen(ctx, "race:italy").Result()
945+
946+
if err != nil {
947+
panic(err)
948+
}
949+
950+
fmt.Println(res35) // >>> 2
951+
952+
res36, err := rdb.XRange(ctx, "race:italy", "-", "+").Result()
953+
954+
if err != nil {
955+
panic(err)
956+
}
957+
958+
// fmt.Println(res36)
959+
// >>> [{1726649529170-1 map[rider:Wood]} {1726649529171-0 map[rider:Henshaw]}]
960+
// STEP_END
961+
962+
// STEP_START xtrim
963+
res37, err := rdb.XTrimMaxLen(ctx, "race:italy", 10).Result()
964+
965+
if err != nil {
966+
panic(err)
967+
}
968+
969+
fmt.Println(res37) // >>> 0
970+
// STEP_END
971+
972+
// STEP_START xtrim
973+
res38, err := rdb.XTrimMaxLenApprox(ctx, "race:italy", 10, 20).Result()
974+
975+
if err != nil {
976+
panic(err)
977+
}
978+
979+
fmt.Println(res38) // >>> 0
980+
// STEP_END
981+
843982
// REMOVE_START
844-
UNUSED(res27)
983+
UNUSED(res27, res34, res36)
845984
// REMOVE_END
846985

847986
// Output:
@@ -852,4 +991,84 @@ func ExampleClient_raceitaly() {
852991
// &{2 1692632647899-0 1692632662819-0 map[Bob:2]}
853992
// [{1692632647899-0 map[rider:Royce]}]
854993
// [{1692632647899-0 map[rider:Royce]}]
994+
// [{1692632647899-0 map[rider:Royce]}]
995+
// 1692632662819-0
996+
// []
997+
// 0-0
998+
// &{5 1 2 1 1692632678249-0 0-0 5 {1692632639151-0 map[rider:Castilla]} {1692632678249-0 map[rider:Norem]} 1692632639151-0}
999+
// [{italy_riders 3 2 1692632662819-0 3 2}]
1000+
// 2
1001+
// 0
1002+
// 0
1003+
}
1004+
1005+
func ExampleClient_xdel() {
1006+
ctx := context.Background()
1007+
1008+
rdb := redis.NewClient(&redis.Options{
1009+
Addr: "localhost:6379",
1010+
Password: "", // no password docs
1011+
DB: 0, // use default DB
1012+
})
1013+
1014+
// REMOVE_START
1015+
rdb.Del(ctx, "race:italy")
1016+
// REMOVE_END
1017+
1018+
_, err := rdb.XAdd(ctx, &redis.XAddArgs{
1019+
Stream: "race:italy",
1020+
MaxLen: 2,
1021+
Values: map[string]interface{}{"rider": "Wood"},
1022+
ID: "1692633198206-0",
1023+
},
1024+
).Result()
1025+
1026+
if err != nil {
1027+
panic(err)
1028+
}
1029+
1030+
_, err = rdb.XAdd(ctx, &redis.XAddArgs{
1031+
Stream: "race:italy",
1032+
MaxLen: 2,
1033+
Values: map[string]interface{}{"rider": "Henshaw"},
1034+
ID: "1692633208557-0",
1035+
},
1036+
).Result()
1037+
1038+
if err != nil {
1039+
panic(err)
1040+
}
1041+
1042+
// STEP_START xdel
1043+
res39, err := rdb.XRangeN(ctx, "race:italy", "-", "+", 2).Result()
1044+
1045+
if err != nil {
1046+
panic(err)
1047+
}
1048+
1049+
fmt.Println(res39)
1050+
// >>> [{1692633198206-0 map[rider:Wood]} {1692633208557-0 map[rider:Henshaw]}]
1051+
1052+
res40, err := rdb.XDel(ctx, "race:italy", "1692633208557-0").Result()
1053+
1054+
if err != nil {
1055+
panic(err)
1056+
}
1057+
1058+
fmt.Println(res40) // 1
1059+
1060+
res41, err := rdb.XRangeN(ctx, "race:italy", "-", "+", 2).Result()
1061+
1062+
if err != nil {
1063+
panic(err)
1064+
}
1065+
1066+
fmt.Println(res41)
1067+
// >>> [{1692633198206-0 map[rider:Wood]}]
1068+
// STEP_END
1069+
1070+
// Output:
1071+
// [{1692633198206-0 map[rider:Wood]} {1692633208557-0 map[rider:Henshaw]}]
1072+
// 1
1073+
// [{1692633198206-0 map[rider:Wood]}]
8551074
}

0 commit comments

Comments
 (0)