Versions in this module Expand all Collapse all v1 v1.2.9 Jun 4, 2023 Changes in this version + func GenGodisInfoString(section string, db *Server) []byte + func Info(db *Server, args [][]byte) redis.Reply + func NewPersister(db database.DBEngine, filename string, load bool, fsync string) (*aof.Persister, error) + type Server struct + func MakeAuxiliaryServer() *Server + func (server *Server) AddAof(dbIndex int, cmdLine CmdLine) + func (server *Server) AfterClientClose(c redis.Connection) + func (server *Server) Close() + func (server *Server) Exec(c redis.Connection, cmdLine [][]byte) (result redis.Reply) + func (server *Server) ExecMulti(conn redis.Connection, watching map[string]uint32, cmdLines []CmdLine) redis.Reply + func (server *Server) ExecWithLock(conn redis.Connection, cmdLine [][]byte) redis.Reply + func (server *Server) ForEach(dbIndex int, ...) + func (server *Server) GetAvgTTL(dbIndex, randomKeyCount int) int64 + func (server *Server) GetDBSize(dbIndex int) (int, int) + func (server *Server) GetUndoLogs(dbIndex int, cmdLine [][]byte) []CmdLine + func (server *Server) LoadRDB(dec *core.Decoder) error + func (server *Server) RWLocks(dbIndex int, writeKeys []string, readKeys []string) + func (server *Server) RWUnLocks(dbIndex int, writeKeys []string, readKeys []string) v1.2.8 May 23, 2022 Changes in this version + func Auth(c redis.Connection, args [][]byte) redis.Reply + func BGRewriteAOF(db *MultiDB, args [][]byte) redis.Reply + func BGSaveRDB(db *MultiDB, args [][]byte) redis.Reply + func DiscardMulti(conn redis.Connection) redis.Reply + func EnqueueCmd(conn redis.Connection, cmdLine [][]byte) redis.Reply + func GetRelatedKeys(cmdLine [][]byte) ([]string, []string) + func Ping(db *DB, args [][]byte) redis.Reply + func RegisterCommand(name string, executor ExecFunc, prepare PreFunc, rollback UndoFunc, arity int) + func RewriteAOF(db *MultiDB, args [][]byte) redis.Reply + func SaveRDB(db *MultiDB, args [][]byte) redis.Reply + func StartMulti(conn redis.Connection) redis.Reply + func Watch(db *DB, conn redis.Connection, args [][]byte) redis.Reply + type CmdLine = [][]byte + type DB struct + func (db *DB) Exec(c redis.Connection, cmdLine [][]byte) redis.Reply + func (db *DB) ExecMulti(conn redis.Connection, watching map[string]uint32, cmdLines []CmdLine) redis.Reply + func (db *DB) Expire(key string, expireTime time.Time) + func (db *DB) Flush() + func (db *DB) ForEach(cb func(key string, data *database.DataEntity, expiration *time.Time) bool) + func (db *DB) GetEntity(key string) (*database.DataEntity, bool) + func (db *DB) GetUndoLogs(cmdLine [][]byte) []CmdLine + func (db *DB) GetVersion(key string) uint32 + func (db *DB) IsExpired(key string) bool + func (db *DB) Persist(key string) + func (db *DB) PutEntity(key string, entity *database.DataEntity) int + func (db *DB) PutIfAbsent(key string, entity *database.DataEntity) int + func (db *DB) PutIfExists(key string, entity *database.DataEntity) int + func (db *DB) RWLocks(writeKeys []string, readKeys []string) + func (db *DB) RWUnLocks(writeKeys []string, readKeys []string) + func (db *DB) Remove(key string) + func (db *DB) Removes(keys ...string) (deleted int) + type ExecFunc func(db *DB, args [][]byte) redis.Reply + type MultiDB struct + func MakeBasicMultiDB() *MultiDB + func NewStandaloneServer() *MultiDB + func (mdb *MultiDB) AfterClientClose(c redis.Connection) + func (mdb *MultiDB) Close() + func (mdb *MultiDB) Exec(c redis.Connection, cmdLine [][]byte) (result redis.Reply) + func (mdb *MultiDB) ExecMulti(conn redis.Connection, watching map[string]uint32, cmdLines []CmdLine) redis.Reply + func (mdb *MultiDB) ExecWithLock(conn redis.Connection, cmdLine [][]byte) redis.Reply + func (mdb *MultiDB) ForEach(dbIndex int, ...) + func (mdb *MultiDB) GetDBSize(dbIndex int) (int, int) + func (mdb *MultiDB) GetUndoLogs(dbIndex int, cmdLine [][]byte) []CmdLine + func (mdb *MultiDB) RWLocks(dbIndex int, writeKeys []string, readKeys []string) + func (mdb *MultiDB) RWUnLocks(dbIndex int, writeKeys []string, readKeys []string) + type PreFunc func(args [][]byte) ([]string, []string) + type UndoFunc func(db *DB, args [][]byte) []CmdLine