keyspacepb

package
v0.0.0-...-65b4e27 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 3, 2026 License: Apache-2.0 Imports: 12 Imported by: 26

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthKeyspacepb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKeyspacepb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupKeyspacepb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var KeyspaceState_name = map[int32]string{
	0: "ENABLED",
	1: "DISABLED",
	2: "ARCHIVED",
	3: "TOMBSTONE",
}
View Source 
var KeyspaceState_value = map[string]int32{
	"ENABLED":   0,
	"DISABLED":  1,
	"ARCHIVED":  2,
	"TOMBSTONE": 3,
}

Functions

func RegisterKeyspaceServer 

func RegisterKeyspaceServer(s *grpc.Server, srv KeyspaceServer)

func RegisterNamespaceServer 

func RegisterNamespaceServer(s *grpc.Server, srv NamespaceServer)

Types

type CreateNamespaceRequest 

type CreateNamespaceRequest struct {
	Header *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Name   string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Config map[string]string   `` /* 153-byte string literal not displayed */
}

func (*CreateNamespaceRequest) Descriptor 

func (*CreateNamespaceRequest) Descriptor() ([]byte, []int)

func (*CreateNamespaceRequest) GetConfig 

func (m *CreateNamespaceRequest) GetConfig() map[string]string

func (*CreateNamespaceRequest) GetHeader 

func (m *CreateNamespaceRequest) GetHeader() *pdpb.RequestHeader

func (*CreateNamespaceRequest) GetName 

func (m *CreateNamespaceRequest) GetName() string

func (*CreateNamespaceRequest) Marshal 

func (m *CreateNamespaceRequest) Marshal() (dAtA []byte, err error)

func (*CreateNamespaceRequest) MarshalTo 

func (m *CreateNamespaceRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateNamespaceRequest) MarshalToSizedBuffer 

func (m *CreateNamespaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateNamespaceRequest) ProtoMessage 

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) Reset 

func (m *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) Size 

func (m *CreateNamespaceRequest) Size() (n int)

func (*CreateNamespaceRequest) String 

func (m *CreateNamespaceRequest) String() string

func (*CreateNamespaceRequest) Unmarshal 

func (m *CreateNamespaceRequest) Unmarshal(dAtA []byte) error

func (*CreateNamespaceRequest) XXX_DiscardUnknown 

func (m *CreateNamespaceRequest) XXX_DiscardUnknown()

func (*CreateNamespaceRequest) XXX_Marshal 

func (m *CreateNamespaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateNamespaceRequest) XXX_Merge 

func (m *CreateNamespaceRequest) XXX_Merge(src proto.Message)

func (*CreateNamespaceRequest) XXX_Size 

func (m *CreateNamespaceRequest) XXX_Size() int

func (*CreateNamespaceRequest) XXX_Unmarshal 

func (m *CreateNamespaceRequest) XXX_Unmarshal(b []byte) error

type CreateNamespaceResponse 

type CreateNamespaceResponse struct {
	Header    *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Namespace *NamespaceMeta       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*CreateNamespaceResponse) Descriptor 

func (*CreateNamespaceResponse) Descriptor() ([]byte, []int)

func (*CreateNamespaceResponse) GetHeader 

func (m *CreateNamespaceResponse) GetHeader() *pdpb.ResponseHeader

func (*CreateNamespaceResponse) GetNamespace 

func (m *CreateNamespaceResponse) GetNamespace() *NamespaceMeta

func (*CreateNamespaceResponse) Marshal 

func (m *CreateNamespaceResponse) Marshal() (dAtA []byte, err error)

func (*CreateNamespaceResponse) MarshalTo 

func (m *CreateNamespaceResponse) MarshalTo(dAtA []byte) (int, error)

func (*CreateNamespaceResponse) MarshalToSizedBuffer 

func (m *CreateNamespaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateNamespaceResponse) ProtoMessage 

func (*CreateNamespaceResponse) ProtoMessage()

func (*CreateNamespaceResponse) Reset 

func (m *CreateNamespaceResponse) Reset()

func (*CreateNamespaceResponse) Size 

func (m *CreateNamespaceResponse) Size() (n int)

func (*CreateNamespaceResponse) String 

func (m *CreateNamespaceResponse) String() string

func (*CreateNamespaceResponse) Unmarshal 

func (m *CreateNamespaceResponse) Unmarshal(dAtA []byte) error

func (*CreateNamespaceResponse) XXX_DiscardUnknown 

func (m *CreateNamespaceResponse) XXX_DiscardUnknown()

func (*CreateNamespaceResponse) XXX_Marshal 

func (m *CreateNamespaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateNamespaceResponse) XXX_Merge 

func (m *CreateNamespaceResponse) XXX_Merge(src proto.Message)

func (*CreateNamespaceResponse) XXX_Size 

func (m *CreateNamespaceResponse) XXX_Size() int

func (*CreateNamespaceResponse) XXX_Unmarshal 

func (m *CreateNamespaceResponse) XXX_Unmarshal(b []byte) error

type GetAllKeyspacesRequest 

type GetAllKeyspacesRequest struct {
	Header *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to StartKeyspace:
	//	*GetAllKeyspacesRequest_StartId
	//	*GetAllKeyspacesRequest_StartKeyspaceIdentity
	StartKeyspace isGetAllKeyspacesRequest_StartKeyspace `protobuf_oneof:"start_keyspace"`
	Limit         uint32                                 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// V3 namespace-scoped pagination. Must be non-zero in V3.
	Namespace *NamespaceRef `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*GetAllKeyspacesRequest) Descriptor 

func (*GetAllKeyspacesRequest) Descriptor() ([]byte, []int)

func (*GetAllKeyspacesRequest) GetHeader 

func (m *GetAllKeyspacesRequest) GetHeader() *pdpb.RequestHeader

func (*GetAllKeyspacesRequest) GetLimit 

func (m *GetAllKeyspacesRequest) GetLimit() uint32

func (*GetAllKeyspacesRequest) GetNamespace 

func (m *GetAllKeyspacesRequest) GetNamespace() *NamespaceRef

func (*GetAllKeyspacesRequest) GetStartId 

func (m *GetAllKeyspacesRequest) GetStartId() uint32

func (*GetAllKeyspacesRequest) GetStartKeyspace 

func (m *GetAllKeyspacesRequest) GetStartKeyspace() isGetAllKeyspacesRequest_StartKeyspace

func (*GetAllKeyspacesRequest) GetStartKeyspaceIdentity 

func (m *GetAllKeyspacesRequest) GetStartKeyspaceIdentity() *apipb.KeyspaceIdentity

func (*GetAllKeyspacesRequest) Marshal 

func (m *GetAllKeyspacesRequest) Marshal() (dAtA []byte, err error)

func (*GetAllKeyspacesRequest) MarshalTo 

func (m *GetAllKeyspacesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetAllKeyspacesRequest) MarshalToSizedBuffer 

func (m *GetAllKeyspacesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllKeyspacesRequest) ProtoMessage 

func (*GetAllKeyspacesRequest) ProtoMessage()

func (*GetAllKeyspacesRequest) Reset 

func (m *GetAllKeyspacesRequest) Reset()

func (*GetAllKeyspacesRequest) Size 

func (m *GetAllKeyspacesRequest) Size() (n int)

func (*GetAllKeyspacesRequest) String 

func (m *GetAllKeyspacesRequest) String() string

func (*GetAllKeyspacesRequest) Unmarshal 

func (m *GetAllKeyspacesRequest) Unmarshal(dAtA []byte) error

func (*GetAllKeyspacesRequest) XXX_DiscardUnknown 

func (m *GetAllKeyspacesRequest) XXX_DiscardUnknown()

func (*GetAllKeyspacesRequest) XXX_Marshal 

func (m *GetAllKeyspacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllKeyspacesRequest) XXX_Merge 

func (m *GetAllKeyspacesRequest) XXX_Merge(src proto.Message)

func (*GetAllKeyspacesRequest) XXX_OneofWrappers 

func (*GetAllKeyspacesRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetAllKeyspacesRequest) XXX_Size 

func (m *GetAllKeyspacesRequest) XXX_Size() int

func (*GetAllKeyspacesRequest) XXX_Unmarshal 

func (m *GetAllKeyspacesRequest) XXX_Unmarshal(b []byte) error

type GetAllKeyspacesRequest_StartId 

type GetAllKeyspacesRequest_StartId struct {
	StartId uint32 `protobuf:"varint,2,opt,name=start_id,json=startId,proto3,oneof" json:"start_id,omitempty"`
}

func (*GetAllKeyspacesRequest_StartId) MarshalTo 

func (m *GetAllKeyspacesRequest_StartId) MarshalTo(dAtA []byte) (int, error)

func (*GetAllKeyspacesRequest_StartId) MarshalToSizedBuffer 

func (m *GetAllKeyspacesRequest_StartId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllKeyspacesRequest_StartId) Size 

func (m *GetAllKeyspacesRequest_StartId) Size() (n int)

type GetAllKeyspacesRequest_StartKeyspaceIdentity 

type GetAllKeyspacesRequest_StartKeyspaceIdentity struct {
	StartKeyspaceIdentity *apipb.KeyspaceIdentity `` /* 132-byte string literal not displayed */
}

func (*GetAllKeyspacesRequest_StartKeyspaceIdentity) MarshalTo 

func (m *GetAllKeyspacesRequest_StartKeyspaceIdentity) MarshalTo(dAtA []byte) (int, error)

func (*GetAllKeyspacesRequest_StartKeyspaceIdentity) MarshalToSizedBuffer 

func (m *GetAllKeyspacesRequest_StartKeyspaceIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllKeyspacesRequest_StartKeyspaceIdentity) Size 

func (m *GetAllKeyspacesRequest_StartKeyspaceIdentity) Size() (n int)

type GetAllKeyspacesResponse 

type GetAllKeyspacesResponse struct {
	Header    *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keyspaces []*KeyspaceMeta      `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
}

