Versions in this module Expand all Collapse all v0 v0.1.0 Jun 23, 2026 Changes in this version + func CountSnapshot(snap rdb.Snapshot, onlyDB int) int + func LoadSnapshot(ks *keyspace.Keyspace, snap rdb.Snapshot, onlyDB int, replace bool) (int, error) + func SnapshotKeyspace(ks *keyspace.Keyspace) (rdb.Snapshot, error) + type CmdDesc struct + Arity int + FirstKey int + Flags FlagSet + Group CmdGroup + Handler func(ctx *Ctx) + LastKey int + Name string + Since string + Step int + SubCmds []*CmdDesc + SubName string + type CmdGroup uint8 + const GroupBitmap + const GroupCluster + const GroupConnection + const GroupGeneric + const GroupGeo + const GroupHash + const GroupHyperLogLog + const GroupList + const GroupPubSub + const GroupScripting + const GroupServer + const GroupSet + const GroupSortedSet + const GroupStream + const GroupString + const GroupTransactions + type Config struct + AclFile string + Databases int + Engine *Engine + Mode string + RequirePass string + Version string + type Ctx struct + Argv [][]byte + Conn *networking.Conn + func (ctx *Ctx) MarkPropagate() + type Dispatcher struct + func New(cfg Config) *Dispatcher + func (d *Dispatcher) AdminAddr() string + func (d *Dispatcher) ApplyGCTuning() + func (d *Dispatcher) ApplyNetworkConfig() + func (d *Dispatcher) Handle(c *networking.Conn, argv [][]byte) + func (d *Dispatcher) LoadACLFromKeyspace() error + func (d *Dispatcher) LoadFunctions(sources []string) + func (d *Dispatcher) LoadFunctionsFromKeyspace() error + func (d *Dispatcher) LoadScriptsFromKeyspace() error + func (d *Dispatcher) LogClose() + func (d *Dispatcher) LogNotice(msg string, kv ...any) + func (d *Dispatcher) LogStart() error + func (d *Dispatcher) MetricsAddr() string + func (d *Dispatcher) OnDisconnect(c *networking.Conn) + func (d *Dispatcher) OnPanic(cause any, stack []byte) + func (d *Dispatcher) PersistFunctions() + func (d *Dispatcher) ReopenLog() error + func (d *Dispatcher) SetConfig(name, value string) error + func (d *Dispatcher) SetReady(v bool) + func (d *Dispatcher) SetServer(s *networking.Server) + func (d *Dispatcher) SetShutdown(fn func()) + func (d *Dispatcher) StartAdmin() error + func (d *Dispatcher) StartBackground() + func (d *Dispatcher) StartMetrics() error + func (d *Dispatcher) StartProfiler() error + func (d *Dispatcher) StopAdmin() + func (d *Dispatcher) StopBackground() + func (d *Dispatcher) StopMetrics() + func (d *Dispatcher) StopProfiler() + func (d *Dispatcher) StopReplication() + func (d *Dispatcher) WriteCrashReport(cause any, stack []byte) + type Engine struct + func NewEngine(ks *keyspace.Keyspace) *Engine + type FlagSet uint64 + const FlagAdmin + const FlagAllowBusy + const FlagBlocking + const FlagDenyOOM + const FlagFast + const FlagLoading + const FlagMovableKeys + const FlagNoAuth + const FlagNoMandatoryKeys + const FlagNoMulti + const FlagNoScript + const FlagPubSub + const FlagReadOnly + const FlagStale + const FlagWrite + func (s FlagSet) Has(f FlagSet) bool + type Table struct + func NewTable(cmds []*CmdDesc) *Table + func (t *Table) Count() int
Go to main page