redis

Dec 27, 2024

Changes in this version

+ type CertConfig interface

+ SetClientAuthType func(authType tls.ClientAuthType)

+ SetRootCertFiles func(files ...string) error

+ SetRootCerts func(certs ...[]byte)

+ SetServerCert func(cert []byte)

+ SetServerCertFile func(file string) error

+ SetServerKey func(key []byte)

+ SetServerKeyFile func(file string) error

+ SetTLSConfig func(tlsConfig *tls.Config)

+ TLSConfig func() (*tls.Config, error)

type Config

+ ConfigRequirePass func() (string, bool)

+ IsPortEnabled func() bool

+ Port func() int

+ RemoveRequirePass func()

+ SetPort func(port int)

+ SetRequirePass func(password string)

type Server

+ Config func() Config

+ type TLSConfig interface

+ IsTLSPortEnabled func() bool

+ SetTLSPort func(port int)

+ TLSPort func() int

Jun 12, 2024

Changes in this version

type Conn

+ func (conn *Conn) Close() error

+ func (conn *Conn) UUID() uuid.UUID

+ type ConnManager struct

+ func NewConnManager() *ConnManager

+ func (mgr *ConnManager) AddConn(c *Conn)

+ func (mgr *ConnManager) Close() error

+ func (mgr *ConnManager) ConnByUUID(uuid uuid.UUID) (*Conn, bool)

+ func (mgr *ConnManager) Conns() []*Conn

+ func (mgr *ConnManager) RemoveConn(conn *Conn) error

+ func (mgr *ConnManager) Start() error

+ func (mgr *ConnManager) Stop() error

May 24, 2024

Changes in this version

type Conn

+ func (conn *Conn) IsTLSConnection() bool

+ func (conn *Conn) Password() (string, bool)

+ func (conn *Conn) SetPassword(password string)

+ func (conn *Conn) SetUserName(username string)

+ func (conn *Conn) TLSConnectionState() (*tls.ConnectionState, bool)

+ func (conn *Conn) UserName() (string, bool)

May 18, 2024

Changes in this version

type ServerConfig

+ CACerts []byte

+ ServerCert []byte

+ ServerKey []byte

+ TLSConfig *tls.Config

+ func (cfg *ServerConfig) ConfigTLSCACert() ([]byte, bool)

+ func (cfg *ServerConfig) ConfigTLSCACertFile() (string, bool)

+ func (cfg *ServerConfig) ConfigTLSCert() ([]byte, bool)

+ func (cfg *ServerConfig) ConfigTLSConfig() (*tls.Config, bool)

+ func (cfg *ServerConfig) ConfigTLSKey() ([]byte, bool)

+ func (cfg *ServerConfig) SetTLSConfig(tlsConfig *tls.Config)

May 17, 2024

Changes in this version

+ const DefaultTLSPort

+ func NewTLSConfigFrom(config *ServerConfig) (*tls.Config, error)

type Config

+ func (cfg *Config) ConfigInteger(key string) (int, bool)

+ func (cfg *Config) ConfigString(key string) (string, bool)

type ServerConfig

+ func (cfg *ServerConfig) ConfigTLSCaCertFile() (string, bool)

+ func (cfg *ServerConfig) ConfigTLSCertFile() (string, bool)

+ func (cfg *ServerConfig) ConfigTLSKeyFile() (string, bool)

+ func (cfg *ServerConfig) ConfigTLSPort() int

+ func (cfg *ServerConfig) IsPortEnabled() bool

+ func (cfg *ServerConfig) IsTLSPortEnabled() bool

+ func (cfg *ServerConfig) SetTLSCaCertFile(caCertFile string)

+ func (cfg *ServerConfig) SetTLSCertFile(certFile string)

+ func (cfg *ServerConfig) SetTLSKeyFile(keyFile string)

+ func (cfg *ServerConfig) SetTLSPort(port int)

Feb 16, 2024

Changes in this version

+ const DefaultScanCount

+ const DefaultScanPattern

+ const DefaultScanType

+ var ErrInvalid = errors.New("invalid")

type GenericCommandHandler

+ Scan func(conn *Conn, cursor int, opt ScanOption) (*Message, error)

+ type ScanOption struct

+ Count int

+ MatchPattern *glob.Glob

+ Type ScanType

+ type ScanType int

+ const HashScan

+ const KeyScan

+ const SetScan

+ const SortedSetScan

Dec 25, 2023

Changes in this version

+ type DatabaseID = int

Nov 19, 2023

Changes in this version

+ var ErrNotAuthrized = errors.New("not authrized")

