Versions in this module Expand all Collapse all v2 v2.1.0 Oct 22, 2026 Changes in this version type Engine + func (e *Engine) ExecPipeline(s *Session, cmds [][]string, w resp.Writer) v2.0.1 Oct 22, 2026 Changes in this version + func IsWrite(name string) bool + func Names() []string + func WriteMessage(w resp.Writer, channel, pattern, message string) + type Authenticator interface + Check func(password string) bool + Enabled func() bool + type Config struct + Auth Authenticator + LuaEnabled bool + Passwords []string + PubSubEnabled bool + ScriptTimeout time.Duration + Version string + type Engine struct + ClientCount func() int64 + Persister *cache.Persister + func New(c *cache.BoltCache, hub *pubsub.Hub, cfg Config) *Engine + func (e *Engine) AuthRequired() bool + func (e *Engine) Cache() *cache.BoltCache + func (e *Engine) CheckPassword(p string) bool + func (e *Engine) CloseSession(s *Session) + func (e *Engine) Exec(s *Session, argv [][]byte, w resp.Writer) + func (e *Engine) ExecStrings(s *Session, args []string, w resp.Writer) + func (e *Engine) Hub() *pubsub.Hub + func (e *Engine) Info(section string) string + func (e *Engine) NewSession(addr string, sub pubsub.Subscriber) *Session + func (e *Engine) Stats() (commands, rejected uint64) + type Session struct + Addr string + Authenticated bool + Close bool + ID int64 + Name string + Subscriber pubsub.Subscriber + func (s *Session) Subscriptions() int