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

Method RemovePeer

store/engine/raft/node.go:355–361  ·  view source on GitHub ↗
(ctx context.Context, nodeID uint64)

Source from the content-addressed store, hash-verified

353}
354
355func (n *Node) RemovePeer(ctx context.Context, nodeID uint64) error {
356 cc := raftpb.ConfChange{
357 Type: raftpb.ConfChangeRemoveNode,
358 NodeID: nodeID,
359 }
360 return n.raftNode.ProposeConfChange(ctx, cc)
361}
362
363func (n *Node) ID() string {
364 return fmt.Sprintf("%d", n.config.ID)

Callers 3

RemoveNodeMethod · 0.95
applyEntryMethod · 0.80
UpdatePeerMethod · 0.80

Implementers 1

ClusterNodestore/cluster_node.go

Calls

no outgoing calls

Tested by 1

RemoveNodeMethod · 0.76