+ var ErrNotSupported = errors.New("not supported")

+ var ErrQuit = errors.New("QUIT")

+ var ErrSystem = errors.New("internal system error")

+ func NewErrNotSupported(target string) error

+ type AuthCommandHandler interface

+ Auth func(conn *Conn, username string, password string) (*Message, error)

type Config

+ func (cfg *Config) RemoveConfig(key string)

type Conn

+ func (conn *Conn) IsAuthrized() bool

+ func (conn *Conn) SetAuthrized(authrized bool)

type Message

+ func NewErrorNotSupportedMessage(cmd string) *Message

type Server

+ func (server *Server) Auth(conn *Conn, username string, password string) (*Message, error)

+ func (server *Server) SetAuthCommandHandler(handler AuthCommandHandler)

+ type ServerConfig struct

+ func NewDefaultServerConfig() *ServerConfig

+ func (cfg *ServerConfig) ConfigPort() int

+ func (cfg *ServerConfig) ConfigRequirePass() (bool, string)

+ func (cfg *ServerConfig) RemoveRequirePass()

+ func (cfg *ServerConfig) SetPort(port int)

+ func (cfg *ServerConfig) SetRequirePass(password string)

May 4, 2023

Changes in this version

type Conn

+ func (conn *Conn) SetSpanContext(span tracer.SpanContext)

+ func (conn *Conn) SpanContext() tracer.SpanContext

Apr 26, 2023

Changes in this version

type Server

+ func (server *Server) SetAddress(addr string)

+ func (server *Server) SetPort(port int)

Apr 23, 2023

Changes in this version

type Server

+ func (server *Server) SetTracer(t tracer.Tracer)

Apr 1, 2023

Changes in this version

+ const PackageName

Mar 28, 2023

Changes in this version

+ type Conn struct

+ func (conn *Conn) Database() int

+ func (conn *Conn) SetDatabase(id int)

+ func (conn *Conn) Timestamp() time.Time

Jan 13, 2023

Changes in this version

+ const ConfigSep

+ type Config struct

+ func (cfg *Config) AppendConfig(key string, params string)

+ func (cfg *Config) ConfigParameter(key string) (string, bool)

+ func (cfg *Config) SetConfig(key string, params string)

+ type ConnectionManagementCommandHandler interface

+ Echo func(ctx *DBContext, arg string) (*Message, error)

+ Ping func(ctx *DBContext, arg string) (*Message, error)

+ Quit func(ctx *DBContext) (*Message, error)

+ Select func(ctx *DBContext, index int) (*Message, error)

type Server

+ func (server *Server) ConfigGet(ctx *DBContext, keys []string) (*Message, error)

+ func (server *Server) ConfigSet(ctx *DBContext, params map[string]string) (*Message, error)

+ type ServerManagementCommandHandler interface

+ ConfigGet func(ctx *DBContext, keys []string) (*Message, error)

+ ConfigSet func(ctx *DBContext, params map[string]string) (*Message, error)

Sep 3, 2022

Changes in this version

+ type ListCommandHandler interface

+ LIndex func(ctx *DBContext, key string, index int) (*Message, error)

+ LLen func(ctx *DBContext, key string) (*Message, error)

+ LPop func(ctx *DBContext, key string, count int) (*Message, error)

+ LPush func(ctx *DBContext, key string, elements []string, opt PushOption) (*Message, error)

+ LRange func(ctx *DBContext, key string, start int, stop int) (*Message, error)

+ RPop func(ctx *DBContext, key string, count int) (*Message, error)

+ RPush func(ctx *DBContext, key string, elements []string, opt PushOption) (*Message, error)

type Message

+ func NewArrayMessageWithArray(val *proto.Array) *Message

+ func NewFloatMessage(val float64) *Message

+ type PushOption struct

+ X bool

+ type SetCommandHandler interface

+ SAdd func(ctx *DBContext, key string, members []string) (*Message, error)

+ SMembers func(ctx *DBContext, key string) (*Message, error)

+ SRem func(ctx *DBContext, key string, members []string) (*Message, error)

+ type UserCommandHandler interface

+ type ZAddOption struct

+ CH bool

+ GT bool

+ INCR bool

+ LT bool

+ NX bool

+ XX bool

+ type ZRangeOption struct

+ BYLEX bool

+ BYSCORE bool

+ Count int

+ MAXEXCLUSIVE bool

+ MINEXCLUSIVE bool

+ Offset int

+ REV bool

+ WITHSCORES bool

+ type ZSetCommandHandler interface

+ ZAdd func(ctx *DBContext, key string, members []*ZSetMember, opt ZAddOption) (*Message, error)

