Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowLogbackuppb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthLogbackuppb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupLogbackuppb = fmt.Errorf("proto: unexpected end of group") + func RegisterLogBackupServer(s *grpc.Server, srv LogBackupServer) + type FlushEvent struct + Checkpoint uint64 + EndKey []byte + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FlushEvent) Descriptor() ([]byte, []int) + func (*FlushEvent) ProtoMessage() + func (m *FlushEvent) GetCheckpoint() uint64 + func (m *FlushEvent) GetEndKey() []byte + func (m *FlushEvent) GetStartKey() []byte + func (m *FlushEvent) Marshal() (dAtA []byte, err error) + func (m *FlushEvent) MarshalTo(dAtA []byte) (int, error) + func (m *FlushEvent) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FlushEvent) Reset() + func (m *FlushEvent) Size() (n int) + func (m *FlushEvent) String() string + func (m *FlushEvent) Unmarshal(dAtA []byte) error + func (m *FlushEvent) XXX_DiscardUnknown() + func (m *FlushEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FlushEvent) XXX_Merge(src proto.Message) + func (m *FlushEvent) XXX_Size() int + func (m *FlushEvent) XXX_Unmarshal(b []byte) error + type GetLastFlushTSOfRegionRequest struct + Regions []*RegionIdentity + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetLastFlushTSOfRegionRequest) Descriptor() ([]byte, []int) + func (*GetLastFlushTSOfRegionRequest) ProtoMessage() + func (m *GetLastFlushTSOfRegionRequest) GetRegions() []*RegionIdentity + func (m *GetLastFlushTSOfRegionRequest) Marshal() (dAtA []byte, err error) + func (m *GetLastFlushTSOfRegionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetLastFlushTSOfRegionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetLastFlushTSOfRegionRequest) Reset() + func (m *GetLastFlushTSOfRegionRequest) Size() (n int) + func (m *GetLastFlushTSOfRegionRequest) String() string + func (m *GetLastFlushTSOfRegionRequest) Unmarshal(dAtA []byte) error + func (m *GetLastFlushTSOfRegionRequest) XXX_DiscardUnknown() + func (m *GetLastFlushTSOfRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetLastFlushTSOfRegionRequest) XXX_Merge(src proto.Message) + func (m *GetLastFlushTSOfRegionRequest) XXX_Size() int + func (m *GetLastFlushTSOfRegionRequest) XXX_Unmarshal(b []byte) error + type GetLastFlushTSOfRegionResponse struct + Checkpoints []*RegionCheckpoint + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetLastFlushTSOfRegionResponse) Descriptor() ([]byte, []int) + func (*GetLastFlushTSOfRegionResponse) ProtoMessage() + func (m *GetLastFlushTSOfRegionResponse) GetCheckpoints() []*RegionCheckpoint + func (m *GetLastFlushTSOfRegionResponse) Marshal() (dAtA []byte, err error) + func (m *GetLastFlushTSOfRegionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetLastFlushTSOfRegionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetLastFlushTSOfRegionResponse) Reset() + func (m *GetLastFlushTSOfRegionResponse) Size() (n int) + func (m *GetLastFlushTSOfRegionResponse) String() string + func (m *GetLastFlushTSOfRegionResponse) Unmarshal(dAtA []byte) error + func (m *GetLastFlushTSOfRegionResponse) XXX_DiscardUnknown() + func (m *GetLastFlushTSOfRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetLastFlushTSOfRegionResponse) XXX_Merge(src proto.Message) + func (m *GetLastFlushTSOfRegionResponse) XXX_Size() int + func (m *GetLastFlushTSOfRegionResponse) XXX_Unmarshal(b []byte) error + type LogBackupClient interface + GetLastFlushTSOfRegion func(ctx context.Context, in *GetLastFlushTSOfRegionRequest, ...) (*GetLastFlushTSOfRegionResponse, error) + SubscribeFlushEvent func(ctx context.Context, in *SubscribeFlushEventRequest, opts ...grpc.CallOption) (LogBackup_SubscribeFlushEventClient, error) + func NewLogBackupClient(cc *grpc.ClientConn) LogBackupClient + type LogBackupServer interface + GetLastFlushTSOfRegion func(context.Context, *GetLastFlushTSOfRegionRequest) (*GetLastFlushTSOfRegionResponse, error) + SubscribeFlushEvent func(*SubscribeFlushEventRequest, LogBackup_SubscribeFlushEventServer) error + type LogBackup_SubscribeFlushEventClient interface + Recv func() (*SubscribeFlushEventResponse, error) + type LogBackup_SubscribeFlushEventServer interface + Send func(*SubscribeFlushEventResponse) error + type RegionCheckpoint struct + Checkpoint uint64 + Err *errorpb.Error + Region *RegionIdentity + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionCheckpoint) Descriptor() ([]byte, []int) + func (*RegionCheckpoint) ProtoMessage() + func (m *RegionCheckpoint) GetCheckpoint() uint64 + func (m *RegionCheckpoint) GetErr() *errorpb.Error + func (m *RegionCheckpoint) GetRegion() *RegionIdentity + func (m *RegionCheckpoint) Marshal() (dAtA []byte, err error) + func (m *RegionCheckpoint) MarshalTo(dAtA []byte) (int, error) + func (m *RegionCheckpoint) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionCheckpoint) Reset() + func (m *RegionCheckpoint) Size() (n int) + func (m *RegionCheckpoint) String() string + func (m *RegionCheckpoint) Unmarshal(dAtA []byte) error + func (m *RegionCheckpoint) XXX_DiscardUnknown() + func (m *RegionCheckpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionCheckpoint) XXX_Merge(src proto.Message) + func (m *RegionCheckpoint) XXX_Size() int + func (m *RegionCheckpoint) XXX_Unmarshal(b []byte) error + type RegionIdentity struct + EpochVersion uint64 + Id uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionIdentity) Descriptor() ([]byte, []int) + func (*RegionIdentity) ProtoMessage() + func (m *RegionIdentity) GetEpochVersion() uint64 + func (m *RegionIdentity) GetId() uint64 + func (m *RegionIdentity) Marshal() (dAtA []byte, err error) + func (m *RegionIdentity) MarshalTo(dAtA []byte) (int, error) + func (m *RegionIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionIdentity) Reset() + func (m *RegionIdentity) Size() (n int) + func (m *RegionIdentity) String() string + func (m *RegionIdentity) Unmarshal(dAtA []byte) error + func (m *RegionIdentity) XXX_DiscardUnknown() + func (m *RegionIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionIdentity) XXX_Merge(src proto.Message) + func (m *RegionIdentity) XXX_Size() int + func (m *RegionIdentity) XXX_Unmarshal(b []byte) error + type SubscribeFlushEventRequest struct + ClientId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeFlushEventRequest) Descriptor() ([]byte, []int) + func (*SubscribeFlushEventRequest) ProtoMessage() + func (m *SubscribeFlushEventRequest) GetClientId() string + func (m *SubscribeFlushEventRequest) Marshal() (dAtA []byte, err error) + func (m *SubscribeFlushEventRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SubscribeFlushEventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SubscribeFlushEventRequest) Reset() + func (m *SubscribeFlushEventRequest) Size() (n int) + func (m *SubscribeFlushEventRequest) String() string + func (m *SubscribeFlushEventRequest) Unmarshal(dAtA []byte) error + func (m *SubscribeFlushEventRequest) XXX_DiscardUnknown() + func (m *SubscribeFlushEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeFlushEventRequest) XXX_Merge(src proto.Message) + func (m *SubscribeFlushEventRequest) XXX_Size() int + func (m *SubscribeFlushEventRequest) XXX_Unmarshal(b []byte) error + type SubscribeFlushEventResponse struct + Events []*FlushEvent + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeFlushEventResponse) Descriptor() ([]byte, []int) + func (*SubscribeFlushEventResponse) ProtoMessage() + func (m *SubscribeFlushEventResponse) GetEvents() []*FlushEvent + func (m *SubscribeFlushEventResponse) Marshal() (dAtA []byte, err error) + func (m *SubscribeFlushEventResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SubscribeFlushEventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SubscribeFlushEventResponse) Reset() + func (m *SubscribeFlushEventResponse) Size() (n int) + func (m *SubscribeFlushEventResponse) String() string + func (m *SubscribeFlushEventResponse) Unmarshal(dAtA []byte) error + func (m *SubscribeFlushEventResponse) XXX_DiscardUnknown() + func (m *SubscribeFlushEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeFlushEventResponse) XXX_Merge(src proto.Message) + func (m *SubscribeFlushEventResponse) XXX_Size() int + func (m *SubscribeFlushEventResponse) XXX_Unmarshal(b []byte) error + type UnimplementedLogBackupServer struct + func (*UnimplementedLogBackupServer) GetLastFlushTSOfRegion(ctx context.Context, req *GetLastFlushTSOfRegionRequest) (*GetLastFlushTSOfRegionResponse, error) + func (*UnimplementedLogBackupServer) SubscribeFlushEvent(req *SubscribeFlushEventRequest, srv LogBackup_SubscribeFlushEventServer) error