func (*GetAllKeyspacesResponse) Descriptor 

func (*GetAllKeyspacesResponse) Descriptor() ([]byte, []int)

func (*GetAllKeyspacesResponse) GetHeader 

func (m *GetAllKeyspacesResponse) GetHeader() *pdpb.ResponseHeader

func (*GetAllKeyspacesResponse) GetKeyspaces 

func (m *GetAllKeyspacesResponse) GetKeyspaces() []*KeyspaceMeta

func (*GetAllKeyspacesResponse) Marshal 

func (m *GetAllKeyspacesResponse) Marshal() (dAtA []byte, err error)

func (*GetAllKeyspacesResponse) MarshalTo 

func (m *GetAllKeyspacesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetAllKeyspacesResponse) MarshalToSizedBuffer 

func (m *GetAllKeyspacesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllKeyspacesResponse) ProtoMessage 

func (*GetAllKeyspacesResponse) ProtoMessage()

func (*GetAllKeyspacesResponse) Reset 

func (m *GetAllKeyspacesResponse) Reset()

func (*GetAllKeyspacesResponse) Size 

func (m *GetAllKeyspacesResponse) Size() (n int)

func (*GetAllKeyspacesResponse) String 

func (m *GetAllKeyspacesResponse) String() string

func (*GetAllKeyspacesResponse) Unmarshal 

func (m *GetAllKeyspacesResponse) Unmarshal(dAtA []byte) error

func (*GetAllKeyspacesResponse) XXX_DiscardUnknown 

func (m *GetAllKeyspacesResponse) XXX_DiscardUnknown()

func (*GetAllKeyspacesResponse) XXX_Marshal 

func (m *GetAllKeyspacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllKeyspacesResponse) XXX_Merge 

func (m *GetAllKeyspacesResponse) XXX_Merge(src proto.Message)

func (*GetAllKeyspacesResponse) XXX_Size 

func (m *GetAllKeyspacesResponse) XXX_Size() int

func (*GetAllKeyspacesResponse) XXX_Unmarshal 

func (m *GetAllKeyspacesResponse) XXX_Unmarshal(b []byte) error

type GetAllNamespacesRequest 

type GetAllNamespacesRequest struct {
	Header  *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	StartId uint32              `protobuf:"varint,2,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"`
	Limit   uint32              `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
}

func (*GetAllNamespacesRequest) Descriptor 

func (*GetAllNamespacesRequest) Descriptor() ([]byte, []int)

func (*GetAllNamespacesRequest) GetHeader 

func (m *GetAllNamespacesRequest) GetHeader() *pdpb.RequestHeader

func (*GetAllNamespacesRequest) GetLimit 

func (m *GetAllNamespacesRequest) GetLimit() uint32

func (*GetAllNamespacesRequest) GetStartId 

func (m *GetAllNamespacesRequest) GetStartId() uint32

func (*GetAllNamespacesRequest) Marshal 

func (m *GetAllNamespacesRequest) Marshal() (dAtA []byte, err error)

func (*GetAllNamespacesRequest) MarshalTo 

func (m *GetAllNamespacesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetAllNamespacesRequest) MarshalToSizedBuffer 

func (m *GetAllNamespacesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllNamespacesRequest) ProtoMessage 

func (*GetAllNamespacesRequest) ProtoMessage()

func (*GetAllNamespacesRequest) Reset 

func (m *GetAllNamespacesRequest) Reset()

func (*GetAllNamespacesRequest) Size 

func (m *GetAllNamespacesRequest) Size() (n int)

func (*GetAllNamespacesRequest) String 

func (m *GetAllNamespacesRequest) String() string

func (*GetAllNamespacesRequest) Unmarshal 

func (m *GetAllNamespacesRequest) Unmarshal(dAtA []byte) error

func (*GetAllNamespacesRequest) XXX_DiscardUnknown 

func (m *GetAllNamespacesRequest) XXX_DiscardUnknown()

func (*GetAllNamespacesRequest) XXX_Marshal 

func (m *GetAllNamespacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllNamespacesRequest) XXX_Merge 

func (m *GetAllNamespacesRequest) XXX_Merge(src proto.Message)

func (*GetAllNamespacesRequest) XXX_Size 

func (m *GetAllNamespacesRequest) XXX_Size() int

func (*GetAllNamespacesRequest) XXX_Unmarshal 

func (m *GetAllNamespacesRequest) XXX_Unmarshal(b []byte) error

type GetAllNamespacesResponse 

type GetAllNamespacesResponse struct {
	Header     *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Namespaces []*NamespaceMeta     `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
}

func (*GetAllNamespacesResponse) Descriptor 

func (*GetAllNamespacesResponse) Descriptor() ([]byte, []int)

func (*GetAllNamespacesResponse) GetHeader 

func (m *GetAllNamespacesResponse) GetHeader() *pdpb.ResponseHeader

func (*GetAllNamespacesResponse) GetNamespaces 

func (m *GetAllNamespacesResponse) GetNamespaces() []*NamespaceMeta

func (*GetAllNamespacesResponse) Marshal 

func (m *GetAllNamespacesResponse) Marshal() (dAtA []byte, err error)

func (*GetAllNamespacesResponse) MarshalTo 

func (m *GetAllNamespacesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetAllNamespacesResponse) MarshalToSizedBuffer 

func (m *GetAllNamespacesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllNamespacesResponse) ProtoMessage 

func (*GetAllNamespacesResponse) ProtoMessage()

func (*GetAllNamespacesResponse) Reset 

func (m *GetAllNamespacesResponse) Reset()

func (*GetAllNamespacesResponse) Size 

func (m *GetAllNamespacesResponse) Size() (n int)

func (*GetAllNamespacesResponse) String 

func (m *GetAllNamespacesResponse) String() string

func (*GetAllNamespacesResponse) Unmarshal 

func (m *GetAllNamespacesResponse) Unmarshal(dAtA []byte) error

func (*GetAllNamespacesResponse) XXX_DiscardUnknown 

func (m *GetAllNamespacesResponse) XXX_DiscardUnknown()

func (*GetAllNamespacesResponse) XXX_Marshal 

func (m *GetAllNamespacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllNamespacesResponse) XXX_Merge 

func (m *GetAllNamespacesResponse) XXX_Merge(src proto.Message)

func (*GetAllNamespacesResponse) XXX_Size 

func (m *GetAllNamespacesResponse) XXX_Size() int

func (*GetAllNamespacesResponse) XXX_Unmarshal 

func (m *GetAllNamespacesResponse) XXX_Unmarshal(b []byte) error

type KeyspaceClient 

