MCPcopy Create free account
hub / github.com/apache/kvrocks-controller / Node

Interface Node

store/cluster_node.go:57–77  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

55)
56
57type Node interface {
58 ID() string
59 Password() string
60 Addr() string
61 IsMaster() bool
62
63 SetRole(string)
64 SetPassword(string)
65
66 Reset(ctx context.Context) error
67 GetClusterNodeInfo(ctx context.Context) (*ClusterNodeInfo, error)
68 GetClusterInfo(ctx context.Context) (*ClusterInfo, error)
69 SyncClusterInfo(ctx context.Context, cluster *Cluster) error
70 CheckClusterMode(ctx context.Context) (int64, error)
71 MigrateSlot(ctx context.Context, slot SlotRange, NodeID string) error
72
73 MarshalJSON() ([]byte, error)
74 UnmarshalJSON(data []byte) error
75
76 GetClusterNodesString(ctx context.Context) (string, error)
77}
78
79type ClusterNode struct {
80 id string

Callers 71

becomeLeaderMethod · 0.65
syncLoopMethod · 0.65
TestCluster_FailureCountFunction · 0.65
increaseFailureCountMethod · 0.65
syncClusterToNodesMethod · 0.65
parallelProbeNodesMethod · 0.65
IsLeaderMethod · 0.65
parallelProbeNodesMethod · 0.65
TestCluster_FailureCountFunction · 0.65
increaseFailureCountMethod · 0.65
syncClusterToNodesMethod · 0.65

Implementers 1

ClusterNodestore/cluster_node.go

Calls

no outgoing calls

Tested by

no test coverage detected