piperedis

README

piperedis

Automatically pipelined redis client for golang

Documentation

Index

• type Client
  • func New(client redis.UniversalClient, option Option) (*Client, error)
  • func (c *Client) Close() (err error)
  • func (c *Client) Do(ctx context.Context, args ...interface{}) *redis.Cmd
• type Option

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func New

func New(client redis.UniversalClient, option Option) (*Client, error)

func (*Client) Close

func (c *Client) Close() (err error)

func (*Client) Do

func (c *Client) Do(ctx context.Context, args ...interface{}) *redis.Cmd

type Option

type Option struct {
	NumBackgroundWorker    int
	ChannelBufferSize      int
	MinCollectInterval     time.Duration
	MaxNRequestsInPipeline int
}