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

Method sendSyncEvent

controller/cluster.go:175–181  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

173}
174
175func (c *ClusterChecker) sendSyncEvent() {
176 select {
177 case c.syncCh <- struct{}{}:
178 case <-c.ctx.Done():
179 return
180 }
181}
182
183func (c *ClusterChecker) syncClusterToNodes(ctx context.Context) error {
184 clusterInfo, err := c.clusterStore.GetCluster(ctx, c.namespace, c.clusterName)

Callers 2

TestCluster_LoadAndProbeFunction · 0.95
updateClusterMethod · 0.80

Calls

no outgoing calls

Tested by 1

TestCluster_LoadAndProbeFunction · 0.76