Documentation
      ¶
    
    
  
    
      Index ¶
- Constants
 - func ClusterClient_processPipeline(c *ClusterClient, ctx context.Context, cmds []redis.Cmder) error
 - func ClusterClient_processTxPipeline(c *ClusterClient, ctx context.Context, cmds []redis.Cmder) error
 - func WrapClusterClient_processPipeline(c *ClusterClient, ctx context.Context, cmds []redis.Cmder) error
 - func WrapClusterClient_processTxPipeline(c *ClusterClient, ctx context.Context, cmds []redis.Cmder) error
 - func WrapbaseClientgeneralProcessPipeline(c *baseClient, ctx context.Context, cmds []redis.Cmder, p pipelineProcessor) error
 - func WrapbaseClientprocess(c *baseClient, ctx context.Context, cmd redis.Cmder) error
 - func WrapbaseClientprocessPipeline(c *baseClient, ctx context.Context, cmds []redis.Cmder) error
 - func WrapredisNewClient(opt *redis.Options) *redis.Client
 - func WrapredisNewClusterClient(opt *redis.ClusterOptions) *redis.ClusterClient
 - func WrapredisNewFailoverClient(failoverOpt *redis.FailoverOptions) *redis.Client
 - func WrapredisNewFailoverClusterClient(failoverOpt *redis.FailoverOptions) *redis.ClusterClient
 - type ClusterClient
 - type Hooks
 - func (h Hooks) AfterProcess(ctx context.Context, cmd redis.Cmder) error
 - func (h Hooks) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
 - func (h Hooks) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
 - func (h Hooks) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)
 
Constants ¶
      View Source
      
  
const (
	StorageIndexRedis = tingyun3.StorageIndexRedis
)
    Variables ¶
This section is empty.
Functions ¶
func WrapbaseClientprocess ¶
func WrapredisNewClusterClient ¶ added in v0.0.3
func WrapredisNewClusterClient(opt *redis.ClusterOptions) *redis.ClusterClient
func WrapredisNewFailoverClient ¶ added in v1.2.0
func WrapredisNewFailoverClient(failoverOpt *redis.FailoverOptions) *redis.Client
func WrapredisNewFailoverClusterClient ¶ added in v1.2.0
func WrapredisNewFailoverClusterClient(failoverOpt *redis.FailoverOptions) *redis.ClusterClient
Types ¶
type ClusterClient ¶
type ClusterClient struct {
	// contains filtered or unexported fields
}
    type Hooks ¶
type Hooks struct {
	// contains filtered or unexported fields
}
    func (Hooks) AfterProcess ¶ added in v0.0.4
func (Hooks) AfterProcessPipeline ¶ added in v0.0.4
func (Hooks) BeforeProcess ¶ added in v0.0.4
 Click to show internal directories. 
   Click to hide internal directories.