type KeyspaceClient interface {
	LoadKeyspace(ctx context.Context, in *LoadKeyspaceRequest, opts ...grpc.CallOption) (*LoadKeyspaceResponse, error)
	LookupKeyspace(ctx context.Context, in *LookupKeyspaceRequest, opts ...grpc.CallOption) (*LookupKeyspaceResponse, error)
	LoadKeyspaceByID(ctx context.Context, in *LoadKeyspaceByIDRequest, opts ...grpc.CallOption) (*LoadKeyspaceResponse, error)
	// WatchKeyspaces first return all current keyspaces' metadata as its first response.
	// Then, it returns responses containing keyspaces that had their metadata changed.
	WatchKeyspaces(ctx context.Context, in *WatchKeyspacesRequest, opts ...grpc.CallOption) (Keyspace_WatchKeyspacesClient, error)
	UpdateKeyspaceState(ctx context.Context, in *UpdateKeyspaceStateRequest, opts ...grpc.CallOption) (*UpdateKeyspaceStateResponse, error)
	GetAllKeyspaces(ctx context.Context, in *GetAllKeyspacesRequest, opts ...grpc.CallOption) (*GetAllKeyspacesResponse, error)
}

KeyspaceClient is the client API for Keyspace service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKeyspaceClient 

func NewKeyspaceClient(cc *grpc.ClientConn) KeyspaceClient

type KeyspaceMeta 

type KeyspaceMeta struct {
	// Types that are valid to be assigned to Keyspace:
	//	*KeyspaceMeta_Id
	//	*KeyspaceMeta_KeyspaceIdentity
	Keyspace       isKeyspaceMeta_Keyspace `protobuf_oneof:"keyspace"`
	Name           string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State          KeyspaceState           `protobuf:"varint,3,opt,name=state,proto3,enum=keyspacepb.KeyspaceState" json:"state,omitempty"`
	CreatedAt      int64                   `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StateChangedAt int64                   `protobuf:"varint,5,opt,name=state_changed_at,json=stateChangedAt,proto3" json:"state_changed_at,omitempty"`
	Config         map[string]string       `` /* 153-byte string literal not displayed */
}

func (*KeyspaceMeta) Descriptor 

func (*KeyspaceMeta) Descriptor() ([]byte, []int)

func (*KeyspaceMeta) GetConfig 

func (m *KeyspaceMeta) GetConfig() map[string]string

func (*KeyspaceMeta) GetCreatedAt 

func (m *KeyspaceMeta) GetCreatedAt() int64

func (*KeyspaceMeta) GetId 

func (m *KeyspaceMeta) GetId() uint32

func (*KeyspaceMeta) GetKeyspace 

func (m *KeyspaceMeta) GetKeyspace() isKeyspaceMeta_Keyspace

func (*KeyspaceMeta) GetKeyspaceIdentity 

func (m *KeyspaceMeta) GetKeyspaceIdentity() *apipb.KeyspaceIdentity

func (*KeyspaceMeta) GetName 

func (m *KeyspaceMeta) GetName() string

func (*KeyspaceMeta) GetState 

func (m *KeyspaceMeta) GetState() KeyspaceState

func (*KeyspaceMeta) GetStateChangedAt 

func (m *KeyspaceMeta) GetStateChangedAt() int64

func (*KeyspaceMeta) Marshal 

func (m *KeyspaceMeta) Marshal() (dAtA []byte, err error)

func (*KeyspaceMeta) MarshalTo 

func (m *KeyspaceMeta) MarshalTo(dAtA []byte) (int, error)

func (*KeyspaceMeta) MarshalToSizedBuffer 

func (m *KeyspaceMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyspaceMeta) ProtoMessage 

func (*KeyspaceMeta) ProtoMessage()

func (*KeyspaceMeta) Reset 

func (m *KeyspaceMeta) Reset()

func (*KeyspaceMeta) Size 

func (m *KeyspaceMeta) Size() (n int)

func (*KeyspaceMeta) String 

func (m *KeyspaceMeta) String() string

func (*KeyspaceMeta) Unmarshal 

func (m *KeyspaceMeta) Unmarshal(dAtA []byte) error

func (*KeyspaceMeta) XXX_DiscardUnknown 

func (m *KeyspaceMeta) XXX_DiscardUnknown()

func (*KeyspaceMeta) XXX_Marshal 

func (m *KeyspaceMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyspaceMeta) XXX_Merge 

func (m *KeyspaceMeta) XXX_Merge(src proto.Message)

func (*KeyspaceMeta) XXX_OneofWrappers 

func (*KeyspaceMeta) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*KeyspaceMeta) XXX_Size 

func (m *KeyspaceMeta) XXX_Size() int

func (*KeyspaceMeta) XXX_Unmarshal 

func (m *KeyspaceMeta) XXX_Unmarshal(b []byte) error

type KeyspaceMeta_Id 

type KeyspaceMeta_Id struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
}

func (*KeyspaceMeta_Id) MarshalTo 

func (m *KeyspaceMeta_Id) MarshalTo(dAtA []byte) (int, error)

func (*KeyspaceMeta_Id) MarshalToSizedBuffer 

func (m *KeyspaceMeta_Id) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyspaceMeta_Id) Size 

func (m *KeyspaceMeta_Id) Size() (n int)

type KeyspaceMeta_KeyspaceIdentity 

type KeyspaceMeta_KeyspaceIdentity struct {
	KeyspaceIdentity *apipb.KeyspaceIdentity `protobuf:"bytes,8,opt,name=keyspace_identity,json=keyspaceIdentity,proto3,oneof" json:"keyspace_identity,omitempty"`
}

func (*KeyspaceMeta_KeyspaceIdentity) MarshalTo 

func (m *KeyspaceMeta_KeyspaceIdentity) MarshalTo(dAtA []byte) (int, error)

func (*KeyspaceMeta_KeyspaceIdentity) MarshalToSizedBuffer 

func (m *KeyspaceMeta_KeyspaceIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyspaceMeta_KeyspaceIdentity) Size 

func (m *KeyspaceMeta_KeyspaceIdentity) Size() (n int)

type KeyspaceServer 

type KeyspaceServer interface {
	LoadKeyspace(context.Context, *LoadKeyspaceRequest) (*LoadKeyspaceResponse, error)
	LookupKeyspace(context.Context, *LookupKeyspaceRequest) (*LookupKeyspaceResponse, error)
	LoadKeyspaceByID(context.Context, *LoadKeyspaceByIDRequest) (*LoadKeyspaceResponse, error)
	// WatchKeyspaces first return all current keyspaces' metadata as its first response.
	// Then, it returns responses containing keyspaces that had their metadata changed.
	WatchKeyspaces(*WatchKeyspacesRequest, Keyspace_WatchKeyspacesServer) error
	UpdateKeyspaceState(context.Context, *UpdateKeyspaceStateRequest) (*UpdateKeyspaceStateResponse, error)
	GetAllKeyspaces(context.Context, *GetAllKeyspacesRequest) (*GetAllKeyspacesResponse, error)
}

KeyspaceServer is the server API for Keyspace service.

type KeyspaceState 

type KeyspaceState int32
const (
	KeyspaceState_ENABLED   KeyspaceState = 0
	KeyspaceState_DISABLED  KeyspaceState = 1
	KeyspaceState_ARCHIVED  KeyspaceState = 2
	KeyspaceState_TOMBSTONE KeyspaceState = 3
)

func (KeyspaceState) EnumDescriptor 

func (KeyspaceState) EnumDescriptor() ([]byte, []int)

func (KeyspaceState) String 

func (x KeyspaceState) String() string

type Keyspace_WatchKeyspacesClient 

type Keyspace_WatchKeyspacesClient interface {
	Recv() (*WatchKeyspacesResponse, error)
	grpc.ClientStream
}

type Keyspace_WatchKeyspacesServer 

type Keyspace_WatchKeyspacesServer interface {
	Send(*WatchKeyspacesResponse) error
	grpc.ServerStream
}

type LoadKeyspaceByIDRequest 

type LoadKeyspaceByIDRequest struct {
	Header *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to Keyspace:
	//	*LoadKeyspaceByIDRequest_Id
	//	*LoadKeyspaceByIDRequest_KeyspaceIdentity
	Keyspace isLoadKeyspaceByIDRequest_Keyspace `protobuf_oneof:"keyspace"`
}

func (*LoadKeyspaceByIDRequest) Descriptor 

func (*LoadKeyspaceByIDRequest) Descriptor() ([]byte, []int)

func (*LoadKeyspaceByIDRequest) GetHeader 

func (m *LoadKeyspaceByIDRequest) GetHeader() *pdpb.RequestHeader

func (*LoadKeyspaceByIDRequest) GetId 

func (m *LoadKeyspaceByIDRequest) GetId() uint32

func (*LoadKeyspaceByIDRequest) GetKeyspace 

func (m *LoadKeyspaceByIDRequest) GetKeyspace() isLoadKeyspaceByIDRequest_Keyspace

func (*LoadKeyspaceByIDRequest) GetKeyspaceIdentity 

func (m *LoadKeyspaceByIDRequest) GetKeyspaceIdentity() *apipb.KeyspaceIdentity

func (*LoadKeyspaceByIDRequest) Marshal 

func (m *LoadKeyspaceByIDRequest) Marshal() (dAtA []byte, err error)

func (*LoadKeyspaceByIDRequest) MarshalTo 

func (m *LoadKeyspaceByIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*LoadKeyspaceByIDRequest) MarshalToSizedBuffer 

func (m *LoadKeyspaceByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadKeyspaceByIDRequest) ProtoMessage 

func (*LoadKeyspaceByIDRequest) ProtoMessage()

func (*LoadKeyspaceByIDRequest) Reset 

func (m *LoadKeyspaceByIDRequest) Reset()

func (*LoadKeyspaceByIDRequest) Size 

func (m *LoadKeyspaceByIDRequest) Size() (n int)

func (*LoadKeyspaceByIDRequest) String 

func (m *LoadKeyspaceByIDRequest) String() string

func (*LoadKeyspaceByIDRequest) Unmarshal 

func (m *LoadKeyspaceByIDRequest) Unmarshal(dAtA []byte) error

func (*LoadKeyspaceByIDRequest) XXX_DiscardUnknown 

func (m *LoadKeyspaceByIDRequest) XXX_DiscardUnknown()

func (*LoadKeyspaceByIDRequest) XXX_Marshal 

func (m *LoadKeyspaceByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadKeyspaceByIDRequest) XXX_Merge 

func (m *LoadKeyspaceByIDRequest) XXX_Merge(src proto.Message)

func (*LoadKeyspaceByIDRequest) XXX_OneofWrappers 

func (*LoadKeyspaceByIDRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*LoadKeyspaceByIDRequest) XXX_Size 

func (m *LoadKeyspaceByIDRequest) XXX_Size() int

func (*LoadKeyspaceByIDRequest) XXX_Unmarshal 

func (m *LoadKeyspaceByIDRequest) XXX_Unmarshal(b []byte) error

type LoadKeyspaceByIDRequest_Id 

type LoadKeyspaceByIDRequest_Id struct {
	Id uint32 `protobuf:"varint,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
}

