store

package

Go to main page

Versions in this module

v1

v1.3.0

Dec 9, 2025

v1.3.0-rc1

Dec 9, 2025

v1.2.0

Oct 2, 2025

Changes in this version

+ const NotMigratingInt

+ func CanMerge(a, b SlotRange) bool

+ type MigratingSlot struct

+ IsMigrating bool

+ func FromSlotRange(slotRange SlotRange) *MigratingSlot

+ func (migratingSlot *MigratingSlot) String() string

+ func (s *MigratingSlot) MarshalJSON() ([]byte, error)

+ func (s *MigratingSlot) Reset()

+ func (s *MigratingSlot) UnmarshalJSON(data []byte) error

type Node

+ GetClusterNodesString func(ctx context.Context) (string, error)

type SlotRange

+ func MergeSlotRanges(a SlotRange, b SlotRange) SlotRange

+ func (s *SlotRange) Reset()

+ func (slotRange *SlotRange) Equal(that SlotRange) bool

type SlotRanges

+ func (SlotRanges *SlotRanges) HasOverlap(slotRange SlotRange) bool

v1.2.0-rc1

Oct 2, 2025

v1.1.0

Jan 19, 2025

Changes in this version

type Cluster

+ func (cluster *Cluster) Clone() *Cluster

+ func (cluster *Cluster) MarshalJSON() ([]byte, error)

+ func (cluster *Cluster) UnmarshalJSON(data []byte) error

type ClusterStore

+ func (s *ClusterStore) GetEngine() engine.Engine

type Shard

+ func (shard *Shard) Clone() *Shard

v1.1.0-rc1

Jan 19, 2025

v1.0.0

Jul 10, 2024

Changes in this version

+ const CommandCreate

+ const CommandRemove

+ const CommandUpdate

+ const MaxSlotID

+ const MinSlotID

+ const NodeIDLen

+ const RoleMaster

+ const RoleSlave

+ var ErrSlotOutOfRange = errors.New("slot id was out of range, should be between 0 and 16383")

+ type Cluster struct

+ Name string

+ Shards []*Shard

+ Version atomic.Int64

+ func NewCluster(name string, nodes []string, replicas int) (*Cluster, error)

+ func ParseCluster(clusterStr string) (*Cluster, error)

+ func (cluster *Cluster) AddNode(shardIndex int, addr, role, password string) error

+ func (cluster *Cluster) GetNodes() []Node

+ func (cluster *Cluster) GetShard(shardIndex int) (*Shard, error)

+ func (cluster *Cluster) MigrateSlot(ctx context.Context, slot int, targetShardIdx int, slotOnly bool) error

+ func (cluster *Cluster) PromoteNewMaster(ctx context.Context, shardIdx int, masterNodeID, preferredNodeID string) (string, error)

+ func (cluster *Cluster) RemoveNode(shardIndex int, nodeID string) error

+ func (cluster *Cluster) Reset(ctx context.Context) error

+ func (cluster *Cluster) SetPassword(password string)

+ func (cluster *Cluster) SetSlot(ctx context.Context, slot int, targetNodeID string) error

+ func (cluster *Cluster) SyncToNodes(ctx context.Context) error

+ func (cluster *Cluster) ToSlotString() (string, error)

+ type ClusterInfo struct

+ CurrentEpoch int64

+ MigratingSlot int

+ MigratingState string

+ type ClusterMockNode struct

+ Sequence uint64

+ func NewClusterMockNode() *ClusterMockNode

+ func (mock *ClusterMockNode) GetClusterInfo(ctx context.Context) (*ClusterInfo, error)

+ func (mock *ClusterMockNode) GetClusterNodeInfo(ctx context.Context) (*ClusterNodeInfo, error)

+ func (mock *ClusterMockNode) Reset(ctx context.Context) error

+ func (mock *ClusterMockNode) SyncClusterInfo(ctx context.Context, cluster *Cluster) error

+ type ClusterNode struct

+ func NewClusterNode(addr, password string) *ClusterNode

+ func (n *ClusterNode) Addr() string

+ func (n *ClusterNode) CheckClusterMode(ctx context.Context) (int64, error)

+ func (n *ClusterNode) GetClient() *redis.Client

+ func (n *ClusterNode) GetClusterInfo(ctx context.Context) (*ClusterInfo, error)

+ func (n *ClusterNode) GetClusterNodeInfo(ctx context.Context) (*ClusterNodeInfo, error)

+ func (n *ClusterNode) GetClusterNodesString(ctx context.Context) (string, error)

+ func (n *ClusterNode) ID() string

+ func (n *ClusterNode) IsMaster() bool

+ func (n *ClusterNode) MarshalJSON() ([]byte, error)

+ func (n *ClusterNode) MigrateSlot(ctx context.Context, slot int, targetNodeID string) error

+ func (n *ClusterNode) Password() string

+ func (n *ClusterNode) Reset(ctx context.Context) error

+ func (n *ClusterNode) SetPassword(password string)

+ func (n *ClusterNode) SetRole(role string)

+ func (n *ClusterNode) SyncClusterInfo(ctx context.Context, cluster *Cluster) error

+ func (n *ClusterNode) UnmarshalJSON(bytes []byte) error

+ func (n *ClusterNode) Validate() error

+ type ClusterNodeInfo struct

+ Role string

