Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowKeyspacepb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthKeyspacepb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupKeyspacepb = fmt.Errorf("proto: unexpected end of group") + var KeyspaceState_name = map[int32]string + var KeyspaceState_value = map[string]int32 + func RegisterKeyspaceServer(s *grpc.Server, srv KeyspaceServer) + type KeyspaceClient interface + LoadKeyspace func(ctx context.Context, in *LoadKeyspaceRequest, opts ...grpc.CallOption) (*LoadKeyspaceResponse, error) + UpdateKeyspaceState func(ctx context.Context, in *UpdateKeyspaceStateRequest, opts ...grpc.CallOption) (*UpdateKeyspaceStateResponse, error) + WatchKeyspaces func(ctx context.Context, in *WatchKeyspacesRequest, opts ...grpc.CallOption) (Keyspace_WatchKeyspacesClient, error) + func NewKeyspaceClient(cc *grpc.ClientConn) KeyspaceClient + type KeyspaceMeta struct + Config map[string]string + CreatedAt int64 + Id uint32 + Name string + State KeyspaceState + StateChangedAt int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyspaceMeta) Descriptor() ([]byte, []int) + func (*KeyspaceMeta) ProtoMessage() + func (m *KeyspaceMeta) GetConfig() map[string]string + func (m *KeyspaceMeta) GetCreatedAt() int64 + func (m *KeyspaceMeta) GetId() uint32 + func (m *KeyspaceMeta) GetName() string + func (m *KeyspaceMeta) GetState() KeyspaceState + func (m *KeyspaceMeta) GetStateChangedAt() int64 + func (m *KeyspaceMeta) Marshal() (dAtA []byte, err error) + func (m *KeyspaceMeta) MarshalTo(dAtA []byte) (int, error) + func (m *KeyspaceMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyspaceMeta) Reset() + func (m *KeyspaceMeta) Size() (n int) + func (m *KeyspaceMeta) String() string + func (m *KeyspaceMeta) Unmarshal(dAtA []byte) error + func (m *KeyspaceMeta) XXX_DiscardUnknown() + func (m *KeyspaceMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyspaceMeta) XXX_Merge(src proto.Message) + func (m *KeyspaceMeta) XXX_Size() int + func (m *KeyspaceMeta) XXX_Unmarshal(b []byte) error + type KeyspaceServer interface + LoadKeyspace func(context.Context, *LoadKeyspaceRequest) (*LoadKeyspaceResponse, error) + UpdateKeyspaceState func(context.Context, *UpdateKeyspaceStateRequest) (*UpdateKeyspaceStateResponse, error) + WatchKeyspaces func(*WatchKeyspacesRequest, Keyspace_WatchKeyspacesServer) error + type KeyspaceState int32 + const KeyspaceState_ARCHIVED + const KeyspaceState_DISABLED + const KeyspaceState_ENABLED + const KeyspaceState_TOMBSTONE + func (KeyspaceState) EnumDescriptor() ([]byte, []int) + func (x KeyspaceState) String() string + type Keyspace_WatchKeyspacesClient interface + Recv func() (*WatchKeyspacesResponse, error) + type Keyspace_WatchKeyspacesServer interface + Send func(*WatchKeyspacesResponse) error + type LoadKeyspaceRequest struct + Header *tmpb.RequestHeader + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadKeyspaceRequest) Descriptor() ([]byte, []int) + func (*LoadKeyspaceRequest) ProtoMessage() + func (m *LoadKeyspaceRequest) GetHeader() *tmpb.RequestHeader + func (m *LoadKeyspaceRequest) GetName() string + func (m *LoadKeyspaceRequest) Marshal() (dAtA []byte, err error) + func (m *LoadKeyspaceRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LoadKeyspaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LoadKeyspaceRequest) Reset() + func (m *LoadKeyspaceRequest) Size() (n int) + func (m *LoadKeyspaceRequest) String() string + func (m *LoadKeyspaceRequest) Unmarshal(dAtA []byte) error + func (m *LoadKeyspaceRequest) XXX_DiscardUnknown() + func (m *LoadKeyspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadKeyspaceRequest) XXX_Merge(src proto.Message) + func (m *LoadKeyspaceRequest) XXX_Size() int + func (m *LoadKeyspaceRequest) XXX_Unmarshal(b []byte) error + type LoadKeyspaceResponse struct + Header *tmpb.ResponseHeader + Keyspace *KeyspaceMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadKeyspaceResponse) Descriptor() ([]byte, []int) + func (*LoadKeyspaceResponse) ProtoMessage() + func (m *LoadKeyspaceResponse) GetHeader() *tmpb.ResponseHeader + func (m *LoadKeyspaceResponse) GetKeyspace() *KeyspaceMeta + func (m *LoadKeyspaceResponse) Marshal() (dAtA []byte, err error) + func (m *LoadKeyspaceResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LoadKeyspaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LoadKeyspaceResponse) Reset() + func (m *LoadKeyspaceResponse) Size() (n int) + func (m *LoadKeyspaceResponse) String() string + func (m *LoadKeyspaceResponse) Unmarshal(dAtA []byte) error + func (m *LoadKeyspaceResponse) XXX_DiscardUnknown() + func (m *LoadKeyspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadKeyspaceResponse) XXX_Merge(src proto.Message) + func (m *LoadKeyspaceResponse) XXX_Size() int + func (m *LoadKeyspaceResponse) XXX_Unmarshal(b []byte) error + type UnimplementedKeyspaceServer struct + func (*UnimplementedKeyspaceServer) LoadKeyspace(ctx context.Context, req *LoadKeyspaceRequest) (*LoadKeyspaceResponse, error) + func (*UnimplementedKeyspaceServer) UpdateKeyspaceState(ctx context.Context, req *UpdateKeyspaceStateRequest) (*UpdateKeyspaceStateResponse, error) + func (*UnimplementedKeyspaceServer) WatchKeyspaces(req *WatchKeyspacesRequest, srv Keyspace_WatchKeyspacesServer) error + type UpdateKeyspaceStateRequest struct + Header *tmpb.RequestHeader + Id uint32 + State KeyspaceState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateKeyspaceStateRequest) Descriptor() ([]byte, []int) + func (*UpdateKeyspaceStateRequest) ProtoMessage() + func (m *UpdateKeyspaceStateRequest) GetHeader() *tmpb.RequestHeader + func (m *UpdateKeyspaceStateRequest) GetId() uint32 + func (m *UpdateKeyspaceStateRequest) GetState() KeyspaceState + func (m *UpdateKeyspaceStateRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateKeyspaceStateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateKeyspaceStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateKeyspaceStateRequest) Reset() + func (m *UpdateKeyspaceStateRequest) Size() (n int) + func (m *UpdateKeyspaceStateRequest) String() string + func (m *UpdateKeyspaceStateRequest) Unmarshal(dAtA []byte) error + func (m *UpdateKeyspaceStateRequest) XXX_DiscardUnknown() + func (m *UpdateKeyspaceStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateKeyspaceStateRequest) XXX_Merge(src proto.Message) + func (m *UpdateKeyspaceStateRequest) XXX_Size() int + func (m *UpdateKeyspaceStateRequest) XXX_Unmarshal(b []byte) error + type UpdateKeyspaceStateResponse struct + Header *tmpb.ResponseHeader + Keyspace *KeyspaceMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateKeyspaceStateResponse) Descriptor() ([]byte, []int) + func (*UpdateKeyspaceStateResponse) ProtoMessage() + func (m *UpdateKeyspaceStateResponse) GetHeader() *tmpb.ResponseHeader + func (m *UpdateKeyspaceStateResponse) GetKeyspace() *KeyspaceMeta + func (m *UpdateKeyspaceStateResponse) Marshal() (dAtA []byte, err error) + func (m *UpdateKeyspaceStateResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateKeyspaceStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateKeyspaceStateResponse) Reset() + func (m *UpdateKeyspaceStateResponse) Size() (n int) + func (m *UpdateKeyspaceStateResponse) String() string + func (m *UpdateKeyspaceStateResponse) Unmarshal(dAtA []byte) error + func (m *UpdateKeyspaceStateResponse) XXX_DiscardUnknown() + func (m *UpdateKeyspaceStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateKeyspaceStateResponse) XXX_Merge(src proto.Message) + func (m *UpdateKeyspaceStateResponse) XXX_Size() int + func (m *UpdateKeyspaceStateResponse) XXX_Unmarshal(b []byte) error + type WatchKeyspacesRequest struct + Header *tmpb.RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchKeyspacesRequest) Descriptor() ([]byte, []int) + func (*WatchKeyspacesRequest) ProtoMessage() + func (m *WatchKeyspacesRequest) GetHeader() *tmpb.RequestHeader + func (m *WatchKeyspacesRequest) Marshal() (dAtA []byte, err error) + func (m *WatchKeyspacesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WatchKeyspacesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WatchKeyspacesRequest) Reset() + func (m *WatchKeyspacesRequest) Size() (n int) + func (m *WatchKeyspacesRequest) String() string + func (m *WatchKeyspacesRequest) Unmarshal(dAtA []byte) error + func (m *WatchKeyspacesRequest) XXX_DiscardUnknown() + func (m *WatchKeyspacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchKeyspacesRequest) XXX_Merge(src proto.Message) + func (m *WatchKeyspacesRequest) XXX_Size() int + func (m *WatchKeyspacesRequest) XXX_Unmarshal(b []byte) error + type WatchKeyspacesResponse struct + Header *tmpb.ResponseHeader + Keyspaces []*KeyspaceMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchKeyspacesResponse) Descriptor() ([]byte, []int) + func (*WatchKeyspacesResponse) ProtoMessage() + func (m *WatchKeyspacesResponse) GetHeader() *tmpb.ResponseHeader + func (m *WatchKeyspacesResponse) GetKeyspaces() []*KeyspaceMeta + func (m *WatchKeyspacesResponse) Marshal() (dAtA []byte, err error) + func (m *WatchKeyspacesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WatchKeyspacesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WatchKeyspacesResponse) Reset() + func (m *WatchKeyspacesResponse) Size() (n int) + func (m *WatchKeyspacesResponse) String() string + func (m *WatchKeyspacesResponse) Unmarshal(dAtA []byte) error + func (m *WatchKeyspacesResponse) XXX_DiscardUnknown() + func (m *WatchKeyspacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchKeyspacesResponse) XXX_Merge(src proto.Message) + func (m *WatchKeyspacesResponse) XXX_Size() int + func (m *WatchKeyspacesResponse) XXX_Unmarshal(b []byte) error