func (*LoadKeyspaceByIDRequest_Id) MarshalTo 

func (m *LoadKeyspaceByIDRequest_Id) MarshalTo(dAtA []byte) (int, error)

func (*LoadKeyspaceByIDRequest_Id) MarshalToSizedBuffer 

func (m *LoadKeyspaceByIDRequest_Id) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadKeyspaceByIDRequest_Id) Size 

func (m *LoadKeyspaceByIDRequest_Id) Size() (n int)

type LoadKeyspaceByIDRequest_KeyspaceIdentity 

type LoadKeyspaceByIDRequest_KeyspaceIdentity struct {
	KeyspaceIdentity *apipb.KeyspaceIdentity `protobuf:"bytes,3,opt,name=keyspace_identity,json=keyspaceIdentity,proto3,oneof" json:"keyspace_identity,omitempty"`
}

func (*LoadKeyspaceByIDRequest_KeyspaceIdentity) MarshalTo 

func (m *LoadKeyspaceByIDRequest_KeyspaceIdentity) MarshalTo(dAtA []byte) (int, error)

func (*LoadKeyspaceByIDRequest_KeyspaceIdentity) MarshalToSizedBuffer 

func (m *LoadKeyspaceByIDRequest_KeyspaceIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadKeyspaceByIDRequest_KeyspaceIdentity) Size 

func (m *LoadKeyspaceByIDRequest_KeyspaceIdentity) Size() (n int)

type LoadKeyspaceRequest 

type LoadKeyspaceRequest struct {
	Header *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Name   string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// V3 namespace-scoped name lookup. If unset, V3 name-only lookup should use LookupKeyspace and may return multiple keyspaces.
	Namespace *NamespaceRef `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*LoadKeyspaceRequest) Descriptor 

func (*LoadKeyspaceRequest) Descriptor() ([]byte, []int)

func (*LoadKeyspaceRequest) GetHeader 

func (m *LoadKeyspaceRequest) GetHeader() *pdpb.RequestHeader

func (*LoadKeyspaceRequest) GetName 

func (m *LoadKeyspaceRequest) GetName() string

func (*LoadKeyspaceRequest) GetNamespace 

func (m *LoadKeyspaceRequest) GetNamespace() *NamespaceRef

func (*LoadKeyspaceRequest) Marshal 

func (m *LoadKeyspaceRequest) Marshal() (dAtA []byte, err error)

func (*LoadKeyspaceRequest) MarshalTo 

func (m *LoadKeyspaceRequest) MarshalTo(dAtA []byte) (int, error)

func (*LoadKeyspaceRequest) MarshalToSizedBuffer 

func (m *LoadKeyspaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadKeyspaceRequest) ProtoMessage 

func (*LoadKeyspaceRequest) ProtoMessage()

func (*LoadKeyspaceRequest) Reset 

func (m *LoadKeyspaceRequest) Reset()

func (*LoadKeyspaceRequest) Size 

func (m *LoadKeyspaceRequest) Size() (n int)

func (*LoadKeyspaceRequest) String 

func (m *LoadKeyspaceRequest) String() string

func (*LoadKeyspaceRequest) Unmarshal 

func (m *LoadKeyspaceRequest) Unmarshal(dAtA []byte) error

func (*LoadKeyspaceRequest) XXX_DiscardUnknown 

func (m *LoadKeyspaceRequest) XXX_DiscardUnknown()

func (*LoadKeyspaceRequest) XXX_Marshal 

func (m *LoadKeyspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadKeyspaceRequest) XXX_Merge 

func (m *LoadKeyspaceRequest) XXX_Merge(src proto.Message)

func (*LoadKeyspaceRequest) XXX_Size 

func (m *LoadKeyspaceRequest) XXX_Size() int

func (*LoadKeyspaceRequest) XXX_Unmarshal 

func (m *LoadKeyspaceRequest) XXX_Unmarshal(b []byte) error

type LoadKeyspaceResponse 

type LoadKeyspaceResponse struct {
	Header   *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keyspace *KeyspaceMeta        `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
}

func (*LoadKeyspaceResponse) Descriptor 

func (*LoadKeyspaceResponse) Descriptor() ([]byte, []int)

func (*LoadKeyspaceResponse) GetHeader 

func (m *LoadKeyspaceResponse) GetHeader() *pdpb.ResponseHeader

func (*LoadKeyspaceResponse) GetKeyspace 

func (m *LoadKeyspaceResponse) GetKeyspace() *KeyspaceMeta

func (*LoadKeyspaceResponse) Marshal 

func (m *LoadKeyspaceResponse) Marshal() (dAtA []byte, err error)

func (*LoadKeyspaceResponse) MarshalTo 

func (m *LoadKeyspaceResponse) MarshalTo(dAtA []byte) (int, error)

func (*LoadKeyspaceResponse) MarshalToSizedBuffer 

func (m *LoadKeyspaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadKeyspaceResponse) ProtoMessage 

func (*LoadKeyspaceResponse) ProtoMessage()

func (*LoadKeyspaceResponse) Reset 

func (m *LoadKeyspaceResponse) Reset()

func (*LoadKeyspaceResponse) Size 

func (m *LoadKeyspaceResponse) Size() (n int)

func (*LoadKeyspaceResponse) String 

func (m *LoadKeyspaceResponse) String() string

func (*LoadKeyspaceResponse) Unmarshal 

func (m *LoadKeyspaceResponse) Unmarshal(dAtA []byte) error

func (*LoadKeyspaceResponse) XXX_DiscardUnknown 

func (m *LoadKeyspaceResponse) XXX_DiscardUnknown()

func (*LoadKeyspaceResponse) XXX_Marshal 

func (m *LoadKeyspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadKeyspaceResponse) XXX_Merge 

func (m *LoadKeyspaceResponse) XXX_Merge(src proto.Message)

func (*LoadKeyspaceResponse) XXX_Size 

func (m *LoadKeyspaceResponse) XXX_Size() int

func (*LoadKeyspaceResponse) XXX_Unmarshal 

func (m *LoadKeyspaceResponse) XXX_Unmarshal(b []byte) error

type LoadNamespaceRequest 

type LoadNamespaceRequest struct {
	Header    *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Namespace *NamespaceRef       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*LoadNamespaceRequest) Descriptor 

func (*LoadNamespaceRequest) Descriptor() ([]byte, []int)

func (*LoadNamespaceRequest) GetHeader 

