Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowGcpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGcpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupGcpb = fmt.Errorf("proto: unexpected end of group") + var ErrorType_name = map[int32]string + var ErrorType_value = map[string]int32 + func RegisterGCServer(s *grpc.Server, srv GCServer) + 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_NOT_BOOTSTRAPPED + const ErrorType_OK + const ErrorType_REVISION_MISMATCH + const ErrorType_SAFEPOINT_ROLLBACK + const ErrorType_UNKNOWN + func (ErrorType) EnumDescriptor() ([]byte, []int) + func (x ErrorType) String() string + type GCClient interface + GetMinServiceSafePoint func(ctx context.Context, in *GetMinServiceSafePointRequest, ...) (*GetMinServiceSafePointResponse, error) + ListKeySpaces func(ctx context.Context, in *ListKeySpacesRequest, opts ...grpc.CallOption) (*ListKeySpacesResponse, error) + UpdateGCSafePoint func(ctx context.Context, in *UpdateGCSafePointRequest, opts ...grpc.CallOption) (*UpdateGCSafePointResponse, error) + UpdateServiceSafePoint func(ctx context.Context, in *UpdateServiceSafePointRequest, ...) (*UpdateServiceSafePointResponse, error) + func NewGCClient(cc *grpc.ClientConn) GCClient + type GCServer interface + GetMinServiceSafePoint func(context.Context, *GetMinServiceSafePointRequest) (*GetMinServiceSafePointResponse, error) + ListKeySpaces func(context.Context, *ListKeySpacesRequest) (*ListKeySpacesResponse, error) + UpdateGCSafePoint func(context.Context, *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error) + UpdateServiceSafePoint func(context.Context, *UpdateServiceSafePointRequest) (*UpdateServiceSafePointResponse, error) + type GetMinServiceSafePointRequest struct + Header *RequestHeader + SpaceId []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMinServiceSafePointRequest) Descriptor() ([]byte, []int) + func (*GetMinServiceSafePointRequest) ProtoMessage() + func (m *GetMinServiceSafePointRequest) GetHeader() *RequestHeader + func (m *GetMinServiceSafePointRequest) GetSpaceId() []byte + func (m *GetMinServiceSafePointRequest) Marshal() (dAtA []byte, err error) + func (m *GetMinServiceSafePointRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetMinServiceSafePointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetMinServiceSafePointRequest) Reset() + func (m *GetMinServiceSafePointRequest) Size() (n int) + func (m *GetMinServiceSafePointRequest) String() string + func (m *GetMinServiceSafePointRequest) Unmarshal(dAtA []byte) error + func (m *GetMinServiceSafePointRequest) XXX_DiscardUnknown() + func (m *GetMinServiceSafePointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMinServiceSafePointRequest) XXX_Merge(src proto.Message) + func (m *GetMinServiceSafePointRequest) XXX_Size() int + func (m *GetMinServiceSafePointRequest) XXX_Unmarshal(b []byte) error + type GetMinServiceSafePointResponse struct + Header *ResponseHeader + Revision int64 + SafePoint uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMinServiceSafePointResponse) Descriptor() ([]byte, []int) + func (*GetMinServiceSafePointResponse) ProtoMessage() + func (m *GetMinServiceSafePointResponse) GetHeader() *ResponseHeader + func (m *GetMinServiceSafePointResponse) GetRevision() int64 + func (m *GetMinServiceSafePointResponse) GetSafePoint() uint64 + func (m *GetMinServiceSafePointResponse) Marshal() (dAtA []byte, err error) + func (m *GetMinServiceSafePointResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetMinServiceSafePointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetMinServiceSafePointResponse) Reset() + func (m *GetMinServiceSafePointResponse) Size() (n int) + func (m *GetMinServiceSafePointResponse) String() string + func (m *GetMinServiceSafePointResponse) Unmarshal(dAtA []byte) error + func (m *GetMinServiceSafePointResponse) XXX_DiscardUnknown() + func (m *GetMinServiceSafePointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMinServiceSafePointResponse) XXX_Merge(src proto.Message) + func (m *GetMinServiceSafePointResponse) XXX_Size() int + func (m *GetMinServiceSafePointResponse) XXX_Unmarshal(b []byte) error + type KeySpace struct + GcSafePoint uint64 + SpaceId []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeySpace) Descriptor() ([]byte, []int) + func (*KeySpace) ProtoMessage() + func (m *KeySpace) GetGcSafePoint() uint64 + func (m *KeySpace) GetSpaceId() []byte + func (m *KeySpace) Marshal() (dAtA []byte, err error) + func (m *KeySpace) MarshalTo(dAtA []byte) (int, error) + func (m *KeySpace) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeySpace) Reset() + func (m *KeySpace) Size() (n int) + func (m *KeySpace) String() string + func (m *KeySpace) Unmarshal(dAtA []byte) error + func (m *KeySpace) XXX_DiscardUnknown() + func (m *KeySpace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeySpace) XXX_Merge(src proto.Message) + func (m *KeySpace) XXX_Size() int + func (m *KeySpace) XXX_Unmarshal(b []byte) error + type ListKeySpacesRequest struct + Header *RequestHeader + WithGcSafePoint bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListKeySpacesRequest) Descriptor() ([]byte, []int) + func (*ListKeySpacesRequest) ProtoMessage() + func (m *ListKeySpacesRequest) GetHeader() *RequestHeader + func (m *ListKeySpacesRequest) GetWithGcSafePoint() bool + func (m *ListKeySpacesRequest) Marshal() (dAtA []byte, err error) + func (m *ListKeySpacesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListKeySpacesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListKeySpacesRequest) Reset() + func (m *ListKeySpacesRequest) Size() (n int) + func (m *ListKeySpacesRequest) String() string + func (m *ListKeySpacesRequest) Unmarshal(dAtA []byte) error + func (m *ListKeySpacesRequest) XXX_DiscardUnknown() + func (m *ListKeySpacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListKeySpacesRequest) XXX_Merge(src proto.Message) + func (m *ListKeySpacesRequest) XXX_Size() int + func (m *ListKeySpacesRequest) XXX_Unmarshal(b []byte) error + type ListKeySpacesResponse struct + Header *ResponseHeader + KeySpaces []*KeySpace + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListKeySpacesResponse) Descriptor() ([]byte, []int) + func (*ListKeySpacesResponse) ProtoMessage() + func (m *ListKeySpacesResponse) GetHeader() *ResponseHeader + func (m *ListKeySpacesResponse) GetKeySpaces() []*KeySpace + func (m *ListKeySpacesResponse) Marshal() (dAtA []byte, err error) + func (m *ListKeySpacesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListKeySpacesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListKeySpacesResponse) Reset() + func (m *ListKeySpacesResponse) Size() (n int) + func (m *ListKeySpacesResponse) String() string + func (m *ListKeySpacesResponse) Unmarshal(dAtA []byte) error + func (m *ListKeySpacesResponse) XXX_DiscardUnknown() + func (m *ListKeySpacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListKeySpacesResponse) XXX_Merge(src proto.Message) + func (m *ListKeySpacesResponse) XXX_Size() int + func (m *ListKeySpacesResponse) XXX_Unmarshal(b []byte) error + type RequestHeader struct + ClusterId uint64 + 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) 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 + 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) 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 UnimplementedGCServer struct + func (*UnimplementedGCServer) GetMinServiceSafePoint(ctx context.Context, req *GetMinServiceSafePointRequest) (*GetMinServiceSafePointResponse, error) + func (*UnimplementedGCServer) ListKeySpaces(ctx context.Context, req *ListKeySpacesRequest) (*ListKeySpacesResponse, error) + func (*UnimplementedGCServer) UpdateGCSafePoint(ctx context.Context, req *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error) + func (*UnimplementedGCServer) UpdateServiceSafePoint(ctx context.Context, req *UpdateServiceSafePointRequest) (*UpdateServiceSafePointResponse, error) + type UpdateGCSafePointRequest struct + Header *RequestHeader + Revision int64 + SafePoint uint64 + SpaceId []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateGCSafePointRequest) Descriptor() ([]byte, []int) + func (*UpdateGCSafePointRequest) ProtoMessage() + func (m *UpdateGCSafePointRequest) GetHeader() *RequestHeader + func (m *UpdateGCSafePointRequest) GetRevision() int64 + func (m *UpdateGCSafePointRequest) GetSafePoint() uint64 + func (m *UpdateGCSafePointRequest) GetSpaceId() []byte + func (m *UpdateGCSafePointRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateGCSafePointRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateGCSafePointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateGCSafePointRequest) Reset() + func (m *UpdateGCSafePointRequest) Size() (n int) + func (m *UpdateGCSafePointRequest) String() string + func (m *UpdateGCSafePointRequest) Unmarshal(dAtA []byte) error + func (m *UpdateGCSafePointRequest) XXX_DiscardUnknown() + func (m *UpdateGCSafePointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateGCSafePointRequest) XXX_Merge(src proto.Message) + func (m *UpdateGCSafePointRequest) XXX_Size() int + func (m *UpdateGCSafePointRequest) XXX_Unmarshal(b []byte) error + type UpdateGCSafePointResponse struct + Header *ResponseHeader + NewSafePoint uint64 + Succeeded bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateGCSafePointResponse) Descriptor() ([]byte, []int) + func (*UpdateGCSafePointResponse) ProtoMessage() + func (m *UpdateGCSafePointResponse) GetHeader() *ResponseHeader + func (m *UpdateGCSafePointResponse) GetNewSafePoint() uint64 + func (m *UpdateGCSafePointResponse) GetSucceeded() bool + func (m *UpdateGCSafePointResponse) Marshal() (dAtA []byte, err error) + func (m *UpdateGCSafePointResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateGCSafePointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateGCSafePointResponse) Reset() + func (m *UpdateGCSafePointResponse) Size() (n int) + func (m *UpdateGCSafePointResponse) String() string + func (m *UpdateGCSafePointResponse) Unmarshal(dAtA []byte) error + func (m *UpdateGCSafePointResponse) XXX_DiscardUnknown() + func (m *UpdateGCSafePointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateGCSafePointResponse) XXX_Merge(src proto.Message) + func (m *UpdateGCSafePointResponse) XXX_Size() int + func (m *UpdateGCSafePointResponse) XXX_Unmarshal(b []byte) error + type UpdateServiceSafePointRequest struct + Header *RequestHeader + SafePoint uint64 + ServiceId []byte + SpaceId []byte + TTL int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateServiceSafePointRequest) Descriptor() ([]byte, []int) + func (*UpdateServiceSafePointRequest) ProtoMessage() + func (m *UpdateServiceSafePointRequest) GetHeader() *RequestHeader + func (m *UpdateServiceSafePointRequest) GetSafePoint() uint64 + func (m *UpdateServiceSafePointRequest) GetServiceId() []byte + func (m *UpdateServiceSafePointRequest) GetSpaceId() []byte + func (m *UpdateServiceSafePointRequest) GetTTL() int64 + func (m *UpdateServiceSafePointRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateServiceSafePointRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateServiceSafePointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateServiceSafePointRequest) Reset() + func (m *UpdateServiceSafePointRequest) Size() (n int) + func (m *UpdateServiceSafePointRequest) String() string + func (m *UpdateServiceSafePointRequest) Unmarshal(dAtA []byte) error + func (m *UpdateServiceSafePointRequest) XXX_DiscardUnknown() + func (m *UpdateServiceSafePointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateServiceSafePointRequest) XXX_Merge(src proto.Message) + func (m *UpdateServiceSafePointRequest) XXX_Size() int + func (m *UpdateServiceSafePointRequest) XXX_Unmarshal(b []byte) error + type UpdateServiceSafePointResponse struct + GcSafePoint uint64 + Header *ResponseHeader + NewSafePoint uint64 + OldSafePoint uint64 + Succeeded bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateServiceSafePointResponse) Descriptor() ([]byte, []int) + func (*UpdateServiceSafePointResponse) ProtoMessage() + func (m *UpdateServiceSafePointResponse) GetGcSafePoint() uint64 + func (m *UpdateServiceSafePointResponse) GetHeader() *ResponseHeader + func (m *UpdateServiceSafePointResponse) GetNewSafePoint() uint64 + func (m *UpdateServiceSafePointResponse) GetOldSafePoint() uint64 + func (m *UpdateServiceSafePointResponse) GetSucceeded() bool + func (m *UpdateServiceSafePointResponse) Marshal() (dAtA []byte, err error) + func (m *UpdateServiceSafePointResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateServiceSafePointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateServiceSafePointResponse) Reset() + func (m *UpdateServiceSafePointResponse) Size() (n int) + func (m *UpdateServiceSafePointResponse) String() string + func (m *UpdateServiceSafePointResponse) Unmarshal(dAtA []byte) error + func (m *UpdateServiceSafePointResponse) XXX_DiscardUnknown() + func (m *UpdateServiceSafePointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateServiceSafePointResponse) XXX_Merge(src proto.Message) + func (m *UpdateServiceSafePointResponse) XXX_Size() int + func (m *UpdateServiceSafePointResponse) XXX_Unmarshal(b []byte) error