+ ZIncBy func(ctx *DBContext, key string, inc float64, member string) (*Message, error)

+ ZRange func(ctx *DBContext, key string, start int, stop int, opt ZRangeOption) (*Message, error)

+ ZRangeByScore func(ctx *DBContext, key string, min float64, max float64, opt ZRangeOption) (*Message, error)

+ ZRem func(ctx *DBContext, key string, members []string) (*Message, error)

+ ZScore func(ctx *DBContext, key string, member string) (*Message, error)

+ type ZSetMember struct

+ Member string

+ Score float64

Aug 21, 2022

Changes in this version

+ type Arguments = *proto.Array

+ type Executor func(*DBContext, string, Arguments) (*Message, error)

+ type Executors map[string]Executor

+ type ExpireOption struct

+ GT bool

+ LT bool

+ NX bool

+ Time time.Time

+ XX bool

+ type GenericCommandHandler interface

+ Del func(ctx *DBContext, keys []string) (*Message, error)

+ Exists func(ctx *DBContext, keys []string) (*Message, error)

+ Expire func(ctx *DBContext, key string, opt ExpireOption) (*Message, error)

+ Keys func(ctx *DBContext, pattern string) (*Message, error)

+ Rename func(ctx *DBContext, key string, newkey string, opt RenameOption) (*Message, error)

+ TTL func(ctx *DBContext, key string) (*Message, error)

+ Type func(ctx *DBContext, key string) (*Message, error)

+ type HSetOption struct

+ NX bool

+ type HashCommandHandler interface

+ HDel func(ctx *DBContext, key string, fields []string) (*Message, error)

+ HGet func(ctx *DBContext, key string, field string) (*Message, error)

+ HGetAll func(ctx *DBContext, key string) (*Message, error)

+ HMGet func(ctx *DBContext, key string, fields []string) (*Message, error)

+ HMSet func(ctx *DBContext, key string, dict map[string]string) (*Message, error)

+ HSet func(ctx *DBContext, key string, field string, val string, opt HSetOption) (*Message, error)

+ type MSetOption struct

+ NX bool

type Message

+ func NewArrayMessage() *Message

+ func NewStringArrayMessage(strs []string) *Message

+ type RenameOption struct

+ NX bool

type Server

+ func (server *Server) RegisterExexutor(cmd string, executor Executor)

+ type StringCommandHandler interface

+ Get func(ctx *DBContext, key string) (*Message, error)

+ MGet func(ctx *DBContext, keys []string) (*Message, error)

+ MSet func(ctx *DBContext, dict map[string]string, opt MSetOption) (*Message, error)

+ Set func(ctx *DBContext, key string, val string, opt SetOption) (*Message, error)

Jul 31, 2022

Changes in this version

+ const DefaultPort

+ const LocalHost

+ const OK

+ const Version

+ type CommandHandler interface

+ Get func(ctx *DBContext, key string, opt GetOption) (*Message, error)

+ Set func(ctx *DBContext, key string, val string, opt SetOption) (*Message, error)

+ type DBContext struct

+ func (ctx *DBContext) ID() int

+ type GetOption struct

+ type Message = proto.Message

+ func NewBulkMessage(msg string) *Message

+ func NewErrorMessage(err error) *Message

+ func NewIntegerMessage(val int) *Message

+ func NewNilMessage() *Message

+ func NewOKMessage() *Message

+ func NewStringMessage(msg string) *Message

+ type Server struct

+ Addr string

+ Port int

+ func NewServer() *Server

+ func (server *Server) Echo(ctx *DBContext, arg string) (*Message, error)

+ func (server *Server) Ping(ctx *DBContext, arg string) (*Message, error)

+ func (server *Server) Quit(ctx *DBContext) (*Message, error)

+ func (server *Server) Restart() error

+ func (server *Server) Select(ctx *DBContext, index int) (*Message, error)

+ func (server *Server) SetCommandHandler(handler CommandHandler)

+ func (server *Server) Start() error

+ func (server *Server) Stop() error

+ type SetOption struct

+ EX time.Duration

+ EXAT time.Time

+ GET bool

+ KEEPTTL bool

+ NX bool

+ PX time.Duration

+ PXAT time.Time

+ XX bool

+ type SystemCommandHandler interface

+ Echo func(ctx *DBContext, arg string) (*Message, error)

+ Ping func(ctx *DBContext, arg string) (*Message, error)

+ Quit func(ctx *DBContext) (*Message, error)

+ Select func(ctx *DBContext, index int) (*Message, error)