keyspacepb

package
v0.0.0-...-3b3056d Latest Latest
Warning

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

Go to latest
Published: Nov 29, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

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",
}
View Source
var KeyspaceState_value = map[string]int32{
	"ENABLED":  0,
	"DISABLED": 1,
	"ARCHIVED": 2,
}

Functions

func RegisterKeyspaceServer

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

Types

type KeyspaceClient

type KeyspaceClient interface {
	LoadKeyspace(ctx context.Context, in *LoadKeyspaceRequest, 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)
}

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 {
	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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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) 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_Size

func (m *KeyspaceMeta) XXX_Size() int

func (*KeyspaceMeta) XXX_Unmarshal

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

type KeyspaceServer

type KeyspaceServer interface {
	LoadKeyspace(context.Context, *LoadKeyspaceRequest) (*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
}

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
)

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 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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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) 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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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 UnimplementedKeyspaceServer

type UnimplementedKeyspaceServer struct {
}

UnimplementedKeyspaceServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyspaceServer) LoadKeyspace

func (*UnimplementedKeyspaceServer) WatchKeyspaces

type WatchKeyspacesRequest

type WatchKeyspacesRequest struct {
	Header               *pdpb.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL