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

Method ListCluster

store/store.go:139–149  ·  view source on GitHub ↗

ListCluster return the list of name of cluster under the specified namespace

(ctx context.Context, ns string)

Source from the content-addressed store, hash-verified

137
138// ListCluster return the list of name of cluster under the specified namespace
139func (s *ClusterStore) ListCluster(ctx context.Context, ns string) ([]string, error) {
140 entries, err := s.e.List(ctx, buildClusterPrefix(ns))
141 if err != nil {
142 return nil, err
143 }
144 keys := make([]string, len(entries))
145 for i, entry := range entries {
146 keys[i] = entry.Key
147 }
148 return keys, nil
149}
150
151func (s *ClusterStore) existsCluster(ctx context.Context, ns, cluster string) (bool, error) {
152 return s.e.Exists(ctx, buildClusterKey(ns, cluster))

Callers 3

RemoveNamespaceMethod · 0.95
CheckNewNodesMethod · 0.95
TestClusterStoreFunction · 0.95

Calls 2

buildClusterPrefixFunction · 0.85
ListMethod · 0.65

Tested by 1

TestClusterStoreFunction · 0.76