+ Sequence uint64

+ type ClusterStore struct

+ func NewClusterStore(e engine.Engine) *ClusterStore

+ func (s *ClusterStore) CheckNewNodes(ctx context.Context, nodes []string) error

+ func (s *ClusterStore) Close() error

+ func (s *ClusterStore) CreateCluster(ctx context.Context, ns string, clusterInfo *Cluster) error

+ func (s *ClusterStore) CreateNamespace(ctx context.Context, ns string) error

+ func (s *ClusterStore) EmitEvent(event EventPayload)

+ func (s *ClusterStore) ExistsNamespace(ctx context.Context, ns string) (bool, error)

+ func (s *ClusterStore) GetCluster(ctx context.Context, ns, cluster string) (*Cluster, error)

+ func (s *ClusterStore) ID() string

+ func (s *ClusterStore) IsLeader() bool

+ func (s *ClusterStore) IsReady(ctx context.Context) bool

+ func (s *ClusterStore) Leader() string

+ func (s *ClusterStore) LeaderChange() <-chan bool

+ func (s *ClusterStore) ListCluster(ctx context.Context, ns string) ([]string, error)

+ func (s *ClusterStore) ListNamespace(ctx context.Context) ([]string, error)

+ func (s *ClusterStore) Notify() <-chan EventPayload

+ func (s *ClusterStore) RemoveCluster(ctx context.Context, ns, cluster string) error

+ func (s *ClusterStore) RemoveNamespace(ctx context.Context, ns string) error

+ func (s *ClusterStore) SetCluster(ctx context.Context, ns string, clusterInfo *Cluster) error

+ func (s *ClusterStore) Stop() error

+ func (s *ClusterStore) UpdateCluster(ctx context.Context, ns string, clusterInfo *Cluster) error

+ type Command int

+ type EventPayload struct

+ Cluster string

+ Command Command

+ Namespace string

+ Type EventType

+ type EventType int

+ const EventCluster

+ const EventNamespace

+ type Node interface

+ Addr func() string

+ CheckClusterMode func(ctx context.Context) (int64, error)

+ GetClusterInfo func(ctx context.Context) (*ClusterInfo, error)

+ GetClusterNodeInfo func(ctx context.Context) (*ClusterNodeInfo, error)

+ ID func() string

+ IsMaster func() bool

+ MarshalJSON func() ([]byte, error)

+ MigrateSlot func(ctx context.Context, slot int, NodeID string) error

+ Password func() string

+ Reset func(ctx context.Context) error

+ SetPassword func(string)

+ SetRole func(string)

+ SyncClusterInfo func(ctx context.Context, cluster *Cluster) error

+ UnmarshalJSON func(data []byte) error

+ type Shard struct

+ MigratingSlot int

+ Nodes []Node

+ SlotRanges []SlotRange

+ TargetShardIndex int

+ func NewShard() *Shard

+ func (shard *Shard) ClearMigrateState()

+ func (shard *Shard) GetMasterNode() Node

+ func (shard *Shard) HasOverlap(slotRange *SlotRange) bool

+ func (shard *Shard) IsMigrating() bool

+ func (shard *Shard) IsServicing() bool

+ func (shard *Shard) ToSlotsString() (string, error)

+ func (shard *Shard) UnmarshalJSON(bytes []byte) error

+ type Shards []*Shard

+ func (s Shards) Len() int

+ func (s Shards) Less(i, j int) bool

+ func (s Shards) Swap(i, j int)

+ type SlotRange struct

+ Start int

+ Stop int

+ func NewSlotRange(start, stop int) (*SlotRange, error)

+ func ParseSlotRange(s string) (*SlotRange, error)

+ func (slotRange *SlotRange) Contains(slot int) bool

+ func (slotRange *SlotRange) HasOverlap(that *SlotRange) bool

+ func (slotRange *SlotRange) MarshalJSON() ([]byte, error)

+ func (slotRange *SlotRange) String() string

+ func (slotRange *SlotRange) UnmarshalJSON(data []byte) error

+ type SlotRanges []SlotRange

+ func AddSlotToSlotRanges(source SlotRanges, slot int) SlotRanges

+ func CalculateSlotRanges(n int) SlotRanges

+ func RemoveSlotFromSlotRanges(source SlotRanges, slot int) SlotRanges

+ func (SlotRanges *SlotRanges) Contains(slot int) bool

+ type Store interface

+ CheckNewNodes func(ctx context.Context, nodes []string) error

+ CreateCluster func(ctx context.Context, ns string, cluster *Cluster) error

+ CreateNamespace func(ctx context.Context, ns string) error

+ ExistsNamespace func(ctx context.Context, ns string) (bool, error)

+ GetCluster func(ctx context.Context, ns, cluster string) (*Cluster, error)

+ IsReady func(ctx context.Context) bool

+ ListCluster func(ctx context.Context, ns string) ([]string, error)

+ ListNamespace func(ctx context.Context) ([]string, error)

+ RemoveCluster func(ctx context.Context, ns, cluster string) error

+ RemoveNamespace func(ctx context.Context, ns string) error

+ SetCluster func(ctx context.Context, ns string, clusterInfo *Cluster) error

+ UpdateCluster func(ctx context.Context, ns string, cluster *Cluster) error

v1.0.0-rc1

Jul 10, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL