tsopb

package
v0.0.0-...-17bdaaa Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2024 License: Apache-2.0 Imports: 11 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTsopb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTsopb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTsopb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ErrorType_name = map[int32]string{
	0: "OK",
	1: "UNKNOWN",
	2: "NOT_BOOTSTRAPPED",
	3: "ALREADY_BOOTSTRAPPED",
	4: "INVALID_VALUE",
	5: "CLUSTER_MISMATCHED",
}
View Source 
var ErrorType_value = map[string]int32{
	"OK":                   0,
	"UNKNOWN":              1,
	"NOT_BOOTSTRAPPED":     2,
	"ALREADY_BOOTSTRAPPED": 3,
	"INVALID_VALUE":        4,
	"CLUSTER_MISMATCHED":   5,
}

Functions

func RegisterTSOServer 

func RegisterTSOServer(s *grpc.Server, srv TSOServer)

Types

type Error 

type Error struct {
	Type    ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=tsopb.ErrorType" json:"type,omitempty"`
	Message string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*Error) Descriptor 

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

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetType 

func (m *Error) GetType() ErrorType

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type ErrorType 

type ErrorType int32
const (
	ErrorType_OK                   ErrorType = 0
	ErrorType_UNKNOWN              ErrorType = 1
	ErrorType_NOT_BOOTSTRAPPED     ErrorType = 2
	ErrorType_ALREADY_BOOTSTRAPPED ErrorType = 3
	ErrorType_INVALID_VALUE        ErrorType = 4
	ErrorType_CLUSTER_MISMATCHED   ErrorType = 5
)

func (ErrorType) EnumDescriptor 

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

func (ErrorType) String 

func (x ErrorType) String() string

type FindGroupByKeyspaceIDRequest 

