Versions in this module Expand all Collapse all v1 v1.2.10 Aug 26, 2024 Changes in this version + type Connection struct + func NewConn(conn net.Conn) *Connection + func (c *Connection) AddTxError(err error) + func (c *Connection) ClearQueuedCmds() + func (c *Connection) Close() error + func (c *Connection) EnqueueCmd(cmdLine [][]byte) + func (c *Connection) GetChannels() []string + func (c *Connection) GetDBIndex() int + func (c *Connection) GetPassword() string + func (c *Connection) GetQueuedCmdLine() [][][]byte + func (c *Connection) GetTxErrors() []error + func (c *Connection) GetWatching() map[string]uint32 + func (c *Connection) InMultiState() bool + func (c *Connection) IsMaster() bool + func (c *Connection) IsSlave() bool + func (c *Connection) Name() string + func (c *Connection) RemoteAddr() string + func (c *Connection) SelectDB(dbNum int) + func (c *Connection) SetMaster() + func (c *Connection) SetMultiState(state bool) + func (c *Connection) SetPassword(password string) + func (c *Connection) SetSlave() + func (c *Connection) SubsCount() int + func (c *Connection) Subscribe(channel string) + func (c *Connection) UnSubscribe(channel string) + func (c *Connection) Write(b []byte) (int, error) + type FakeConn struct + func NewFakeConn() *FakeConn + func (c *FakeConn) Bytes() []byte + func (c *FakeConn) Clean() + func (c *FakeConn) Close() error + func (c *FakeConn) Read(p []byte) (int, error) + func (c *FakeConn) RemoteAddr() string + func (c *FakeConn) Write(b []byte) (int, error)
Go to main page