func (m *LoadNamespaceRequest) GetHeader() *pdpb.RequestHeader

func (*LoadNamespaceRequest) GetNamespace 

func (m *LoadNamespaceRequest) GetNamespace() *NamespaceRef

func (*LoadNamespaceRequest) Marshal 

func (m *LoadNamespaceRequest) Marshal() (dAtA []byte, err error)

func (*LoadNamespaceRequest) MarshalTo 

func (m *LoadNamespaceRequest) MarshalTo(dAtA []byte) (int, error)

func (*LoadNamespaceRequest) MarshalToSizedBuffer 

func (m *LoadNamespaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadNamespaceRequest) ProtoMessage 

func (*LoadNamespaceRequest) ProtoMessage()

func (*LoadNamespaceRequest) Reset 

func (m *LoadNamespaceRequest) Reset()

func (*LoadNamespaceRequest) Size 

func (m *LoadNamespaceRequest) Size() (n int)

func (*LoadNamespaceRequest) String 

func (m *LoadNamespaceRequest) String() string

func (*LoadNamespaceRequest) Unmarshal 

func (m *LoadNamespaceRequest) Unmarshal(dAtA []byte) error

func (*LoadNamespaceRequest) XXX_DiscardUnknown 

func (m *LoadNamespaceRequest) XXX_DiscardUnknown()

func (*LoadNamespaceRequest) XXX_Marshal 

func (m *LoadNamespaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadNamespaceRequest) XXX_Merge 

func (m *LoadNamespaceRequest) XXX_Merge(src proto.Message)

func (*LoadNamespaceRequest) XXX_Size 

func (m *LoadNamespaceRequest) XXX_Size() int

func (*LoadNamespaceRequest) XXX_Unmarshal 

func (m *LoadNamespaceRequest) XXX_Unmarshal(b []byte) error

type LoadNamespaceResponse 

type LoadNamespaceResponse struct {
	Header    *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Namespace *NamespaceMeta       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*LoadNamespaceResponse) Descriptor 

func (*LoadNamespaceResponse) Descriptor() ([]byte, []int)

func (*LoadNamespaceResponse) GetHeader 

func (m *LoadNamespaceResponse) GetHeader() *pdpb.ResponseHeader

func (*LoadNamespaceResponse) GetNamespace 

func (m *LoadNamespaceResponse) GetNamespace() *NamespaceMeta

func (*LoadNamespaceResponse) Marshal 

func (m *LoadNamespaceResponse) Marshal() (dAtA []byte, err error)

func (*LoadNamespaceResponse) MarshalTo 

func (m *LoadNamespaceResponse) MarshalTo(dAtA []byte) (int, error)

func (*LoadNamespaceResponse) MarshalToSizedBuffer 

func (m *LoadNamespaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadNamespaceResponse) ProtoMessage 

func (*LoadNamespaceResponse) ProtoMessage()

func (*LoadNamespaceResponse) Reset 

func (m *LoadNamespaceResponse) Reset()

func (*LoadNamespaceResponse) Size 

func (m *LoadNamespaceResponse) Size() (n int)

func (*LoadNamespaceResponse) String 

func (m *LoadNamespaceResponse) String() string

func (*LoadNamespaceResponse) Unmarshal 

func (m *LoadNamespaceResponse) Unmarshal(dAtA []byte) error

func (*LoadNamespaceResponse) XXX_DiscardUnknown 

func (m *LoadNamespaceResponse) XXX_DiscardUnknown()

func (*LoadNamespaceResponse) XXX_Marshal 

func (m *LoadNamespaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadNamespaceResponse) XXX_Merge 

func (m *LoadNamespaceResponse) XXX_Merge(src proto.Message)

func (*LoadNamespaceResponse) XXX_Size 

func (m *LoadNamespaceResponse) XXX_Size() int

func (*LoadNamespaceResponse) XXX_Unmarshal 

func (m *LoadNamespaceResponse) XXX_Unmarshal(b []byte) error

type LookupKeyspaceRequest 

type LookupKeyspaceRequest struct {
	Header *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Name   string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*LookupKeyspaceRequest) Descriptor 

func (*LookupKeyspaceRequest) Descriptor() ([]byte, []int)

func (*LookupKeyspaceRequest) GetHeader 

func (m *LookupKeyspaceRequest) GetHeader() *pdpb.RequestHeader

func (*LookupKeyspaceRequest) GetName 

func (m *LookupKeyspaceRequest) GetName() string

func (*LookupKeyspaceRequest) Marshal 

func (m *LookupKeyspaceRequest) Marshal() (dAtA []byte, err error)

func (*LookupKeyspaceRequest) MarshalTo 

func (m *LookupKeyspaceRequest) MarshalTo(dAtA []byte) (int, error)

func (*LookupKeyspaceRequest) MarshalToSizedBuffer 

func (m *LookupKeyspaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LookupKeyspaceRequest) ProtoMessage 

func (*LookupKeyspaceRequest) ProtoMessage()

func (*LookupKeyspaceRequest) Reset 

func (m *LookupKeyspaceRequest) Reset()

func (*LookupKeyspaceRequest) Size 

func (m *LookupKeyspaceRequest) Size() (n int)

func (*LookupKeyspaceRequest) String 

func (m *LookupKeyspaceRequest) String() string

func (*LookupKeyspaceRequest) Unmarshal 

func (m *LookupKeyspaceRequest) Unmarshal(dAtA []byte) error

func (*LookupKeyspaceRequest) XXX_DiscardUnknown 

func (m *LookupKeyspaceRequest) XXX_DiscardUnknown()

func (*LookupKeyspaceRequest) XXX_Marshal 

func (m *LookupKeyspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookupKeyspaceRequest) XXX_Merge 

func (m *LookupKeyspaceRequest) XXX_Merge(src proto.Message)

func (*LookupKeyspaceRequest) XXX_Size 

func (m *LookupKeyspaceRequest) XXX_Size() int

func (*LookupKeyspaceRequest) XXX_Unmarshal 

func (m *LookupKeyspaceRequest) XXX_Unmarshal(b []byte) error

type LookupKeyspaceResponse 

type LookupKeyspaceResponse struct {
	Header    *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keyspaces []*KeyspaceMeta      `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
}

func (*LookupKeyspaceResponse) Descriptor 

func (*LookupKeyspaceResponse) Descriptor() ([]byte, []int)

func (*LookupKeyspaceResponse) GetHeader 

func (m *LookupKeyspaceResponse) GetHeader() *pdpb.ResponseHeader

func (*LookupKeyspaceResponse) GetKeyspaces 

func (m *LookupKeyspaceResponse) GetKeyspaces() []*KeyspaceMeta

func (*LookupKeyspaceResponse) Marshal 

func (m *LookupKeyspaceResponse) Marshal() (dAtA []byte, err error)

func (*LookupKeyspaceResponse) MarshalTo 

func (m *LookupKeyspaceResponse) MarshalTo(dAtA []byte) (int, error)

func (*LookupKeyspaceResponse) MarshalToSizedBuffer 

func (m *LookupKeyspaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LookupKeyspaceResponse) ProtoMessage 

func (*LookupKeyspaceResponse) ProtoMessage()

func (*LookupKeyspaceResponse) Reset 

func (m *LookupKeyspaceResponse) Reset()

func (*LookupKeyspaceResponse) Size 

func (m *LookupKeyspaceResponse) Size() (n int)

func (*LookupKeyspaceResponse) String 

func (m *LookupKeyspaceResponse) String() string

func (*LookupKeyspaceResponse) Unmarshal 

func (m *LookupKeyspaceResponse) Unmarshal(dAtA []byte) error

func (*LookupKeyspaceResponse) XXX_DiscardUnknown 

func (m *LookupKeyspaceResponse) XXX_DiscardUnknown()

func (*LookupKeyspaceResponse) XXX_Marshal 

func (m *LookupKeyspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookupKeyspaceResponse) XXX_Merge 

func (m *LookupKeyspaceResponse) XXX_Merge(src proto.Message)

func (*LookupKeyspaceResponse) XXX_Size 

func (m *LookupKeyspaceResponse) XXX_Size() int

func (*LookupKeyspaceResponse) XXX_Unmarshal 

func (m *LookupKeyspaceResponse) XXX_Unmarshal(b []byte) error

type NamespaceClient 

type NamespaceClient interface {
	CreateNamespace(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*CreateNamespaceResponse, error)
	LoadNamespace(ctx context.Context, in *LoadNamespaceRequest, opts ...grpc.CallOption) (*LoadNamespaceResponse, error)
	GetAllNamespaces(ctx context.Context, in *GetAllNamespacesRequest, opts ...grpc.CallOption) (*GetAllNamespacesResponse, error)
	UpdateNamespaceState(ctx context.Context, in *UpdateNamespaceStateRequest, opts ...grpc.CallOption) (*UpdateNamespaceStateResponse, error)
}

NamespaceClient is the client API for Namespace service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNamespaceClient 

func NewNamespaceClient(cc *grpc.ClientConn) NamespaceClient

type NamespaceMeta 

type NamespaceMeta struct {
	Id             uint32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name           string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State          KeyspaceState     `protobuf:"varint,3,opt,name=state,proto3,enum=keyspacepb.KeyspaceState" json:"state,omitempty"`
	CreatedAt      int64             `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StateChangedAt int64             `protobuf:"varint,5,opt,name=state_changed_at,json=stateChangedAt,proto3" json:"state_changed_at,omitempty"`
	Config         map[string]string `` /* 153-byte string literal not displayed */
}

