Versions in this module Expand all Collapse all v1 v1.2.10 Aug 26, 2024 Changes in this version + func Copy(cluster *Cluster, c redis.Connection, args [][]byte) redis.Reply + func Del(cluster *Cluster, c redis.Connection, args [][]byte) redis.Reply + func FlushAll(cluster *Cluster, c redis.Connection, args [][]byte) redis.Reply + func FlushDB(cluster *Cluster, c redis.Connection, cmdLine [][]byte) redis.Reply + func MGet(cluster *Cluster, c redis.Connection, cmdLine CmdLine) redis.Reply + func MSet(cluster *Cluster, c redis.Connection, cmdLine CmdLine) redis.Reply + func MSetNX(cluster *Cluster, c redis.Connection, cmdLine CmdLine) redis.Reply + func Publish(cluster *Cluster, c redis.Connection, cmdLine [][]byte) redis.Reply + func Rename(cluster *Cluster, c redis.Connection, cmdLine [][]byte) redis.Reply + func RenameNx(cluster *Cluster, c redis.Connection, cmdLine [][]byte) redis.Reply + func Subscribe(cluster *Cluster, c redis.Connection, args [][]byte) redis.Reply + func UnSubscribe(cluster *Cluster, c redis.Connection, args [][]byte) redis.Reply + type Cluster struct + func MakeCluster() *Cluster + func (cluster *Cluster) AfterClientClose(c redis.Connection) + func (cluster *Cluster) Close() + func (cluster *Cluster) Exec(c redis.Connection, cmdLine [][]byte) (result redis.Reply) + func (cluster *Cluster) Join(seed string) protocol.ErrorReply + func (cluster *Cluster) LoadConfig() protocol.ErrorReply + func (cluster *Cluster) LoadRDB(dec *core.Decoder) error + type CmdFunc func(cluster *Cluster, c redis.Connection, cmdLine CmdLine) redis.Reply + type CmdLine = [][]byte + type Node struct + Addr string + Flags uint32 + ID string + Slots []*Slot + type Raft struct + func (raft *Raft) Close() error + func (raft *Raft) GetNode(nodeID string) *Node + func (raft *Raft) GetNodes() []*Node + func (raft *Raft) GetSelfNodeID() string + func (raft *Raft) GetSlots() []*Slot + func (raft *Raft) Join(seed string) protocol.ErrorReply + func (raft *Raft) LoadConfigFile() protocol.ErrorReply + func (raft *Raft) NewNode(addr string) (*Node, error) + func (raft *Raft) SetSlot(slotIDs []uint32, newNodeID string) protocol.ErrorReply + func (raft *Raft) StartAsSeed(listenAddr string) protocol.ErrorReply + type Slot struct + Flags uint32 + ID uint32 + NodeID string + type Transaction struct + func NewTransaction(cluster *Cluster, c redis.Connection, id string, cmdLine [][]byte) *Transaction
Go to main page