@@ -50,7 +50,7 @@ import (
5050// To avoid this: it is a good idea to use reasonable bigger read/write timeouts
5151// depends on your batch size and/or use TxPipeline.
5252type Pipeliner interface {
53- CoreCmdable
53+ Cmdable
5454
5555 // Len is to obtain the number of commands in the pipeline that have not yet been executed.
5656 Len () int
@@ -67,6 +67,7 @@ type Pipeliner interface {
6767}
6868
6969var _ Pipeliner = (* Pipeline )(nil )
70+ var _ Cmdable = (* Pipeline )(nil )
7071
7172type proxyresult struct {
7273 err error
@@ -3163,6 +3164,30 @@ func (c *Pipeline) ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *
31633164 return ret
31643165}
31653166
3167+ func (c * Pipeline ) Cache (_ time.Duration ) CacheCompat {
3168+ panic ("not implemented" )
3169+ }
3170+
3171+ func (c * Pipeline ) Subscribe (_ context.Context , _ ... string ) PubSub {
3172+ panic ("not implemented" )
3173+ }
3174+
3175+ func (c * Pipeline ) PSubscribe (_ context.Context , _ ... string ) PubSub {
3176+ panic ("not implemented" )
3177+ }
3178+
3179+ func (c * Pipeline ) SSubscribe (_ context.Context , _ ... string ) PubSub {
3180+ panic ("not implemented" )
3181+ }
3182+
3183+ func (c * Pipeline ) Watch (_ context.Context , _ func (Tx ) error , _ ... string ) error {
3184+ panic ("not implemented" )
3185+ }
3186+
3187+ func (c * Pipeline ) Client () valkey.Client {
3188+ return c .comp .client .(* proxy ).Client
3189+ }
3190+
31663191// Len returns the number of queued commands.
31673192func (c * Pipeline ) Len () int {
31683193 return len (c .comp .client .(* proxy ).cmds )
0 commit comments