func (*NamespaceMeta) Descriptor 

func (*NamespaceMeta) Descriptor() ([]byte, []int)

func (*NamespaceMeta) GetConfig 

func (m *NamespaceMeta) GetConfig() map[string]string

func (*NamespaceMeta) GetCreatedAt 

func (m *NamespaceMeta) GetCreatedAt() int64

func (*NamespaceMeta) GetId 

func (m *NamespaceMeta) GetId() uint32

func (*NamespaceMeta) GetName 

func (m *NamespaceMeta) GetName() string

func (*NamespaceMeta) GetState 

func (m *NamespaceMeta) GetState() KeyspaceState

func (*NamespaceMeta) GetStateChangedAt 

func (m *NamespaceMeta) GetStateChangedAt() int64

func (*NamespaceMeta) Marshal 

func (m *NamespaceMeta) Marshal() (dAtA []byte, err error)

func (*NamespaceMeta) MarshalTo 

func (m *NamespaceMeta) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceMeta) MarshalToSizedBuffer 

func (m *NamespaceMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NamespaceMeta) ProtoMessage 

func (*NamespaceMeta) ProtoMessage()

func (*NamespaceMeta) Reset 

func (m *NamespaceMeta) Reset()

func (*NamespaceMeta) Size 

func (m *NamespaceMeta) Size() (n int)

func (*NamespaceMeta) String 

func (m *NamespaceMeta) String() string

func (*NamespaceMeta) Unmarshal 

func (m *NamespaceMeta) Unmarshal(dAtA []byte) error

func (*NamespaceMeta) XXX_DiscardUnknown 

func (m *NamespaceMeta) XXX_DiscardUnknown()

func (*NamespaceMeta) XXX_Marshal 

func (m *NamespaceMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NamespaceMeta) XXX_Merge 

func (m *NamespaceMeta) XXX_Merge(src proto.Message)

func (*NamespaceMeta) XXX_Size 

func (m *NamespaceMeta) XXX_Size() int

func (*NamespaceMeta) XXX_Unmarshal 

func (m *NamespaceMeta) XXX_Unmarshal(b []byte) error

type NamespaceRef 

type NamespaceRef struct {
	// Types that are valid to be assigned to Namespace:
	//	*NamespaceRef_NamespaceId
	//	*NamespaceRef_NamespaceName
	Namespace isNamespaceRef_Namespace `protobuf_oneof:"namespace"`
}

func (*NamespaceRef) Descriptor 

func (*NamespaceRef) Descriptor() ([]byte, []int)

func (*NamespaceRef) GetNamespace 

func (m *NamespaceRef) GetNamespace() isNamespaceRef_Namespace

func (*NamespaceRef) GetNamespaceId 

func (m *NamespaceRef) GetNamespaceId() uint32

func (*NamespaceRef) GetNamespaceName 

func (m *NamespaceRef) GetNamespaceName() string

func (*NamespaceRef) Marshal 

func (m *NamespaceRef) Marshal() (dAtA []byte, err error)

func (*NamespaceRef) MarshalTo 

func (m *NamespaceRef) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceRef) MarshalToSizedBuffer 

func (m *NamespaceRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NamespaceRef) ProtoMessage 

func (*NamespaceRef) ProtoMessage()

func (*NamespaceRef) Reset 

func (m *NamespaceRef) Reset()

func (*NamespaceRef) Size 

func (m *NamespaceRef) Size() (n int)

func (*NamespaceRef) String 

func (m *NamespaceRef) String() string

func (*NamespaceRef) Unmarshal 

func (m *NamespaceRef) Unmarshal(dAtA []byte) error

func (*NamespaceRef) XXX_DiscardUnknown 

func (m *NamespaceRef) XXX_DiscardUnknown()

func (*NamespaceRef) XXX_Marshal 

func (m *NamespaceRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NamespaceRef) XXX_Merge 

func (m *NamespaceRef) XXX_Merge(src proto.Message)

func (*NamespaceRef) XXX_OneofWrappers 

func (*NamespaceRef) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NamespaceRef) XXX_Size 

func (m *NamespaceRef) XXX_Size() int

func (*NamespaceRef) XXX_Unmarshal 

func (m *NamespaceRef) XXX_Unmarshal(b []byte) error

type NamespaceRef_NamespaceId 

type NamespaceRef_NamespaceId struct {
	NamespaceId uint32 `protobuf:"varint,1,opt,name=namespace_id,json=namespaceId,proto3,oneof" json:"namespace_id,omitempty"`
}

func (*NamespaceRef_NamespaceId) MarshalTo 

func (m *NamespaceRef_NamespaceId) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceRef_NamespaceId) MarshalToSizedBuffer 

func (m *NamespaceRef_NamespaceId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NamespaceRef_NamespaceId) Size 

func (m *NamespaceRef_NamespaceId) Size() (n int)

type NamespaceRef_NamespaceName 

type NamespaceRef_NamespaceName struct {
	NamespaceName string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3,oneof" json:"namespace_name,omitempty"`
}

func (*NamespaceRef_NamespaceName) MarshalTo 

func (m *NamespaceRef_NamespaceName) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceRef_NamespaceName) MarshalToSizedBuffer 

func (m *NamespaceRef_NamespaceName) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NamespaceRef_NamespaceName) Size 

func (m *NamespaceRef_NamespaceName) Size() (n int)

type NamespaceServer 

type NamespaceServer interface {
	CreateNamespace(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)
	LoadNamespace(context.Context, *LoadNamespaceRequest) (*LoadNamespaceResponse, error)
	GetAllNamespaces(context.Context, *GetAllNamespacesRequest) (*GetAllNamespacesResponse, error)
	UpdateNamespaceState(context.Context, *UpdateNamespaceStateRequest) (*UpdateNamespaceStateResponse, error)
}

NamespaceServer is the server API for Namespace service.

type UnimplementedKeyspaceServer 

type UnimplementedKeyspaceServer struct {
}

UnimplementedKeyspaceServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyspaceServer) GetAllKeyspaces 

func (*UnimplementedKeyspaceServer) GetAllKeyspaces(ctx context.Context, req *GetAllKeyspacesRequest) (*GetAllKeyspacesResponse, error)

func (*UnimplementedKeyspaceServer) LoadKeyspace 

func (*UnimplementedKeyspaceServer) LoadKeyspace(ctx context.Context, req *LoadKeyspaceRequest) (*LoadKeyspaceResponse, error)

func (*UnimplementedKeyspaceServer) LoadKeyspaceByID 

func (*UnimplementedKeyspaceServer) LoadKeyspaceByID(ctx context.Context, req *LoadKeyspaceByIDRequest) (*LoadKeyspaceResponse, error)

func (*UnimplementedKeyspaceServer) LookupKeyspace 

func (*UnimplementedKeyspaceServer) LookupKeyspace(ctx context.Context, req *LookupKeyspaceRequest) (*LookupKeyspaceResponse, error)

func (*UnimplementedKeyspaceServer) UpdateKeyspaceState 

func (*UnimplementedKeyspaceServer) UpdateKeyspaceState(ctx context.Context, req *UpdateKeyspaceStateRequest) (*UpdateKeyspaceStateResponse, error)

func (*UnimplementedKeyspaceServer) WatchKeyspaces 

func (*UnimplementedKeyspaceServer) WatchKeyspaces(req *WatchKeyspacesRequest, srv Keyspace_WatchKeyspacesServer) error

type UnimplementedNamespaceServer 

type UnimplementedNamespaceServer struct {
}

UnimplementedNamespaceServer can be embedded to have forward compatible implementations.

