gcpb

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: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGcpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGcpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGcpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ErrorType_name = map[int32]string{
	0: "OK",
	1: "UNKNOWN",
	2: "NOT_BOOTSTRAPPED",
	3: "REVISION_MISMATCH",
	4: "SAFEPOINT_ROLLBACK",
}
View Source 
var ErrorType_value = map[string]int32{
	"OK":                 0,
	"UNKNOWN":            1,
	"NOT_BOOTSTRAPPED":   2,
	"REVISION_MISMATCH":  3,
	"SAFEPOINT_ROLLBACK": 4,
}

Functions

func RegisterGCServer 

func RegisterGCServer(s *grpc.Server, srv GCServer)

Types

type Error 

type Error struct {
	Type                 ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=gcpb.ErrorType" json:"type,omitempty"`
	Message              string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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
	// revision supplied does not match the current etcd revision
	ErrorType_REVISION_MISMATCH ErrorType = 3
	// if the proposed safe point is earlier than old safe point or gc safe point
	ErrorType_SAFEPOINT_ROLLBACK ErrorType = 4
)

func (ErrorType) EnumDescriptor 

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

func (ErrorType) String 

func (x ErrorType) String() string

type GCClient 

type GCClient interface {
	ListKeySpaces(ctx context.Context, in *ListKeySpacesRequest, opts ...grpc.CallOption) (*ListKeySpacesResponse, error)
	GetMinServiceSafePoint(ctx context.Context, in *GetMinServiceSafePointRequest, opts ...grpc.CallOption) (*GetMinServiceSafePointResponse, error)
	UpdateGCSafePoint(ctx context.Context, in *UpdateGCSafePointRequest, opts ...grpc.CallOption) (*UpdateGCSafePointResponse, error)
	UpdateServiceSafePoint(ctx context.Context, in *UpdateServiceSafePointRequest, opts ...grpc.CallOption) (*UpdateServiceSafePointResponse, error)
}

GCClient is the client API for GC service.

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

func NewGCClient 

func NewGCClient(cc *grpc.ClientConn) GCClient

type GCServer 

type GCServer interface {
	ListKeySpaces(context.Context, *ListKeySpacesRequest) (*ListKeySpacesResponse, error)
	GetMinServiceSafePoint(context.Context, *GetMinServiceSafePointRequest) (*GetMinServiceSafePointResponse, error)
	UpdateGCSafePoint(context.Context, *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error)
	UpdateServiceSafePoint(context.Context, *UpdateServiceSafePointRequest) (*UpdateServiceSafePointResponse, error)
}

GCServer is the server API for GC service.

type GetMinServiceSafePointRequest 

type GetMinServiceSafePointRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SpaceId              []byte         `protobuf:"bytes,2,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetMinServiceSafePointRequest) Descriptor 

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

func (*GetMinServiceSafePointRequest) GetHeader 

func (m *GetMinServiceSafePointRequest) GetHeader() *RequestHeader

func (*GetMinServiceSafePointRequest) GetSpaceId 

func (m *GetMinServiceSafePointRequest) GetSpaceId() []byte

func (*GetMinServiceSafePointRequest) Marshal 

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

func (*GetMinServiceSafePointRequest) MarshalTo 

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

func (*GetMinServiceSafePointRequest) MarshalToSizedBuffer 

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

func (*GetMinServiceSafePointRequest) ProtoMessage 

func (*GetMinServiceSafePointRequest) ProtoMessage()

func (*GetMinServiceSafePointRequest) Reset 

func (m *GetMinServiceSafePointRequest) Reset()

func (*GetMinServiceSafePointRequest) Size 

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

func (*GetMinServiceSafePointRequest) String 

func (m *GetMinServiceSafePointRequest) String() string

func (*GetMinServiceSafePointRequest) Unmarshal 

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

func (*GetMinServiceSafePointRequest) XXX_DiscardUnknown 

func (m *GetMinServiceSafePointRequest) XXX_DiscardUnknown()

func (*GetMinServiceSafePointRequest) XXX_Marshal 

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

func (*GetMinServiceSafePointRequest) XXX_Merge 

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

func (*GetMinServiceSafePointRequest) XXX_Size 

func (m *GetMinServiceSafePointRequest) XXX_Size() int

func (*GetMinServiceSafePointRequest) XXX_Unmarshal 

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

type GetMinServiceSafePointResponse 

type GetMinServiceSafePointResponse struct {
	Header    *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SafePoint uint64          `protobuf:"varint,2,opt,name=safe_point,json=safePoint,proto3" json:"safe_point,omitempty"`
	// revision here is to safeguard the validity of the obtained min,
	// preventing cases where new services register their safe points after min is obtained by gc worker
	Revision             int64    `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMinServiceSafePointResponse) Descriptor 

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

