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

Function NewMockClusterStore

controller/cluster_test.go:43–48  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

41}
42
43func NewMockClusterStore() *MockClusterStore {
44 return &MockClusterStore{
45 ClusterStore: store.NewClusterStore(engine.NewMock()),
46 clusters: make(map[string]*store.Cluster),
47 }
48}
49
50func (s *MockClusterStore) CreateCluster(ctx context.Context, ns string, cluster *store.Cluster) error {
51 s.mu.Lock()

Callers 3

TestCluster_FailureCountFunction · 0.85
TestCluster_LoadAndProbeFunction · 0.85
TestCluster_MigrateSlotFunction · 0.85

Calls 2

NewClusterStoreFunction · 0.92
NewMockFunction · 0.92

Tested by

no test coverage detected