Documentation ¶
Index ¶
- Variables
- type AllocClient
- type AllocServer
- type FetchSegmentNextReq
- func (*FetchSegmentNextReq) Descriptor() ([]byte, []int)deprecated
- func (x *FetchSegmentNextReq) GetTag() string
- func (*FetchSegmentNextReq) ProtoMessage()
- func (x *FetchSegmentNextReq) ProtoReflect() protoreflect.Message
- func (x *FetchSegmentNextReq) Reset()
- func (x *FetchSegmentNextReq) String() string
- type FetchSeqNextReq
- type FetchSnowflakeNextReq
- type SegmentClient
- type SegmentServer
- type SeqsvrErrReason
- func (r SeqsvrErrReason) Code() code.Code
- func (SeqsvrErrReason) Descriptor() protoreflect.EnumDescriptor
- func (r SeqsvrErrReason) Domain() string
- func (x SeqsvrErrReason) Enum() *SeqsvrErrReason
- func (SeqsvrErrReason) EnumDescriptor() ([]byte, []int)deprecated
- func (x SeqsvrErrReason) Number() protoreflect.EnumNumber
- func (r SeqsvrErrReason) Reason() string
- func (x SeqsvrErrReason) String() string
- func (SeqsvrErrReason) Type() protoreflect.EnumType
- type SnowflakeClient
- type SnowflakeServer
- type UUID
- type UnimplementedAllocServer
- type UnimplementedSegmentServer
- type UnimplementedSnowflakeServer
- type UnsafeAllocServer
- type UnsafeSegmentServer
- type UnsafeSnowflakeServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( SeqsvrErrReason_name = map[int32]string{ 0: "ERROR_REASON_UNSPECIFIED", 1: "SERVICE_PAUSE", 2: "NOT_FOUND_SEQUENCE", } SeqsvrErrReason_value = map[string]int32{ "ERROR_REASON_UNSPECIFIED": 0, "SERVICE_PAUSE": 1, "NOT_FOUND_SEQUENCE": 2, } )
Enum value maps for SeqsvrErrReason.
View Source
var File_api_common_proto protoreflect.FileDescriptor
View Source
var File_api_segment_proto protoreflect.FileDescriptor
View Source
var File_api_seqsvr_proto protoreflect.FileDescriptor
View Source
var File_api_snowflake_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AllocClient ¶
type AllocClient interface {
FetchNext(context.Context, *FetchSeqNextReq) (*UUID, error)
}
type AllocServer ¶
type AllocServer interface { FetchNext(context.Context, *FetchSeqNextReq) (*UUID, error) UnsafeAllocServer }
type FetchSegmentNextReq ¶
type FetchSegmentNextReq struct { Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` // contains filtered or unexported fields }
func (*FetchSegmentNextReq) Descriptor
deprecated
func (*FetchSegmentNextReq) Descriptor() ([]byte, []int)
Deprecated: Use FetchSegmentNextReq.ProtoReflect.Descriptor instead.
func (*FetchSegmentNextReq) GetTag ¶
func (x *FetchSegmentNextReq) GetTag() string
func (*FetchSegmentNextReq) ProtoMessage ¶
func (*FetchSegmentNextReq) ProtoMessage()
func (*FetchSegmentNextReq) ProtoReflect ¶
func (x *FetchSegmentNextReq) ProtoReflect() protoreflect.Message
func (*FetchSegmentNextReq) Reset ¶
func (x *FetchSegmentNextReq) Reset()
func (*FetchSegmentNextReq) String ¶
func (x *FetchSegmentNextReq) String() string
type FetchSeqNextReq ¶
type FetchSeqNextReq struct { ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` // contains filtered or unexported fields }
func (*FetchSeqNextReq) Descriptor
deprecated
func (*FetchSeqNextReq) Descriptor() ([]byte, []int)
Deprecated: Use FetchSeqNextReq.ProtoReflect.Descriptor instead.
func (*FetchSeqNextReq) GetID ¶
func (x *FetchSeqNextReq) GetID() uint32
func (*FetchSeqNextReq) ProtoMessage ¶
func (*FetchSeqNextReq) ProtoMessage()
func (*FetchSeqNextReq) ProtoReflect ¶
func (x *FetchSeqNextReq) ProtoReflect() protoreflect.Message
func (*FetchSeqNextReq) Reset ¶
func (x *FetchSeqNextReq) Reset()
func (*FetchSeqNextReq) String ¶
func (x *FetchSeqNextReq) String() string
type FetchSnowflakeNextReq ¶
type FetchSnowflakeNextReq struct {
// contains filtered or unexported fields
}
func (*FetchSnowflakeNextReq) Descriptor
deprecated
func (*FetchSnowflakeNextReq) Descriptor() ([]byte, []int)
Deprecated: Use FetchSnowflakeNextReq.ProtoReflect.Descriptor instead.
func (*FetchSnowflakeNextReq) ProtoMessage ¶
func (*FetchSnowflakeNextReq) ProtoMessage()
func (*FetchSnowflakeNextReq) ProtoReflect ¶
func (x *FetchSnowflakeNextReq) ProtoReflect() protoreflect.Message
func (*FetchSnowflakeNextReq) Reset ¶
func (x *FetchSnowflakeNextReq) Reset()
func (*FetchSnowflakeNextReq) String ¶
func (x *FetchSnowflakeNextReq) String() string
type SegmentClient ¶
type SegmentClient interface {
FetchNext(context.Context, *FetchSegmentNextReq) (*UUID, error)
}
type SegmentServer ¶
type SegmentServer interface { FetchNext(context.Context, *FetchSegmentNextReq) (*UUID, error) UnsafeSegmentServer }
type SeqsvrErrReason ¶
type SeqsvrErrReason int32
const ( // Do not use this default value. SeqsvrErrReason_ERROR_REASON_UNSPECIFIED SeqsvrErrReason = 0 SeqsvrErrReason_SERVICE_PAUSE SeqsvrErrReason = 1 SeqsvrErrReason_NOT_FOUND_SEQUENCE SeqsvrErrReason = 2 )
func (SeqsvrErrReason) Code ¶
func (r SeqsvrErrReason) Code() code.Code
func (SeqsvrErrReason) Descriptor ¶
func (SeqsvrErrReason) Descriptor() protoreflect.EnumDescriptor
func (SeqsvrErrReason) Domain ¶
func (r SeqsvrErrReason) Domain() string
func (SeqsvrErrReason) Enum ¶
func (x SeqsvrErrReason) Enum() *SeqsvrErrReason
func (SeqsvrErrReason) EnumDescriptor
deprecated
func (SeqsvrErrReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use SeqsvrErrReason.Descriptor instead.
func (SeqsvrErrReason) Number ¶
func (x SeqsvrErrReason) Number() protoreflect.EnumNumber
func (SeqsvrErrReason) Reason ¶
func (r SeqsvrErrReason) Reason() string
func (SeqsvrErrReason) String ¶
func (x SeqsvrErrReason) String() string
func (SeqsvrErrReason) Type ¶
func (SeqsvrErrReason) Type() protoreflect.EnumType
type SnowflakeClient ¶
type SnowflakeClient interface {
FetchNext(context.Context, *FetchSnowflakeNextReq) (*UUID, error)
}
type SnowflakeServer ¶
type SnowflakeServer interface { FetchNext(context.Context, *FetchSnowflakeNextReq) (*UUID, error) UnsafeSnowflakeServer }
type UUID ¶
type UUID struct { Val uint64 `protobuf:"varint,1,opt,name=val,proto3" json:"val,omitempty"` // contains filtered or unexported fields }
func (*UUID) Descriptor
deprecated
func (*UUID) ProtoMessage ¶
func (*UUID) ProtoMessage()
func (*UUID) ProtoReflect ¶
func (x *UUID) ProtoReflect() protoreflect.Message
type UnimplementedAllocServer ¶
type UnimplementedAllocServer struct { }
UnimplementedAllocServer must be embedded to have forward compatible implementations.
func (UnimplementedAllocServer) FetchNext ¶
func (UnimplementedAllocServer) FetchNext(context.Context, *FetchSeqNextReq) (*UUID, error)
type UnimplementedSegmentServer ¶
type UnimplementedSegmentServer struct { }
UnimplementedSegmentServer must be embedded to have forward compatible implementations.
func (UnimplementedSegmentServer) FetchNext ¶
func (UnimplementedSegmentServer) FetchNext(context.Context, *FetchSegmentNextReq) (*UUID, error)
type UnimplementedSnowflakeServer ¶
type UnimplementedSnowflakeServer struct { }
UnimplementedSnowflakeServer must be embedded to have forward compatible implementations.
func (UnimplementedSnowflakeServer) FetchNext ¶
func (UnimplementedSnowflakeServer) FetchNext(context.Context, *FetchSnowflakeNextReq) (*UUID, error)
type UnsafeAllocServer ¶
type UnsafeAllocServer interface {
// contains filtered or unexported methods
}
type UnsafeSegmentServer ¶
type UnsafeSegmentServer interface {
// contains filtered or unexported methods
}
type UnsafeSnowflakeServer ¶
type UnsafeSnowflakeServer interface {
// contains filtered or unexported methods
}
Source Files ¶
Click to show internal directories.
Click to hide internal directories.