func (*GetMinServiceSafePointResponse) GetHeader 

func (m *GetMinServiceSafePointResponse) GetHeader() *ResponseHeader

func (*GetMinServiceSafePointResponse) GetRevision 

func (m *GetMinServiceSafePointResponse) GetRevision() int64

func (*GetMinServiceSafePointResponse) GetSafePoint 

func (m *GetMinServiceSafePointResponse) GetSafePoint() uint64

func (*GetMinServiceSafePointResponse) Marshal 

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

func (*GetMinServiceSafePointResponse) MarshalTo 

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

func (*GetMinServiceSafePointResponse) MarshalToSizedBuffer 

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

func (*GetMinServiceSafePointResponse) ProtoMessage 

func (*GetMinServiceSafePointResponse) ProtoMessage()

func (*GetMinServiceSafePointResponse) Reset 

func (m *GetMinServiceSafePointResponse) Reset()

func (*GetMinServiceSafePointResponse) Size 

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

func (*GetMinServiceSafePointResponse) String 

func (m *GetMinServiceSafePointResponse) String() string

func (*GetMinServiceSafePointResponse) Unmarshal 

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

func (*GetMinServiceSafePointResponse) XXX_DiscardUnknown 

func (m *GetMinServiceSafePointResponse) XXX_DiscardUnknown()

func (*GetMinServiceSafePointResponse) XXX_Marshal 

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

func (*GetMinServiceSafePointResponse) XXX_Merge 

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

func (*GetMinServiceSafePointResponse) XXX_Size 

func (m *GetMinServiceSafePointResponse) XXX_Size() int

func (*GetMinServiceSafePointResponse) XXX_Unmarshal 

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

type KeySpace 

