client

Documentation

Index

• type RedisClient
  • func NewRedisClient(addr string) (*RedisClient, error)
  • func (rc *RedisClient) Send(command [][]byte) (protocol.Reply, error)
  • func (rc *RedisClient) Start() error
  • func (rc *RedisClient) Stop()

Types

type RedisClient

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

func NewRedisClient

func NewRedisClient(addr string) (*RedisClient, error)

创建redis客户端socket

func (*RedisClient) Send

func (rc *RedisClient) Send(command [][]byte) (protocol.Reply, error)

将redis命令保存到 waitSend 中

func (*RedisClient) Start

func (rc *RedisClient) Start() error

启动

func (*RedisClient) Stop

func (rc *RedisClient) Stop()