type FindGroupByKeyspaceIDRequest struct {
	Header     *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	KeyspaceId uint32         `protobuf:"varint,2,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
}

func (*FindGroupByKeyspaceIDRequest) Descriptor 

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

func (*FindGroupByKeyspaceIDRequest) GetHeader 

func (m *FindGroupByKeyspaceIDRequest) GetHeader() *RequestHeader

func (*FindGroupByKeyspaceIDRequest) GetKeyspaceId 

func (m *FindGroupByKeyspaceIDRequest) GetKeyspaceId() uint32

func (*FindGroupByKeyspaceIDRequest) Marshal 

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

func (*FindGroupByKeyspaceIDRequest) MarshalTo 

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

func (*FindGroupByKeyspaceIDRequest) MarshalToSizedBuffer 

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

func (*FindGroupByKeyspaceIDRequest) ProtoMessage 

func (*FindGroupByKeyspaceIDRequest) ProtoMessage()

func (*FindGroupByKeyspaceIDRequest) Reset 

func (m *FindGroupByKeyspaceIDRequest) Reset()

func (*FindGroupByKeyspaceIDRequest) Size 

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

func (*FindGroupByKeyspaceIDRequest) String 

func (m *FindGroupByKeyspaceIDRequest) String() string

func (*FindGroupByKeyspaceIDRequest) Unmarshal 

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

func (*FindGroupByKeyspaceIDRequest) XXX_DiscardUnknown 

func (m *FindGroupByKeyspaceIDRequest) XXX_DiscardUnknown()

func (*FindGroupByKeyspaceIDRequest) XXX_Marshal 

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

func (*FindGroupByKeyspaceIDRequest) XXX_Merge 

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

func (*FindGroupByKeyspaceIDRequest) XXX_Size 

func (m *FindGroupByKeyspaceIDRequest) XXX_Size() int

func (*FindGroupByKeyspaceIDRequest) XXX_Unmarshal 

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

type FindGroupByKeyspaceIDResponse 

type FindGroupByKeyspaceIDResponse struct {
	Header        *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	KeyspaceGroup *KeyspaceGroup  `protobuf:"bytes,2,opt,name=keyspace_group,json=keyspaceGroup,proto3" json:"keyspace_group,omitempty"`
}

func (*FindGroupByKeyspaceIDResponse) Descriptor 

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

func (*FindGroupByKeyspaceIDResponse) GetHeader 

func (m *FindGroupByKeyspaceIDResponse) GetHeader() *ResponseHeader

func (*FindGroupByKeyspaceIDResponse) GetKeyspaceGroup 

func (m *FindGroupByKeyspaceIDResponse) GetKeyspaceGroup() *KeyspaceGroup

func (*FindGroupByKeyspaceIDResponse) Marshal 

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

func (*FindGroupByKeyspaceIDResponse) MarshalTo 

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

func (*FindGroupByKeyspaceIDResponse) MarshalToSizedBuffer 

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

func (*FindGroupByKeyspaceIDResponse) ProtoMessage 

func (*FindGroupByKeyspaceIDResponse) ProtoMessage()

func (*FindGroupByKeyspaceIDResponse) Reset 

func (m *FindGroupByKeyspaceIDResponse) Reset()

func (*FindGroupByKeyspaceIDResponse) Size 

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

func (*FindGroupByKeyspaceIDResponse) String 

func (m *FindGroupByKeyspaceIDResponse) String() string

func (*FindGroupByKeyspaceIDResponse) Unmarshal 

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

func (*FindGroupByKeyspaceIDResponse) XXX_DiscardUnknown 

func (m *FindGroupByKeyspaceIDResponse) XXX_DiscardUnknown()

func (*FindGroupByKeyspaceIDResponse) XXX_Marshal 

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

func (*FindGroupByKeyspaceIDResponse) XXX_Merge 

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

func (*FindGroupByKeyspaceIDResponse) XXX_Size 

func (m *FindGroupByKeyspaceIDResponse) XXX_Size() int

func (*FindGroupByKeyspaceIDResponse) XXX_Unmarshal 

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

type GetMinTSRequest 

type GetMinTSRequest struct {
	Header     *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DcLocation string         `protobuf:"bytes,2,opt,name=dc_location,json=dcLocation,proto3" json:"dc_location,omitempty"`
}

func (*GetMinTSRequest) Descriptor 

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

func (*GetMinTSRequest) GetDcLocation 

func (m *GetMinTSRequest) GetDcLocation() string

func (*GetMinTSRequest) GetHeader 

func (m *GetMinTSRequest) GetHeader() *RequestHeader

func (*GetMinTSRequest) Marshal 

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

func (*GetMinTSRequest) MarshalTo 

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

func (*GetMinTSRequest) MarshalToSizedBuffer 

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

func (*GetMinTSRequest) ProtoMessage 

func (*GetMinTSRequest) ProtoMessage()

func (*GetMinTSRequest) Reset 

func (m *GetMinTSRequest) Reset()

func (*GetMinTSRequest) Size 

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

func (*GetMinTSRequest) String 

func (m *GetMinTSRequest) String() string

func (*GetMinTSRequest) Unmarshal 

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

func (*GetMinTSRequest) XXX_DiscardUnknown 

func (m *GetMinTSRequest) XXX_DiscardUnknown()

func (*GetMinTSRequest) XXX_Marshal 

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

func (*GetMinTSRequest) XXX_Merge 

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

func (*GetMinTSRequest) XXX_Size 

func (m *GetMinTSRequest) XXX_Size() int

func (*GetMinTSRequest) XXX_Unmarshal 

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

type GetMinTSResponse 

type GetMinTSResponse struct {
	Header    *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Timestamp *pdpb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// the count of keyspace group primaries that the TSO server/pod is serving
	KeyspaceGroupsServing uint32 `` /* 127-byte string literal not displayed */
	// the total count of keyspace groups
	KeyspaceGroupsTotal uint32 `protobuf:"varint,4,opt,name=keyspace_groups_total,json=keyspaceGroupsTotal,proto3" json:"keyspace_groups_total,omitempty"`
}

func (*GetMinTSResponse) Descriptor 

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

func (*GetMinTSResponse) GetHeader 

func (m *GetMinTSResponse) GetHeader() *ResponseHeader

func (*GetMinTSResponse) GetKeyspaceGroupsServing 

func (m *GetMinTSResponse) GetKeyspaceGroupsServing() uint32

func (*GetMinTSResponse) GetKeyspaceGroupsTotal 

func (m *GetMinTSResponse) GetKeyspaceGroupsTotal() uint32

func (*GetMinTSResponse) GetTimestamp 

func (m *GetMinTSResponse) GetTimestamp() *pdpb.Timestamp

func (*GetMinTSResponse) Marshal 

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

func (*GetMinTSResponse) MarshalTo 

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

func (*GetMinTSResponse) MarshalToSizedBuffer 

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

func (*GetMinTSResponse) ProtoMessage 

func (*GetMinTSResponse) ProtoMessage()

func (*GetMinTSResponse) Reset 

func (m *GetMinTSResponse) Reset()

func (*GetMinTSResponse) Size 

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

func (*GetMinTSResponse) String 

func (m *GetMinTSResponse) String() string

func (*GetMinTSResponse) Unmarshal 

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

func (*GetMinTSResponse) XXX_DiscardUnknown 

func (m *GetMinTSResponse) XXX_DiscardUnknown()

func (*GetMinTSResponse) XXX_Marshal 

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

func (*GetMinTSResponse) XXX_Merge 

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

func (*GetMinTSResponse) XXX_Size 

func (m *GetMinTSResponse) XXX_Size() int

func (*GetMinTSResponse) XXX_Unmarshal 

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

type KeyspaceGroup 

type KeyspaceGroup struct {
	Id         uint32                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserKind   string                 `protobuf:"bytes,2,opt,name=user_kind,json=userKind,proto3" json:"user_kind,omitempty"`
	SplitState *SplitState            `protobuf:"bytes,3,opt,name=split_state,json=splitState,proto3" json:"split_state,omitempty"`
	Members    []*KeyspaceGroupMember `protobuf:"bytes,4,rep,name=members,proto3" json:"members,omitempty"`
}

func (*KeyspaceGroup) Descriptor 

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

func (*KeyspaceGroup) GetId 

func (m *KeyspaceGroup) GetId() uint32

func (*KeyspaceGroup) GetMembers 

func (m *KeyspaceGroup) GetMembers() []*KeyspaceGroupMember

func (*KeyspaceGroup) GetSplitState 

func (m *KeyspaceGroup) GetSplitState() *SplitState

func (*KeyspaceGroup) GetUserKind 

func (m *KeyspaceGroup) GetUserKind() string

func (*KeyspaceGroup) Marshal 

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

func (*KeyspaceGroup) MarshalTo 

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

func (*KeyspaceGroup) MarshalToSizedBuffer 

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

func (*KeyspaceGroup) ProtoMessage 

func (*KeyspaceGroup) ProtoMessage()

func (*KeyspaceGroup) Reset 

func (m *KeyspaceGroup) Reset()

func (*KeyspaceGroup) Size 

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

func (*KeyspaceGroup) String 

func (m *KeyspaceGroup) String() string

func (*KeyspaceGroup) Unmarshal 

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

func (*KeyspaceGroup) XXX_DiscardUnknown 

func (m *KeyspaceGroup) XXX_DiscardUnknown()

func (*KeyspaceGroup) XXX_Marshal 

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

func (*KeyspaceGroup) XXX_Merge 

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

func (*KeyspaceGroup) XXX_Size 

func (m *KeyspaceGroup) XXX_Size() int

func (*KeyspaceGroup) XXX_Unmarshal 

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

type KeyspaceGroupMember 

type KeyspaceGroupMember struct {
	Address   string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	IsPrimary bool   `protobuf:"varint,2,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
}

