(ctx context.Context, stream string, start, stop string, count int64)
| 46 | XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd |
| 47 | XRevRange(ctx context.Context, stream string, start, stop string) *XMessageSliceCmd |
| 48 | XRevRangeN(ctx context.Context, stream string, start, stop string, count int64) *XMessageSliceCmd |
| 49 | XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd |
| 50 | XReadStreams(ctx context.Context, streams ...string) *XStreamSliceCmd |
| 51 | XGroupCreate(ctx context.Context, stream, group, start string) *StatusCmd |
no outgoing calls