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

Method MigrateSlot

store/cluster_node.go:264–266  ·  view source on GitHub ↗
(ctx context.Context, slot SlotRange, targetNodeID string)

Source from the content-addressed store, hash-verified

262}
263
264func (n *ClusterNode) MigrateSlot(ctx context.Context, slot SlotRange, targetNodeID string) error {
265 return n.GetClient().Do(ctx, "CLUSTERX", "MIGRATE", slot.String(), targetNodeID).Err()
266}
267
268func (n *ClusterNode) MarshalJSON() ([]byte, error) {
269 return json.Marshal(map[string]interface{}{

Callers

nothing calls this directly

Calls 2

GetClientMethod · 0.95
StringMethod · 0.45

Tested by

no test coverage detected