func (*KeyspaceGroupMember) Descriptor 

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

func (*KeyspaceGroupMember) GetAddress 

func (m *KeyspaceGroupMember) GetAddress() string

func (*KeyspaceGroupMember) GetIsPrimary 

func (m *KeyspaceGroupMember) GetIsPrimary() bool

func (*KeyspaceGroupMember) Marshal 

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

func (*KeyspaceGroupMember) MarshalTo 

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

func (*KeyspaceGroupMember) MarshalToSizedBuffer 

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

func (*KeyspaceGroupMember) ProtoMessage 

func (*KeyspaceGroupMember) ProtoMessage()

func (*KeyspaceGroupMember) Reset 

func (m *KeyspaceGroupMember) Reset()

func (*KeyspaceGroupMember) Size 

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

func (*KeyspaceGroupMember) String 

func (m *KeyspaceGroupMember) String() string

func (*KeyspaceGroupMember) Unmarshal 

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

func (*KeyspaceGroupMember) XXX_DiscardUnknown 

func (m *KeyspaceGroupMember) XXX_DiscardUnknown()

func (*KeyspaceGroupMember) XXX_Marshal 

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

func (*KeyspaceGroupMember) XXX_Merge 

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

func (*KeyspaceGroupMember) XXX_Size 

func (m *KeyspaceGroupMember) XXX_Size() int

