client

Documentation

Index

• type Client
  • func MakeClient(addr string) (*Client, error)
  • func (client *Client) Close()
  • func (client *Client) Send(args [][]byte) reply.Reply
  • func (client *Client) Start()
• type ConnectionFactory
  • func (f *ConnectionFactory) ActivateObject(ctx context.Context, object *pool.PooledObject) error
  • func (f *ConnectionFactory) DestroyObject(ctx context.Context, object *pool.PooledObject) error
  • func (f *ConnectionFactory) MakeObject(ctx context.Context) (*pool.PooledObject, error)
  • func (f *ConnectionFactory) PassivateObject(ctx context.Context, object *pool.PooledObject) error
  • func (f *ConnectionFactory) ValidateObject(ctx context.Context, object *pool.PooledObject) bool

Types

type Client

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

Client is a pipeline mode redis client

func MakeClient

func MakeClient(addr string) (*Client, error)

MakeClient creates a new client

func (*Client) Close

func (client *Client) Close()

Close stops asynchronous goroutines and close connection

func (*Client) Send

func (client *Client) Send(args [][]byte) reply.Reply

Send sends a request to redis server

func (*Client) Start

func (client *Client) Start()

Start starts asynchronous goroutines

type ConnectionFactory

type ConnectionFactory struct {
	Peer string
}

func (*ConnectionFactory) ActivateObject

func (f *ConnectionFactory) ActivateObject(ctx context.Context, object *pool.PooledObject) error

func (*ConnectionFactory) DestroyObject

func (f *ConnectionFactory) DestroyObject(ctx context.Context, object *pool.PooledObject) error

func (*ConnectionFactory) MakeObject

func (f *ConnectionFactory) MakeObject(ctx context.Context) (*pool.PooledObject, error)

func (*ConnectionFactory) PassivateObject

func (f *ConnectionFactory) PassivateObject(ctx context.Context, object *pool.PooledObject) error

func (*ConnectionFactory) ValidateObject

func (f *ConnectionFactory) ValidateObject(ctx context.Context, object *pool.PooledObject) bool