From 44d4466bf7b3bbbef6db34c4359569908f267a7e Mon Sep 17 00:00:00 2001 From: ystaticy Date: Thu, 13 Jul 2023 14:45:53 +0800 Subject: [PATCH] get all keyspaces Signed-off-by: ystaticy --- client/keyspace_client.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/client/keyspace_client.go b/client/keyspace_client.go index f18055f22e5..d9b9172dd69 100644 --- a/client/keyspace_client.go +++ b/client/keyspace_client.go @@ -30,6 +30,8 @@ type KeyspaceClient interface { LoadKeyspace(ctx context.Context, name string) (*keyspacepb.KeyspaceMeta, error) // UpdateKeyspaceState updates target keyspace's state. UpdateKeyspaceState(ctx context.Context, id uint32, state keyspacepb.KeyspaceState) (*keyspacepb.KeyspaceMeta, error) + // WatchKeyspaces watches keyspace meta changes. + WatchKeyspaces(ctx context.Context) (chan []*keyspacepb.KeyspaceMeta, error) // GetAllKeyspaces get all keyspace's metadata. GetAllKeyspaces(ctx context.Context, startID uint32, limit uint32) ([]*keyspacepb.KeyspaceMeta, error) } @@ -114,6 +116,14 @@ func (c *client) UpdateKeyspaceState(ctx context.Context, id uint32, state keysp return resp.Keyspace, nil } +// WatchKeyspaces watches keyspace meta changes. +// It returns a stream of slices of keyspace metadata. +// The first message in stream contains all current keyspaceMeta, +// all subsequent messages contains new put events for all keyspaces. +func (c *client) WatchKeyspaces(ctx context.Context) (chan []*keyspacepb.KeyspaceMeta, error) { + return nil, errors.Errorf("WatchKeyspaces unimplemented") +} + // GetAllKeyspaces get all keyspaces metadata. func (c *client) GetAllKeyspaces(ctx context.Context, startID uint32, limit uint32) ([]*keyspacepb.KeyspaceMeta, error) { if span := opentracing.SpanFromContext(ctx); span != nil {