connection

Documentation

Index

• type Connection
  • func NewConn(conn net.Conn) *Connection
  • func (c *Connection) ClearQueuedCmds()
  • func (c *Connection) Close() error
  • func (c *Connection) EnqueueCmd(cmdLine [][]byte)
  • func (c *Connection) GetChannels() []string
  • func (c *Connection) GetPassword() string
  • func (c *Connection) GetQueuedCmdLine() [][][]byte
  • func (c *Connection) GetWatching() map[string]uint32
  • func (c *Connection) InMultiState() bool
  • func (c *Connection) RemoteAddr() net.Addr
  • func (c *Connection) SetMultiState(state bool)
  • func (c *Connection) SetPassword(password string)
  • func (c *Connection) SubsCount() int
  • func (c *Connection) Subscribe(channel string)
  • func (c *Connection) UnSubscribe(channel string)
  • func (c *Connection) Write(b []byte) error
• type FakeConn
  • func (c *FakeConn) Bytes() []byte
  • func (c *FakeConn) Clean()
  • func (c *FakeConn) Write(b []byte) error

Types

type Connection

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

Connection represents a connection with a redis-cli

func NewConn

func NewConn(conn net.Conn) *Connection

NewConn creates Connection instance

func (*Connection) ClearQueuedCmds

func (c *Connection) ClearQueuedCmds()

func (*Connection) Close

func (c *Connection) Close() error

Close disconnect with the client

func (*Connection) EnqueueCmd

func (c *Connection) EnqueueCmd(cmdLine [][]byte)

func (*Connection) GetChannels

func (c *Connection) GetChannels() []string

GetChannels returns all subscribing channels

func (*Connection) GetPassword

func (c *Connection) GetPassword() string

GetPassword get password for authentication

func (*Connection) GetQueuedCmdLine

func (c *Connection) GetQueuedCmdLine() [][][]byte

func (*Connection) GetWatching

func (c *Connection) GetWatching() map[string]uint32

func (*Connection) InMultiState

func (c *Connection) InMultiState() bool

func (*Connection) RemoteAddr

func (c *Connection) RemoteAddr() net.Addr

RemoteAddr returns the remote network address

func (*Connection) SetMultiState

func (c *Connection) SetMultiState(state bool)

func (*Connection) SetPassword

func (c *Connection) SetPassword(password string)

SetPassword stores password for authentication

func (*Connection) SubsCount

func (c *Connection) SubsCount() int

SubsCount returns the number of subscribing channels

func (*Connection) Subscribe

func (c *Connection) Subscribe(channel string)

Subscribe add current connection into subscribers of the given channel

func (*Connection) UnSubscribe

func (c *Connection) UnSubscribe(channel string)

UnSubscribe removes current connection into subscribers of the given channel

func (*Connection) Write

func (c *Connection) Write(b []byte) error

Write sends response to client over tcp connection

type FakeConn

type FakeConn struct {
	Connection
	// contains filtered or unexported fields
}

FakeConn implements redis.Connection for test

func (*FakeConn) Bytes

func (c *FakeConn) Bytes() []byte

Bytes returns written data

func (*FakeConn) Clean

func (c *FakeConn) Clean()

Clean resets the buffer

func (*FakeConn) Write

func (c *FakeConn) Write(b []byte) error

Write writes data to buffer