func (*UnimplementedNamespaceServer) CreateNamespace 

func (*UnimplementedNamespaceServer) CreateNamespace(ctx context.Context, req *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

func (*UnimplementedNamespaceServer) GetAllNamespaces 

func (*UnimplementedNamespaceServer) GetAllNamespaces(ctx context.Context, req *GetAllNamespacesRequest) (*GetAllNamespacesResponse, error)

func (*UnimplementedNamespaceServer) LoadNamespace 

func (*UnimplementedNamespaceServer) LoadNamespace(ctx context.Context, req *LoadNamespaceRequest) (*LoadNamespaceResponse, error)

func (*UnimplementedNamespaceServer) UpdateNamespaceState 

func (*UnimplementedNamespaceServer) UpdateNamespaceState(ctx context.Context, req *UpdateNamespaceStateRequest) (*UpdateNamespaceStateResponse, error)

type UpdateKeyspaceStateRequest 

type UpdateKeyspaceStateRequest struct {
	Header *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to Keyspace:
	//	*UpdateKeyspaceStateRequest_Id
	//	*UpdateKeyspaceStateRequest_KeyspaceIdentity
	Keyspace isUpdateKeyspaceStateRequest_Keyspace `protobuf_oneof:"keyspace"`
	State    KeyspaceState                         `protobuf:"varint,3,opt,name=state,proto3,enum=keyspacepb.KeyspaceState" json:"state,omitempty"`
}

func (*UpdateKeyspaceStateRequest) Descriptor 

func (*UpdateKeyspaceStateRequest) Descriptor() ([]byte, []int)

func (*UpdateKeyspaceStateRequest) GetHeader 

func (m *UpdateKeyspaceStateRequest) GetHeader() *pdpb.RequestHeader

func (*UpdateKeyspaceStateRequest) GetId 

func (m *UpdateKeyspaceStateRequest) GetId() uint32

func (*UpdateKeyspaceStateRequest) GetKeyspace 

func (m *UpdateKeyspaceStateRequest) GetKeyspace() isUpdateKeyspaceStateRequest_Keyspace

func (*UpdateKeyspaceStateRequest) GetKeyspaceIdentity 

func (m *UpdateKeyspaceStateRequest) GetKeyspaceIdentity() *apipb.KeyspaceIdentity

func (*UpdateKeyspaceStateRequest) GetState 

func (m *UpdateKeyspaceStateRequest) GetState() KeyspaceState

func (*UpdateKeyspaceStateRequest) Marshal 

func (m *UpdateKeyspaceStateRequest) Marshal() (dAtA []byte, err error)

func (*UpdateKeyspaceStateRequest) MarshalTo 

func (m *UpdateKeyspaceStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateRequest) MarshalToSizedBuffer 

func (m *UpdateKeyspaceStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateRequest) ProtoMessage 

func (*UpdateKeyspaceStateRequest) ProtoMessage()

func (*UpdateKeyspaceStateRequest) Reset 

func (m *UpdateKeyspaceStateRequest) Reset()

func (*UpdateKeyspaceStateRequest) Size 

func (m *UpdateKeyspaceStateRequest) Size() (n int)

func (*UpdateKeyspaceStateRequest) String 

func (m *UpdateKeyspaceStateRequest) String() string

func (*UpdateKeyspaceStateRequest) Unmarshal 

func (m *UpdateKeyspaceStateRequest) Unmarshal(dAtA []byte) error

func (*UpdateKeyspaceStateRequest) XXX_DiscardUnknown 

func (m *UpdateKeyspaceStateRequest) XXX_DiscardUnknown()

func (*UpdateKeyspaceStateRequest) XXX_Marshal 

func (m *UpdateKeyspaceStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateKeyspaceStateRequest) XXX_Merge 

func (m *UpdateKeyspaceStateRequest) XXX_Merge(src proto.Message)

func (*UpdateKeyspaceStateRequest) XXX_OneofWrappers 

func (*UpdateKeyspaceStateRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpdateKeyspaceStateRequest) XXX_Size 

func (m *UpdateKeyspaceStateRequest) XXX_Size() int

func (*UpdateKeyspaceStateRequest) XXX_Unmarshal 

func (m *UpdateKeyspaceStateRequest) XXX_Unmarshal(b []byte) error

type UpdateKeyspaceStateRequest_Id 

type UpdateKeyspaceStateRequest_Id struct {
	Id uint32 `protobuf:"varint,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
}

func (*UpdateKeyspaceStateRequest_Id) MarshalTo 

func (m *UpdateKeyspaceStateRequest_Id) MarshalTo(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateRequest_Id) MarshalToSizedBuffer 

func (m *UpdateKeyspaceStateRequest_Id) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateRequest_Id) Size 

func (m *UpdateKeyspaceStateRequest_Id) Size() (n int)

type UpdateKeyspaceStateRequest_KeyspaceIdentity 

type UpdateKeyspaceStateRequest_KeyspaceIdentity struct {
	KeyspaceIdentity *apipb.KeyspaceIdentity `protobuf:"bytes,4,opt,name=keyspace_identity,json=keyspaceIdentity,proto3,oneof" json:"keyspace_identity,omitempty"`
}

func (*UpdateKeyspaceStateRequest_KeyspaceIdentity) MarshalTo 

func (m *UpdateKeyspaceStateRequest_KeyspaceIdentity) MarshalTo(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateRequest_KeyspaceIdentity) MarshalToSizedBuffer 

func (m *UpdateKeyspaceStateRequest_KeyspaceIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateRequest_KeyspaceIdentity) Size 

func (m *UpdateKeyspaceStateRequest_KeyspaceIdentity) Size() (n int)

type UpdateKeyspaceStateResponse 

type UpdateKeyspaceStateResponse struct {
	Header   *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keyspace *KeyspaceMeta        `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
}

func (*UpdateKeyspaceStateResponse) Descriptor 

func (*UpdateKeyspaceStateResponse) Descriptor() ([]byte, []int)

func (*UpdateKeyspaceStateResponse) GetHeader 

func (m *UpdateKeyspaceStateResponse) GetHeader() *pdpb.ResponseHeader

func (*UpdateKeyspaceStateResponse) GetKeyspace 

func (m *UpdateKeyspaceStateResponse) GetKeyspace() *KeyspaceMeta

func (*UpdateKeyspaceStateResponse) Marshal 

func (m *UpdateKeyspaceStateResponse) Marshal() (dAtA []byte, err error)

func (*UpdateKeyspaceStateResponse) MarshalTo 

func (m *UpdateKeyspaceStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateResponse) MarshalToSizedBuffer 

func (m *UpdateKeyspaceStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateKeyspaceStateResponse) ProtoMessage 

func (*UpdateKeyspaceStateResponse) ProtoMessage()

func (*UpdateKeyspaceStateResponse) Reset 

func (m *UpdateKeyspaceStateResponse) Reset()

func (*UpdateKeyspaceStateResponse) Size 

func (m *UpdateKeyspaceStateResponse) Size() (n int)

func (*UpdateKeyspaceStateResponse) String 

func (m *UpdateKeyspaceStateResponse) String() string

func (*UpdateKeyspaceStateResponse) Unmarshal 

func (m *UpdateKeyspaceStateResponse) Unmarshal(dAtA []byte) error

func (*UpdateKeyspaceStateResponse) XXX_DiscardUnknown 

func (m *UpdateKeyspaceStateResponse) XXX_DiscardUnknown()

func (*UpdateKeyspaceStateResponse) XXX_Marshal 

func (m *UpdateKeyspaceStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateKeyspaceStateResponse) XXX_Merge 

func (m *UpdateKeyspaceStateResponse) XXX_Merge(src proto.Message)

func (*UpdateKeyspaceStateResponse) XXX_Size 

func (m *UpdateKeyspaceStateResponse) XXX_Size() int

func (*UpdateKeyspaceStateResponse) XXX_Unmarshal 

func (m *UpdateKeyspaceStateResponse) XXX_Unmarshal(b []byte) error

type UpdateNamespaceStateRequest 

type UpdateNamespaceStateRequest struct {
	Header    *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Namespace *NamespaceRef       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	State     KeyspaceState       `protobuf:"varint,3,opt,name=state,proto3,enum=keyspacepb.KeyspaceState" json:"state,omitempty"`
}

func (*UpdateNamespaceStateRequest) Descriptor 

func (*UpdateNamespaceStateRequest) Descriptor() ([]byte, []int)

func (*UpdateNamespaceStateRequest) GetHeader 

func (m *UpdateNamespaceStateRequest) GetHeader() *pdpb.RequestHeader

func (*UpdateNamespaceStateRequest) GetNamespace 

func (m *UpdateNamespaceStateRequest) GetNamespace() *NamespaceRef

func (*UpdateNamespaceStateRequest) GetState 

func (m *UpdateNamespaceStateRequest) GetState() KeyspaceState

func (*UpdateNamespaceStateRequest) Marshal 

func (m *UpdateNamespaceStateRequest) Marshal() (dAtA []byte, err error)

func (*UpdateNamespaceStateRequest) MarshalTo 

func (m *UpdateNamespaceStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateNamespaceStateRequest) MarshalToSizedBuffer 

func (m *UpdateNamespaceStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateNamespaceStateRequest) ProtoMessage 

func (*UpdateNamespaceStateRequest) ProtoMessage()

func (*UpdateNamespaceStateRequest) Reset 

func (m *UpdateNamespaceStateRequest) Reset()

func (*UpdateNamespaceStateRequest) Size 

func (m *UpdateNamespaceStateRequest) Size() (n int)

func (*UpdateNamespaceStateRequest) String 

func (m *UpdateNamespaceStateRequest) String() string

func (*UpdateNamespaceStateRequest) Unmarshal 

func (m *UpdateNamespaceStateRequest) Unmarshal(dAtA []byte) error

func (*UpdateNamespaceStateRequest) XXX_DiscardUnknown 

func (m *UpdateNamespaceStateRequest) XXX_DiscardUnknown()

func (*UpdateNamespaceStateRequest) XXX_Marshal 

func (m *UpdateNamespaceStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateNamespaceStateRequest) XXX_Merge 

func (m *UpdateNamespaceStateRequest) XXX_Merge(src proto.Message)

func (*UpdateNamespaceStateRequest) XXX_Size 

func (m *UpdateNamespaceStateRequest) XXX_Size() int

func (*UpdateNamespaceStateRequest) XXX_Unmarshal 

func (m *UpdateNamespaceStateRequest) XXX_Unmarshal(b []byte) error

type UpdateNamespaceStateResponse 

type UpdateNamespaceStateResponse struct {
	Header    *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Namespace *NamespaceMeta       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*UpdateNamespaceStateResponse) Descriptor 

func (*UpdateNamespaceStateResponse) Descriptor() ([]byte, []int)

func (*UpdateNamespaceStateResponse) GetHeader 

func (m *UpdateNamespaceStateResponse) GetHeader() *pdpb.ResponseHeader

func (*UpdateNamespaceStateResponse) GetNamespace 

func (m *UpdateNamespaceStateResponse) GetNamespace() *NamespaceMeta

func (*UpdateNamespaceStateResponse) Marshal 

func (m *UpdateNamespaceStateResponse) Marshal() (dAtA []byte, err error)

func (*UpdateNamespaceStateResponse) MarshalTo 

func (m *UpdateNamespaceStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateNamespaceStateResponse) MarshalToSizedBuffer 

func (m *UpdateNamespaceStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateNamespaceStateResponse) ProtoMessage 

func (*UpdateNamespaceStateResponse) ProtoMessage()

func (*UpdateNamespaceStateResponse) Reset 

func (m *UpdateNamespaceStateResponse) Reset()

func (*UpdateNamespaceStateResponse) Size 

func (m *UpdateNamespaceStateResponse) Size() (n int)

func (*UpdateNamespaceStateResponse) String 

func (m *UpdateNamespaceStateResponse) String() string

func (*UpdateNamespaceStateResponse) Unmarshal 

func (m *UpdateNamespaceStateResponse) Unmarshal(dAtA []byte) error

func (*UpdateNamespaceStateResponse) XXX_DiscardUnknown 

func (m *UpdateNamespaceStateResponse) XXX_DiscardUnknown()

func (*UpdateNamespaceStateResponse) XXX_Marshal 

func (m *UpdateNamespaceStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateNamespaceStateResponse) XXX_Merge 

func (m *UpdateNamespaceStateResponse) XXX_Merge(src proto.Message)

func (*UpdateNamespaceStateResponse) XXX_Size 

func (m *UpdateNamespaceStateResponse) XXX_Size() int

func (*UpdateNamespaceStateResponse) XXX_Unmarshal 

func (m *UpdateNamespaceStateResponse) XXX_Unmarshal(b []byte) error

type WatchKeyspacesRequest 

type WatchKeyspacesRequest struct {
	Header *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*WatchKeyspacesRequest) Descriptor 

func (*WatchKeyspacesRequest) Descriptor() ([]byte, []int)

func (*WatchKeyspacesRequest) GetHeader 

func (m *WatchKeyspacesRequest) GetHeader() *pdpb.RequestHeader

func (*WatchKeyspacesRequest) Marshal 

func (m *WatchKeyspacesRequest) Marshal() (dAtA []byte, err error)

func (*WatchKeyspacesRequest) MarshalTo 

func (m *WatchKeyspacesRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatchKeyspacesRequest) MarshalToSizedBuffer 

func (m *WatchKeyspacesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchKeyspacesRequest) ProtoMessage 

func (*WatchKeyspacesRequest) ProtoMessage()

func (*WatchKeyspacesRequest) Reset 

func (m *WatchKeyspacesRequest) Reset()

func (*WatchKeyspacesRequest) Size 

func (m *WatchKeyspacesRequest) Size() (n int)

func (*WatchKeyspacesRequest) String 

func (m *WatchKeyspacesRequest) String() string

func (*WatchKeyspacesRequest) Unmarshal 

func (m *WatchKeyspacesRequest) Unmarshal(dAtA []byte) error

func (*WatchKeyspacesRequest) XXX_DiscardUnknown 

func (m *WatchKeyspacesRequest) XXX_DiscardUnknown()

func (*WatchKeyspacesRequest) XXX_Marshal 

func (m *WatchKeyspacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchKeyspacesRequest) XXX_Merge 

func (m *WatchKeyspacesRequest) XXX_Merge(src proto.Message)

func (*WatchKeyspacesRequest) XXX_Size 

func (m *WatchKeyspacesRequest) XXX_Size() int

func (*WatchKeyspacesRequest) XXX_Unmarshal 

func (m *WatchKeyspacesRequest) XXX_Unmarshal(b []byte) error

type WatchKeyspacesResponse 

type WatchKeyspacesResponse struct {
	Header    *pdpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keyspaces []*KeyspaceMeta      `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
}

func (*WatchKeyspacesResponse) Descriptor 

func (*WatchKeyspacesResponse) Descriptor() ([]byte, []int)

func (*WatchKeyspacesResponse) GetHeader 

func (m *WatchKeyspacesResponse) GetHeader() *pdpb.ResponseHeader

func (*WatchKeyspacesResponse) GetKeyspaces 

func (m *WatchKeyspacesResponse) GetKeyspaces() []*KeyspaceMeta

func (*WatchKeyspacesResponse) Marshal 

func (m *WatchKeyspacesResponse) Marshal() (dAtA []byte, err error)

func (*WatchKeyspacesResponse) MarshalTo 

func (m *WatchKeyspacesResponse) MarshalTo(dAtA []byte) (int, error)

func (*WatchKeyspacesResponse) MarshalToSizedBuffer 

func (m *WatchKeyspacesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchKeyspacesResponse) ProtoMessage 

func (*WatchKeyspacesResponse) ProtoMessage()

func (*WatchKeyspacesResponse) Reset 

func (m *WatchKeyspacesResponse) Reset()

func (*WatchKeyspacesResponse) Size 

func (m *WatchKeyspacesResponse) Size() (n int)

func (*WatchKeyspacesResponse) String 

func (m *WatchKeyspacesResponse) String() string

func (*WatchKeyspacesResponse) Unmarshal 

func (m *WatchKeyspacesResponse) Unmarshal(dAtA []byte) error

func (*WatchKeyspacesResponse) XXX_DiscardUnknown 

func (m *WatchKeyspacesResponse) XXX_DiscardUnknown()

func (*WatchKeyspacesResponse) XXX_Marshal 

func (m *WatchKeyspacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchKeyspacesResponse) XXX_Merge 

func (m *WatchKeyspacesResponse) XXX_Merge(src proto.Message)

func (*WatchKeyspacesResponse) XXX_Size 

func (m *WatchKeyspacesResponse) XXX_Size() int

func (*WatchKeyspacesResponse) XXX_Unmarshal 

func (m *WatchKeyspacesResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.