Versions in this module Expand all Collapse all v1 v1.2.10 Aug 26, 2024 Changes in this version + func Auth(c redis.Connection, args [][]byte) redis.Reply + func BGRewriteAOF(db *Server, args [][]byte) redis.Reply + func BGSaveRDB(db *Server, args [][]byte) redis.Reply + func DbSize(c redis.Connection, db *Server) redis.Reply + func DiscardMulti(conn redis.Connection) redis.Reply + func EnqueueCmd(conn redis.Connection, cmdLine [][]byte) redis.Reply + func GenGodisInfoString(section string, db *Server) []byte + func GetRelatedKeys(cmdLine [][]byte) ([]string, []string) + func Info(db *Server, args [][]byte) redis.Reply + func NewPersister(db database.DBEngine, filename string, load bool, fsync string) (*aof.Persister, error) + func Ping(c redis.Connection, args [][]byte) redis.Reply + func RewriteAOF(db *Server, args [][]byte) redis.Reply + func SaveRDB(db *Server, 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 PreFunc func(args [][]byte) ([]string, []string) + type Server struct + func MakeAuxiliaryServer() *Server + func NewStandaloneServer() *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) GetEntity(dbIndex int, key string) (*database.DataEntity, bool) + func (server *Server) GetExpiration(dbIndex int, key string) *time.Time + 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) + func (server *Server) SetKeyDeletedCallback(cb database.KeyEventCallback) + func (server *Server) SetKeyInsertedCallback(cb database.KeyEventCallback) + type UndoFunc func(db *DB, args [][]byte) []CmdLine
Go to main page