type KeySpace struct {
	SpaceId              []byte   `protobuf:"bytes,1,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
	GcSafePoint          uint64   `protobuf:"varint,2,opt,name=gc_safe_point,json=gcSafePoint,proto3" json:"gc_safe_point,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeySpace) Descriptor 

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

func (*KeySpace) GetGcSafePoint 

func (m *KeySpace) GetGcSafePoint() uint64

func (*KeySpace) GetSpaceId 

func (m *KeySpace) GetSpaceId() []byte

func (*KeySpace) Marshal 

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

func (*KeySpace) MarshalTo 

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

func (*KeySpace) MarshalToSizedBuffer 

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

func (*KeySpace) ProtoMessage 

func (*KeySpace) ProtoMessage()

func (*KeySpace) Reset 

func (m *KeySpace) Reset()

func (*KeySpace) Size 

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

func (*KeySpace) String 

func (m *KeySpace) String() string

func (*KeySpace) Unmarshal 

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

func (*KeySpace) XXX_DiscardUnknown 

func (m *KeySpace) XXX_DiscardUnknown()

func (*KeySpace) XXX_Marshal 

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

func (*KeySpace) XXX_Merge 

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

func (*KeySpace) XXX_Size 

func (m *KeySpace) XXX_Size() int

func (*KeySpace) XXX_Unmarshal 

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

type ListKeySpacesRequest 

type ListKeySpacesRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// set with_gc_safe_point to true to also receive gc safe point for each key space
	WithGcSafePoint      bool     `protobuf:"varint,2,opt,name=with_gc_safe_point,json=withGcSafePoint,proto3" json:"with_gc_safe_point,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListKeySpacesRequest) Descriptor 

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

func (*ListKeySpacesRequest) GetHeader 

func (m *ListKeySpacesRequest) GetHeader() *RequestHeader

func (*ListKeySpacesRequest) GetWithGcSafePoint 

func (m *ListKeySpacesRequest) GetWithGcSafePoint() bool

func (*ListKeySpacesRequest) Marshal 

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

func (*ListKeySpacesRequest) MarshalTo 

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

func (*ListKeySpacesRequest) MarshalToSizedBuffer 

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

func (*ListKeySpacesRequest) ProtoMessage 

func (*ListKeySpacesRequest) ProtoMessage()

func (*ListKeySpacesRequest) Reset 

func (m *ListKeySpacesRequest) Reset()

func (*ListKeySpacesRequest) Size 

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

func (*ListKeySpacesRequest) String 

func (m *ListKeySpacesRequest) String() string

func (*ListKeySpacesRequest) Unmarshal 

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

func (*ListKeySpacesRequest) XXX_DiscardUnknown 

func (m *ListKeySpacesRequest) XXX_DiscardUnknown()

func (*ListKeySpacesRequest) XXX_Marshal 

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

func (*ListKeySpacesRequest) XXX_Merge 

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

func (*ListKeySpacesRequest) XXX_Size 

func (m *ListKeySpacesRequest) XXX_Size() int

func (*ListKeySpacesRequest) XXX_Unmarshal 

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

type ListKeySpacesResponse 

type ListKeySpacesResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	KeySpaces            []*KeySpace     `protobuf:"bytes,2,rep,name=key_spaces,json=keySpaces,proto3" json:"key_spaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListKeySpacesResponse) Descriptor 

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

func (*ListKeySpacesResponse) GetHeader 

func (m *ListKeySpacesResponse) GetHeader() *ResponseHeader

func (*ListKeySpacesResponse) GetKeySpaces 

func (m *ListKeySpacesResponse) GetKeySpaces() []*KeySpace

func (*ListKeySpacesResponse) Marshal 

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

func (*ListKeySpacesResponse) MarshalTo 

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

func (*ListKeySpacesResponse) MarshalToSizedBuffer 

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

func (*ListKeySpacesResponse) ProtoMessage 

func (*ListKeySpacesResponse) ProtoMessage()

func (*ListKeySpacesResponse) Reset 

func (m *ListKeySpacesResponse) Reset()

func (*ListKeySpacesResponse) Size 

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

func (*ListKeySpacesResponse) String 

func (m *ListKeySpacesResponse) String() string

func (*ListKeySpacesResponse) Unmarshal 

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

func (*ListKeySpacesResponse) XXX_DiscardUnknown 

func (m *ListKeySpacesResponse) XXX_DiscardUnknown()

func (*ListKeySpacesResponse) XXX_Marshal 

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

func (*ListKeySpacesResponse) XXX_Merge 

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

func (*ListKeySpacesResponse) XXX_Size 

func (m *ListKeySpacesResponse) XXX_Size() int

func (*ListKeySpacesResponse) XXX_Unmarshal 

func (m *ListKeySpacesResponse) 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, also member ID or etcd ID.
	SenderId             uint64   `protobuf:"varint,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterId 

func (m *RequestHeader) GetClusterId() uint64

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

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

type UnimplementedGCServer struct {
}

UnimplementedGCServer can be embedded to have forward compatible implementations.

func (*UnimplementedGCServer) GetMinServiceSafePoint 

func (*UnimplementedGCServer) GetMinServiceSafePoint(ctx context.Context, req *GetMinServiceSafePointRequest) (*GetMinServiceSafePointResponse, error)

func (*UnimplementedGCServer) ListKeySpaces 

func (*UnimplementedGCServer) ListKeySpaces(ctx context.Context, req *ListKeySpacesRequest) (*ListKeySpacesResponse, error)

func (*UnimplementedGCServer) UpdateGCSafePoint 

func (*UnimplementedGCServer) UpdateGCSafePoint(ctx context.Context, req *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error)

func (*UnimplementedGCServer) UpdateServiceSafePoint 

func (*UnimplementedGCServer) UpdateServiceSafePoint(ctx context.Context, req *UpdateServiceSafePointRequest) (*UpdateServiceSafePointResponse, error)

type UpdateGCSafePointRequest 

type UpdateGCSafePointRequest struct {
	Header    *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SpaceId   []byte         `protobuf:"bytes,2,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
	SafePoint uint64         `protobuf:"varint,3,opt,name=safe_point,json=safePoint,proto3" json:"safe_point,omitempty"`
	// here client need to provide the revision obtained from GetMinServiceSafePoint,
	// so server can check if it's still valid
	Revision             int64    `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateGCSafePointRequest) Descriptor 

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

func (*UpdateGCSafePointRequest) GetHeader 

func (m *UpdateGCSafePointRequest) GetHeader() *RequestHeader

func (*UpdateGCSafePointRequest) GetRevision 

func (m *UpdateGCSafePointRequest) GetRevision() int64

func (*UpdateGCSafePointRequest) GetSafePoint 

func (m *UpdateGCSafePointRequest) GetSafePoint() uint64

func (*UpdateGCSafePointRequest) GetSpaceId 

func (m *UpdateGCSafePointRequest) GetSpaceId() []byte

func (*UpdateGCSafePointRequest) Marshal 

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

func (*UpdateGCSafePointRequest) MarshalTo 

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

func (*UpdateGCSafePointRequest) MarshalToSizedBuffer 

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

func (*UpdateGCSafePointRequest) ProtoMessage 

func (*UpdateGCSafePointRequest) ProtoMessage()

func (*UpdateGCSafePointRequest) Reset 

func (m *UpdateGCSafePointRequest) Reset()

func (*UpdateGCSafePointRequest) Size 

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

func (*UpdateGCSafePointRequest) String 

func (m *UpdateGCSafePointRequest) String() string

func (*UpdateGCSafePointRequest) Unmarshal 

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

func (*UpdateGCSafePointRequest) XXX_DiscardUnknown 

func (m *UpdateGCSafePointRequest) XXX_DiscardUnknown()

func (*UpdateGCSafePointRequest) XXX_Marshal 

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

func (*UpdateGCSafePointRequest) XXX_Merge 

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

func (*UpdateGCSafePointRequest) XXX_Size 

func (m *UpdateGCSafePointRequest) XXX_Size() int

func (*UpdateGCSafePointRequest) XXX_Unmarshal 

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

type UpdateGCSafePointResponse 

type UpdateGCSafePointResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// update will be successful if revision is valid and new safepoint > old safe point
	// if failed, previously obtained min might be incorrect, should retry from GetMinServiceSafePoint
	Succeeded            bool     `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	NewSafePoint         uint64   `protobuf:"varint,3,opt,name=new_safe_point,json=newSafePoint,proto3" json:"new_safe_point,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateGCSafePointResponse) Descriptor 

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

func (*UpdateGCSafePointResponse) GetHeader 

func (m *UpdateGCSafePointResponse) GetHeader() *ResponseHeader

func (*UpdateGCSafePointResponse) GetNewSafePoint 

func (m *UpdateGCSafePointResponse) GetNewSafePoint() uint64

func (*UpdateGCSafePointResponse) GetSucceeded 

func (m *UpdateGCSafePointResponse) GetSucceeded() bool

func (*UpdateGCSafePointResponse) Marshal 

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

func (*UpdateGCSafePointResponse) MarshalTo 

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

func (*UpdateGCSafePointResponse) MarshalToSizedBuffer 

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

func (*UpdateGCSafePointResponse) ProtoMessage 

func (*UpdateGCSafePointResponse) ProtoMessage()

func (*UpdateGCSafePointResponse) Reset 

func (m *UpdateGCSafePointResponse) Reset()

func (*UpdateGCSafePointResponse) Size 

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

func (*UpdateGCSafePointResponse) String 

func (m *UpdateGCSafePointResponse) String() string

func (*UpdateGCSafePointResponse) Unmarshal 

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

func (*UpdateGCSafePointResponse) XXX_DiscardUnknown 

func (m *UpdateGCSafePointResponse) XXX_DiscardUnknown()

func (*UpdateGCSafePointResponse) XXX_Marshal 

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

func (*UpdateGCSafePointResponse) XXX_Merge 

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

func (*UpdateGCSafePointResponse) XXX_Size 

func (m *UpdateGCSafePointResponse) XXX_Size() int

func (*UpdateGCSafePointResponse) XXX_Unmarshal 

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

type UpdateServiceSafePointRequest 

type UpdateServiceSafePointRequest struct {
	Header    *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SpaceId   []byte         `protobuf:"bytes,2,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
	ServiceId []byte         `protobuf:"bytes,3,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// safe point will be set to expire on (PD Server time + TTL)
	// pass in a ttl < 0 to remove target safe point
	// pass in MAX_INT64 to set a safe point that never expire
	TTL                  int64    `protobuf:"varint,4,opt,name=TTL,proto3" json:"TTL,omitempty"`
	SafePoint            uint64   `protobuf:"varint,5,opt,name=safe_point,json=safePoint,proto3" json:"safe_point,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateServiceSafePointRequest) Descriptor 

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

func (*UpdateServiceSafePointRequest) GetHeader 

func (m *UpdateServiceSafePointRequest) GetHeader() *RequestHeader

func (*UpdateServiceSafePointRequest) GetSafePoint 

func (m *UpdateServiceSafePointRequest) GetSafePoint() uint64

func (*UpdateServiceSafePointRequest) GetServiceId 

func (m *UpdateServiceSafePointRequest) GetServiceId() []byte

func (*UpdateServiceSafePointRequest) GetSpaceId 

func (m *UpdateServiceSafePointRequest) GetSpaceId() []byte

func (*UpdateServiceSafePointRequest) GetTTL 

func (m *UpdateServiceSafePointRequest) GetTTL() int64

func (*UpdateServiceSafePointRequest) Marshal 

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

func (*UpdateServiceSafePointRequest) MarshalTo 

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

func (*UpdateServiceSafePointRequest) MarshalToSizedBuffer 

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

func (*UpdateServiceSafePointRequest) ProtoMessage 

func (*UpdateServiceSafePointRequest) ProtoMessage()

func (*UpdateServiceSafePointRequest) Reset 

func (m *UpdateServiceSafePointRequest) Reset()

func (*UpdateServiceSafePointRequest) Size 

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

func (*UpdateServiceSafePointRequest) String 

func (m *UpdateServiceSafePointRequest) String() string

func (*UpdateServiceSafePointRequest) Unmarshal 

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

func (*UpdateServiceSafePointRequest) XXX_DiscardUnknown 

func (m *UpdateServiceSafePointRequest) XXX_DiscardUnknown()

func (*UpdateServiceSafePointRequest) XXX_Marshal 

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

func (*UpdateServiceSafePointRequest) XXX_Merge 

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

func (*UpdateServiceSafePointRequest) XXX_Size 

func (m *UpdateServiceSafePointRequest) XXX_Size() int

func (*UpdateServiceSafePointRequest) XXX_Unmarshal 

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

type UpdateServiceSafePointResponse 

type UpdateServiceSafePointResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// update will be successful if ttl < 0 (a removal request)
	// or if new safe point >= old safe point and new safe point >= gc safe point
	Succeeded            bool     `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	GcSafePoint          uint64   `protobuf:"varint,3,opt,name=gc_safe_point,json=gcSafePoint,proto3" json:"gc_safe_point,omitempty"`
	OldSafePoint         uint64   `protobuf:"varint,4,opt,name=old_safe_point,json=oldSafePoint,proto3" json:"old_safe_point,omitempty"`
	NewSafePoint         uint64   `protobuf:"varint,5,opt,name=new_safe_point,json=newSafePoint,proto3" json:"new_safe_point,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateServiceSafePointResponse) Descriptor 

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

func (*UpdateServiceSafePointResponse) GetGcSafePoint 

func (m *UpdateServiceSafePointResponse) GetGcSafePoint() uint64

func (*UpdateServiceSafePointResponse) GetHeader 

func (m *UpdateServiceSafePointResponse) GetHeader() *ResponseHeader

func (*UpdateServiceSafePointResponse) GetNewSafePoint 

func (m *UpdateServiceSafePointResponse) GetNewSafePoint() uint64

func (*UpdateServiceSafePointResponse) GetOldSafePoint 

func (m *UpdateServiceSafePointResponse) GetOldSafePoint() uint64

func (*UpdateServiceSafePointResponse) GetSucceeded 

func (m *UpdateServiceSafePointResponse) GetSucceeded() bool

func (*UpdateServiceSafePointResponse) Marshal 

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

func (*UpdateServiceSafePointResponse) MarshalTo 

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

func (*UpdateServiceSafePointResponse) MarshalToSizedBuffer 

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

func (*UpdateServiceSafePointResponse) ProtoMessage 

func (*UpdateServiceSafePointResponse) ProtoMessage()

func (*UpdateServiceSafePointResponse) Reset 

func (m *UpdateServiceSafePointResponse) Reset()

func (*UpdateServiceSafePointResponse) Size 

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

func (*UpdateServiceSafePointResponse) String 

func (m *UpdateServiceSafePointResponse) String() string

func (*UpdateServiceSafePointResponse) Unmarshal 

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

func (*UpdateServiceSafePointResponse) XXX_DiscardUnknown 

func (m *UpdateServiceSafePointResponse) XXX_DiscardUnknown()

func (*UpdateServiceSafePointResponse) XXX_Marshal 

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

func (*UpdateServiceSafePointResponse) XXX_Merge 

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

func (*UpdateServiceSafePointResponse) XXX_Size 

func (m *UpdateServiceSafePointResponse) XXX_Size() int

func (*UpdateServiceSafePointResponse) XXX_Unmarshal 

func (m *UpdateServiceSafePointResponse) XXX_Unmarshal(b []byte) 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.