func (*KeyspaceGroupMember) XXX_Unmarshal 

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

type Participant 

type Participant struct {
	// name is the unique name of the TSO participant.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// id is the unique id of the TSO participant.
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// listen_urls is the serivce endpoint list in the url format.
	// listen_urls[0] is primary service endpoint.
	ListenUrls []string `protobuf:"bytes,3,rep,name=listen_urls,json=listenUrls,proto3" json:"listen_urls,omitempty"`
}

func (*Participant) Descriptor 

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

func (*Participant) GetId 

func (m *Participant) GetId() uint64

func (*Participant) GetListenUrls 

func (m *Participant) GetListenUrls() []string

func (*Participant) GetName 

func (m *Participant) GetName() string

func (*Participant) Marshal 

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

func (*Participant) MarshalTo 

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

func (*Participant) MarshalToSizedBuffer 

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

func (*Participant) ProtoMessage 

func (*Participant) ProtoMessage()

func (*Participant) Reset 

func (m *Participant) Reset()

func (*Participant) Size 

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

func (*Participant) String 

func (m *Participant) String() string

func (*Participant) Unmarshal 

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

func (*Participant) XXX_DiscardUnknown 

func (m *Participant) XXX_DiscardUnknown()

func (*Participant) XXX_Marshal 

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

func (*Participant) XXX_Merge 

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

func (*Participant) XXX_Size 

func (m *Participant) XXX_Size() int

func (*Participant) XXX_Unmarshal 

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

type RequestHeader 

type RequestHeader struct {
	// cluster_id is the ID of the cluster which be sent to.
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// sender_id is the ID of the sender server.
	SenderId uint64 `protobuf:"varint,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	// keyspace_id is the unique id of the tenant/keyspace.
	KeyspaceId uint32 `protobuf:"varint,3,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
	// keyspace_group_id is the unique id of the keyspace group to which the tenant/keyspace belongs.
	KeyspaceGroupId uint32 `protobuf:"varint,4,opt,name=keyspace_group_id,json=keyspaceGroupId,proto3" json:"keyspace_group_id,omitempty"`
}

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterId 

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) GetKeyspaceGroupId 

func (m *RequestHeader) GetKeyspaceGroupId() uint32

func (*RequestHeader) GetKeyspaceId 

func (m *RequestHeader) GetKeyspaceId() uint32

func (*RequestHeader) GetSenderId 

func (m *RequestHeader) GetSenderId() uint64

func (*RequestHeader) Marshal 

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

func (*RequestHeader) MarshalTo 

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

func (*RequestHeader) MarshalToSizedBuffer 

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

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

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

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

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

func (*RequestHeader) XXX_DiscardUnknown 

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal 

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

func (*RequestHeader) XXX_Merge 

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

func (*RequestHeader) XXX_Size 

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal 

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

type ResponseHeader 

