redisProtocol

Documentation

Index

• type RedisProtocol
  • func NewRedisProtocol() *RedisProtocol
  • func (p *RedisProtocol) HandleConnection(conn *net.TCPConn) (server.ProtocolClient, error)
  • func (p *RedisProtocol) Initialize(ctx *server.BroadcastContext) error
  • func (p *RedisProtocol) Name() string
  • func (p *RedisProtocol) RunClient(client server.ProtocolClient)
• type RedisProtocolClient
  • func NewRedisProtocolClient(conn *net.TCPConn) (*RedisProtocolClient, error)
  • func NewRedisProtocolClientSize(conn *net.TCPConn, bufferSize int) (*RedisProtocolClient, error)
  • func (client *RedisProtocolClient) WriteCommand(cmd string, args []interface{}) error

Types

type RedisProtocol

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

func NewRedisProtocol

func NewRedisProtocol() *RedisProtocol

func (*RedisProtocol) HandleConnection

func (p *RedisProtocol) HandleConnection(conn *net.TCPConn) (server.ProtocolClient, error)

func (*RedisProtocol) Initialize

func (p *RedisProtocol) Initialize(ctx *server.BroadcastContext) error

func (*RedisProtocol) Name

func (p *RedisProtocol) Name() string

func (*RedisProtocol) RunClient

func (p *RedisProtocol) RunClient(client server.ProtocolClient)

type RedisProtocolClient

type RedisProtocolClient struct {
	server.NetworkClient
}

func NewRedisProtocolClient

func NewRedisProtocolClient(conn *net.TCPConn) (*RedisProtocolClient, error)

func NewRedisProtocolClientSize

func NewRedisProtocolClientSize(conn *net.TCPConn, bufferSize int) (*RedisProtocolClient, error)

func (*RedisProtocolClient) WriteCommand

func (client *RedisProtocolClient) WriteCommand(cmd string, args []interface{}) error