Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowTsopb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTsopb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTsopb = fmt.Errorf("proto: unexpected end of group") + var ErrorType_name = map[int32]string + var ErrorType_value = map[string]int32 + func RegisterTSOServer(s *grpc.Server, srv TSOServer) + type Error struct + Message string + Type ErrorType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetMessage() string + func (m *Error) GetType() ErrorType + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type ErrorType int32 + const ErrorType_ALREADY_BOOTSTRAPPED + const ErrorType_CLUSTER_MISMATCHED + const ErrorType_INVALID_VALUE + const ErrorType_NOT_BOOTSTRAPPED + const ErrorType_OK + const ErrorType_UNKNOWN + func (ErrorType) EnumDescriptor() ([]byte, []int) + func (x ErrorType) String() string + type FindGroupByKeyspaceIDRequest struct + Header *RequestHeader + KeyspaceId uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindGroupByKeyspaceIDRequest) Descriptor() ([]byte, []int) + func (*FindGroupByKeyspaceIDRequest) ProtoMessage() + func (m *FindGroupByKeyspaceIDRequest) GetHeader() *RequestHeader + func (m *FindGroupByKeyspaceIDRequest) GetKeyspaceId() uint32 + func (m *FindGroupByKeyspaceIDRequest) Marshal() (dAtA []byte, err error) + func (m *FindGroupByKeyspaceIDRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FindGroupByKeyspaceIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FindGroupByKeyspaceIDRequest) Reset() + func (m *FindGroupByKeyspaceIDRequest) Size() (n int) + func (m *FindGroupByKeyspaceIDRequest) String() string + func (m *FindGroupByKeyspaceIDRequest) Unmarshal(dAtA []byte) error + func (m *FindGroupByKeyspaceIDRequest) XXX_DiscardUnknown() + func (m *FindGroupByKeyspaceIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FindGroupByKeyspaceIDRequest) XXX_Merge(src proto.Message) + func (m *FindGroupByKeyspaceIDRequest) XXX_Size() int + func (m *FindGroupByKeyspaceIDRequest) XXX_Unmarshal(b []byte) error + type FindGroupByKeyspaceIDResponse struct + Header *ResponseHeader + KeyspaceGroup *KeyspaceGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindGroupByKeyspaceIDResponse) Descriptor() ([]byte, []int) + func (*FindGroupByKeyspaceIDResponse) ProtoMessage() + func (m *FindGroupByKeyspaceIDResponse) GetHeader() *ResponseHeader + func (m *FindGroupByKeyspaceIDResponse) GetKeyspaceGroup() *KeyspaceGroup + func (m *FindGroupByKeyspaceIDResponse) Marshal() (dAtA []byte, err error) + func (m *FindGroupByKeyspaceIDResponse) MarshalTo(dAtA []byte) (int, error) + func (m *FindGroupByKeyspaceIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FindGroupByKeyspaceIDResponse) Reset() + func (m *FindGroupByKeyspaceIDResponse) Size() (n int) + func (m *FindGroupByKeyspaceIDResponse) String() string + func (m *FindGroupByKeyspaceIDResponse) Unmarshal(dAtA []byte) error + func (m *FindGroupByKeyspaceIDResponse) XXX_DiscardUnknown() + func (m *FindGroupByKeyspaceIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FindGroupByKeyspaceIDResponse) XXX_Merge(src proto.Message) + func (m *FindGroupByKeyspaceIDResponse) XXX_Size() int + func (m *FindGroupByKeyspaceIDResponse) XXX_Unmarshal(b []byte) error + type GetMinTSRequest struct + DcLocation string + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMinTSRequest) Descriptor() ([]byte, []int) + func (*GetMinTSRequest) ProtoMessage() + func (m *GetMinTSRequest) GetDcLocation() string + func (m *GetMinTSRequest) GetHeader() *RequestHeader + func (m *GetMinTSRequest) Marshal() (dAtA []byte, err error) + func (m *GetMinTSRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetMinTSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetMinTSRequest) Reset() + func (m *GetMinTSRequest) Size() (n int) + func (m *GetMinTSRequest) String() string + func (m *GetMinTSRequest) Unmarshal(dAtA []byte) error + func (m *GetMinTSRequest) XXX_DiscardUnknown() + func (m *GetMinTSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMinTSRequest) XXX_Merge(src proto.Message) + func (m *GetMinTSRequest) XXX_Size() int + func (m *GetMinTSRequest) XXX_Unmarshal(b []byte) error + type GetMinTSResponse struct + Header *ResponseHeader + KeyspaceGroupsServing uint32 + KeyspaceGroupsTotal uint32 + Timestamp *tmpb.Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMinTSResponse) Descriptor() ([]byte, []int) + func (*GetMinTSResponse) ProtoMessage() + func (m *GetMinTSResponse) GetHeader() *ResponseHeader + func (m *GetMinTSResponse) GetKeyspaceGroupsServing() uint32 + func (m *GetMinTSResponse) GetKeyspaceGroupsTotal() uint32 + func (m *GetMinTSResponse) GetTimestamp() *tmpb.Timestamp + func (m *GetMinTSResponse) Marshal() (dAtA []byte, err error) + func (m *GetMinTSResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetMinTSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetMinTSResponse) Reset() + func (m *GetMinTSResponse) Size() (n int) + func (m *GetMinTSResponse) String() string + func (m *GetMinTSResponse) Unmarshal(dAtA []byte) error + func (m *GetMinTSResponse) XXX_DiscardUnknown() + func (m *GetMinTSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMinTSResponse) XXX_Merge(src proto.Message) + func (m *GetMinTSResponse) XXX_Size() int + func (m *GetMinTSResponse) XXX_Unmarshal(b []byte) error + type KeyspaceGroup struct + Id uint32 + Members []*KeyspaceGroupMember + SplitState *SplitState + UserKind string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyspaceGroup) Descriptor() ([]byte, []int) + func (*KeyspaceGroup) ProtoMessage() + func (m *KeyspaceGroup) GetId() uint32 + func (m *KeyspaceGroup) GetMembers() []*KeyspaceGroupMember + func (m *KeyspaceGroup) GetSplitState() *SplitState + func (m *KeyspaceGroup) GetUserKind() string + func (m *KeyspaceGroup) Marshal() (dAtA []byte, err error) + func (m *KeyspaceGroup) MarshalTo(dAtA []byte) (int, error) + func (m *KeyspaceGroup) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyspaceGroup) Reset() + func (m *KeyspaceGroup) Size() (n int) + func (m *KeyspaceGroup) String() string + func (m *KeyspaceGroup) Unmarshal(dAtA []byte) error + func (m *KeyspaceGroup) XXX_DiscardUnknown() + func (m *KeyspaceGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyspaceGroup) XXX_Merge(src proto.Message) + func (m *KeyspaceGroup) XXX_Size() int + func (m *KeyspaceGroup) XXX_Unmarshal(b []byte) error + type KeyspaceGroupMember struct + Address string + IsPrimary bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyspaceGroupMember) Descriptor() ([]byte, []int) + func (*KeyspaceGroupMember) ProtoMessage() + func (m *KeyspaceGroupMember) GetAddress() string + func (m *KeyspaceGroupMember) GetIsPrimary() bool + func (m *KeyspaceGroupMember) Marshal() (dAtA []byte, err error) + func (m *KeyspaceGroupMember) MarshalTo(dAtA []byte) (int, error) + func (m *KeyspaceGroupMember) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyspaceGroupMember) Reset() + func (m *KeyspaceGroupMember) Size() (n int) + func (m *KeyspaceGroupMember) String() string + func (m *KeyspaceGroupMember) Unmarshal(dAtA []byte) error + func (m *KeyspaceGroupMember) XXX_DiscardUnknown() + func (m *KeyspaceGroupMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyspaceGroupMember) XXX_Merge(src proto.Message) + func (m *KeyspaceGroupMember) XXX_Size() int + func (m *KeyspaceGroupMember) XXX_Unmarshal(b []byte) error + type Participant struct + Id uint64 + ListenUrls []string + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Participant) Descriptor() ([]byte, []int) + func (*Participant) ProtoMessage() + func (m *Participant) GetId() uint64 + func (m *Participant) GetListenUrls() []string + func (m *Participant) GetName() string + func (m *Participant) Marshal() (dAtA []byte, err error) + func (m *Participant) MarshalTo(dAtA []byte) (int, error) + func (m *Participant) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Participant) Reset() + func (m *Participant) Size() (n int) + func (m *Participant) String() string + func (m *Participant) Unmarshal(dAtA []byte) error + func (m *Participant) XXX_DiscardUnknown() + func (m *Participant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Participant) XXX_Merge(src proto.Message) + func (m *Participant) XXX_Size() int + func (m *Participant) XXX_Unmarshal(b []byte) error + type RequestHeader struct + ClusterId uint64 + KeyspaceGroupId uint32 + KeyspaceId uint32 + SenderId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RequestHeader) Descriptor() ([]byte, []int) + func (*RequestHeader) ProtoMessage() + func (m *RequestHeader) GetClusterId() uint64 + func (m *RequestHeader) GetKeyspaceGroupId() uint32 + func (m *RequestHeader) GetKeyspaceId() uint32 + func (m *RequestHeader) GetSenderId() uint64 + func (m *RequestHeader) Marshal() (dAtA []byte, err error) + func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error) + func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestHeader) Reset() + func (m *RequestHeader) Size() (n int) + func (m *RequestHeader) String() string + func (m *RequestHeader) Unmarshal(dAtA []byte) error + func (m *RequestHeader) XXX_DiscardUnknown() + func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestHeader) XXX_Merge(src proto.Message) + func (m *RequestHeader) XXX_Size() int + func (m *RequestHeader) XXX_Unmarshal(b []byte) error + type ResponseHeader struct + ClusterId uint64 + Error *Error + KeyspaceGroupId uint32 + KeyspaceId uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) GetClusterId() uint64 + func (m *ResponseHeader) GetError() *Error + func (m *ResponseHeader) GetKeyspaceGroupId() uint32 + func (m *ResponseHeader) GetKeyspaceId() uint32 + func (m *ResponseHeader) Marshal() (dAtA []byte, err error) + func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) Size() (n int) + func (m *ResponseHeader) String() string + func (m *ResponseHeader) Unmarshal(dAtA []byte) error + func (m *ResponseHeader) XXX_DiscardUnknown() + func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseHeader) XXX_Merge(src proto.Message) + func (m *ResponseHeader) XXX_Size() int + func (m *ResponseHeader) XXX_Unmarshal(b []byte) error + type SplitState struct + SplitSource uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitState) Descriptor() ([]byte, []int) + func (*SplitState) ProtoMessage() + func (m *SplitState) GetSplitSource() uint32 + func (m *SplitState) Marshal() (dAtA []byte, err error) + func (m *SplitState) MarshalTo(dAtA []byte) (int, error) + func (m *SplitState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SplitState) Reset() + func (m *SplitState) Size() (n int) + func (m *SplitState) String() string + func (m *SplitState) Unmarshal(dAtA []byte) error + func (m *SplitState) XXX_DiscardUnknown() + func (m *SplitState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SplitState) XXX_Merge(src proto.Message) + func (m *SplitState) XXX_Size() int + func (m *SplitState) XXX_Unmarshal(b []byte) error + type TSOClient interface + FindGroupByKeyspaceID func(ctx context.Context, in *FindGroupByKeyspaceIDRequest, opts ...grpc.CallOption) (*FindGroupByKeyspaceIDResponse, error) + GetMinTS func(ctx context.Context, in *GetMinTSRequest, opts ...grpc.CallOption) (*GetMinTSResponse, error) + Tso func(ctx context.Context, opts ...grpc.CallOption) (TSO_TsoClient, error) + func NewTSOClient(cc *grpc.ClientConn) TSOClient + type TSOServer interface + FindGroupByKeyspaceID func(context.Context, *FindGroupByKeyspaceIDRequest) (*FindGroupByKeyspaceIDResponse, error) + GetMinTS func(context.Context, *GetMinTSRequest) (*GetMinTSResponse, error) + Tso func(TSO_TsoServer) error + type TSO_TsoClient interface + Recv func() (*TsoResponse, error) + Send func(*TsoRequest) error + type TSO_TsoServer interface + Recv func() (*TsoRequest, error) + Send func(*TsoResponse) error + type TsoRequest struct + Count uint32 + DcLocation string + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TsoRequest) Descriptor() ([]byte, []int) + func (*TsoRequest) ProtoMessage() + func (m *TsoRequest) GetCount() uint32 + func (m *TsoRequest) GetDcLocation() string + func (m *TsoRequest) GetHeader() *RequestHeader + func (m *TsoRequest) Marshal() (dAtA []byte, err error) + func (m *TsoRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TsoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TsoRequest) Reset() + func (m *TsoRequest) Size() (n int) + func (m *TsoRequest) String() string + func (m *TsoRequest) Unmarshal(dAtA []byte) error + func (m *TsoRequest) XXX_DiscardUnknown() + func (m *TsoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TsoRequest) XXX_Merge(src proto.Message) + func (m *TsoRequest) XXX_Size() int + func (m *TsoRequest) XXX_Unmarshal(b []byte) error + type TsoResponse struct + Count uint32 + Header *ResponseHeader + Timestamp *tmpb.Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TsoResponse) Descriptor() ([]byte, []int) + func (*TsoResponse) ProtoMessage() + func (m *TsoResponse) GetCount() uint32 + func (m *TsoResponse) GetHeader() *ResponseHeader + func (m *TsoResponse) GetTimestamp() *tmpb.Timestamp + func (m *TsoResponse) Marshal() (dAtA []byte, err error) + func (m *TsoResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TsoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TsoResponse) Reset() + func (m *TsoResponse) Size() (n int) + func (m *TsoResponse) String() string + func (m *TsoResponse) Unmarshal(dAtA []byte) error + func (m *TsoResponse) XXX_DiscardUnknown() + func (m *TsoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TsoResponse) XXX_Merge(src proto.Message) + func (m *TsoResponse) XXX_Size() int + func (m *TsoResponse) XXX_Unmarshal(b []byte) error + type UnimplementedTSOServer struct + func (*UnimplementedTSOServer) FindGroupByKeyspaceID(ctx context.Context, req *FindGroupByKeyspaceIDRequest) (*FindGroupByKeyspaceIDResponse, error) + func (*UnimplementedTSOServer) GetMinTS(ctx context.Context, req *GetMinTSRequest) (*GetMinTSResponse, error) + func (*UnimplementedTSOServer) Tso(srv TSO_TsoServer) error