type ResponseHeader struct {
	// cluster_id is the ID of the cluster which sent the response.
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Error     *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// keyspace_id is the unique id of the tenant/keyspace as the response receiver.
	KeyspaceId uint32 `protobuf:"varint,3,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
	// keyspace_group_id is the unique id of the keyspace group to which the tenant/keyspace belongs.
	KeyspaceGroupId uint32 `protobuf:"varint,4,opt,name=keyspace_group_id,json=keyspaceGroupId,proto3" json:"keyspace_group_id,omitempty"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetClusterId 

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError 

func (m *ResponseHeader) GetError() *Error

func (*ResponseHeader) GetKeyspaceGroupId 

func (m *ResponseHeader) GetKeyspaceGroupId() uint32

func (*ResponseHeader) GetKeyspaceId 

func (m *ResponseHeader) GetKeyspaceId() uint32

func (*ResponseHeader) Marshal 

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

func (*ResponseHeader) MarshalTo 

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

func (*ResponseHeader) MarshalToSizedBuffer 

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

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

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

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

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

func (*ResponseHeader) XXX_DiscardUnknown 

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal 

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

func (*ResponseHeader) XXX_Merge 

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

func (*ResponseHeader) XXX_Size 

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal 

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

type SplitState 

type SplitState struct {
	SplitSource uint32 `protobuf:"varint,1,opt,name=split_source,json=splitSource,proto3" json:"split_source,omitempty"`
}

func (*SplitState) Descriptor 

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

func (*SplitState) GetSplitSource 

func (m *SplitState) GetSplitSource() uint32

func (*SplitState) Marshal 

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

func (*SplitState) MarshalTo 

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

func (*SplitState) MarshalToSizedBuffer 

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

func (*SplitState) ProtoMessage 

func (*SplitState) ProtoMessage()

func (*SplitState) Reset 

func (m *SplitState) Reset()

func (*SplitState) Size 

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

func (*SplitState) String 

func (m *SplitState) String() string

func (*SplitState) Unmarshal 

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

func (*SplitState) XXX_DiscardUnknown 

func (m *SplitState) XXX_DiscardUnknown()

func (*SplitState) XXX_Marshal 

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

func (*SplitState) XXX_Merge 

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

func (*SplitState) XXX_Size 

func (m *SplitState) XXX_Size() int

func (*SplitState) XXX_Unmarshal 

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

type TSOClient 

type TSOClient interface {
	Tso(ctx context.Context, opts ...grpc.CallOption) (TSO_TsoClient, error)
	// Find the keyspace group that the keyspace belongs to by keyspace id.
	FindGroupByKeyspaceID(ctx context.Context, in *FindGroupByKeyspaceIDRequest, opts ...grpc.CallOption) (*FindGroupByKeyspaceIDResponse, error)
	// Get the minimum timestamp across all keyspace groups served by the TSO server who receives
	// and handle the request. If the TSO server/pod is not serving any keyspace group, return
	// an empty timestamp, and the client needs to skip the empty timestamps when collecting
	// the min timestamp from all TSO servers/pods.
	GetMinTS(ctx context.Context, in *GetMinTSRequest, opts ...grpc.CallOption) (*GetMinTSResponse, error)
}

TSOClient is the client API for TSO service.

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

func NewTSOClient 

func NewTSOClient(cc *grpc.ClientConn) TSOClient

type TSOServer 

type TSOServer interface {
	Tso(TSO_TsoServer) error
	// Find the keyspace group that the keyspace belongs to by keyspace id.
	FindGroupByKeyspaceID(context.Context, *FindGroupByKeyspaceIDRequest) (*FindGroupByKeyspaceIDResponse, error)
	// Get the minimum timestamp across all keyspace groups served by the TSO server who receives
	// and handle the request. If the TSO server/pod is not serving any keyspace group, return
	// an empty timestamp, and the client needs to skip the empty timestamps when collecting
	// the min timestamp from all TSO servers/pods.
	GetMinTS(context.Context, *GetMinTSRequest) (*GetMinTSResponse, error)
}

TSOServer is the server API for TSO service.

type TSO_TsoClient 

type TSO_TsoClient interface {
	Send(*TsoRequest) error
	Recv() (*TsoResponse, error)
	grpc.ClientStream
}

type TSO_TsoServer 

type TSO_TsoServer interface {
	Send(*TsoResponse) error
	Recv() (*TsoRequest, error)
	grpc.ServerStream
}

type TsoRequest 

type TsoRequest struct {
	Header     *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Count      uint32         `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	DcLocation string         `protobuf:"bytes,3,opt,name=dc_location,json=dcLocation,proto3" json:"dc_location,omitempty"`
}

func (*TsoRequest) Descriptor 

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

func (*TsoRequest) GetCount 

func (m *TsoRequest) GetCount() uint32

func (*TsoRequest) GetDcLocation 

func (m *TsoRequest) GetDcLocation() string

func (*TsoRequest) GetHeader 

func (m *TsoRequest) GetHeader() *RequestHeader

func (*TsoRequest) Marshal 

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

func (*TsoRequest) MarshalTo 

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

func (*TsoRequest) MarshalToSizedBuffer 

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

func (*TsoRequest) ProtoMessage 

func (*TsoRequest) ProtoMessage()

func (*TsoRequest) Reset 

func (m *TsoRequest) Reset()

func (*TsoRequest) Size 

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

func (*TsoRequest) String 

func (m *TsoRequest) String() string

func (*TsoRequest) Unmarshal 

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

func (*TsoRequest) XXX_DiscardUnknown 

func (m *TsoRequest) XXX_DiscardUnknown()

func (*TsoRequest) XXX_Marshal 

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

func (*TsoRequest) XXX_Merge 

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

func (*TsoRequest) XXX_Size 

func (m *TsoRequest) XXX_Size() int

func (*TsoRequest) XXX_Unmarshal 

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

type TsoResponse 

type TsoResponse struct {
	Header    *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Count     uint32          `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Timestamp *pdpb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*TsoResponse) Descriptor 

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

func (*TsoResponse) GetCount 

func (m *TsoResponse) GetCount() uint32

func (*TsoResponse) GetHeader 

func (m *TsoResponse) GetHeader() *ResponseHeader

func (*TsoResponse) GetTimestamp 

func (m *TsoResponse) GetTimestamp() *pdpb.Timestamp

func (*TsoResponse) Marshal 

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

func (*TsoResponse) MarshalTo 

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

func (*TsoResponse) MarshalToSizedBuffer 

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

func (*TsoResponse) ProtoMessage 

func (*TsoResponse) ProtoMessage()

func (*TsoResponse) Reset 

func (m *TsoResponse) Reset()

func (*TsoResponse) Size 

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

func (*TsoResponse) String 

func (m *TsoResponse) String() string

func (*TsoResponse) Unmarshal 

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

func (*TsoResponse) XXX_DiscardUnknown 

func (m *TsoResponse) XXX_DiscardUnknown()

func (*TsoResponse) XXX_Marshal 

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

func (*TsoResponse) XXX_Merge 

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

func (*TsoResponse) XXX_Size 

func (m *TsoResponse) XXX_Size() int

func (*TsoResponse) XXX_Unmarshal 

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

type UnimplementedTSOServer 

type UnimplementedTSOServer struct {
}

UnimplementedTSOServer can be embedded to have forward compatible implementations.

func (*UnimplementedTSOServer) FindGroupByKeyspaceID 

func (*UnimplementedTSOServer) FindGroupByKeyspaceID(ctx context.Context, req *FindGroupByKeyspaceIDRequest) (*FindGroupByKeyspaceIDResponse, error)

func (*UnimplementedTSOServer) GetMinTS 

func (*UnimplementedTSOServer) GetMinTS(ctx context.Context, req *GetMinTSRequest) (*GetMinTSResponse, error)

func (*UnimplementedTSOServer) Tso 

func (*UnimplementedTSOServer) Tso(srv TSO_TsoServer) 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.