logbackup

package
v0.0.0-...-ad14807 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2025 License: Apache-2.0 Imports: 11 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLogbackuppb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogbackuppb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogbackuppb = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterLogBackupServer 

func RegisterLogBackupServer(s *grpc.Server, srv LogBackupServer)

Types

type FlushEvent 

type FlushEvent struct {
	StartKey   []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey     []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Checkpoint uint64 `protobuf:"varint,3,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
}

func (*FlushEvent) Descriptor 

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

func (*FlushEvent) GetCheckpoint 

func (m *FlushEvent) GetCheckpoint() uint64

func (*FlushEvent) GetEndKey 

func (m *FlushEvent) GetEndKey() []byte

func (*FlushEvent) GetStartKey 

func (m *FlushEvent) GetStartKey() []byte

func (*FlushEvent) Marshal 

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

func (*FlushEvent) MarshalTo 

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

func (*FlushEvent) MarshalToSizedBuffer 

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

func (*FlushEvent) ProtoMessage 

func (*FlushEvent) ProtoMessage()

func (*FlushEvent) Reset 

func (m *FlushEvent) Reset()

func (*FlushEvent) Size 

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

func (*FlushEvent) String 

func (m *FlushEvent) String() string

func (*FlushEvent) Unmarshal 

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

func (*FlushEvent) XXX_DiscardUnknown 

func (m *FlushEvent) XXX_DiscardUnknown()

func (*FlushEvent) XXX_Marshal 

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

func (*FlushEvent) XXX_Merge 

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

func (*FlushEvent) XXX_Size 

func (m *FlushEvent) XXX_Size() int

func (*FlushEvent) XXX_Unmarshal 

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

type FlushNowRequest 

type FlushNowRequest struct {
}

func (*FlushNowRequest) Descriptor 

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

func (*FlushNowRequest) Marshal 

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

func (*FlushNowRequest) MarshalTo 

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

func (*FlushNowRequest) MarshalToSizedBuffer 

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

func (*FlushNowRequest) ProtoMessage 

func (*FlushNowRequest) ProtoMessage()

func (*FlushNowRequest) Reset 

func (m *FlushNowRequest) Reset()

func (*FlushNowRequest) Size 

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

func (*FlushNowRequest) String 

func (m *FlushNowRequest) String() string

func (*FlushNowRequest) Unmarshal 

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

func (*FlushNowRequest) XXX_DiscardUnknown 

func (m *FlushNowRequest) XXX_DiscardUnknown()

func (*FlushNowRequest) XXX_Marshal 

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

func (*FlushNowRequest) XXX_Merge 

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

func (*FlushNowRequest) XXX_Size 

func (m *FlushNowRequest) XXX_Size() int

func (*FlushNowRequest) XXX_Unmarshal 

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

type FlushNowResponse 

type FlushNowResponse struct {
	Results []*FlushResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

func (*FlushNowResponse) Descriptor 

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

func (*FlushNowResponse) GetResults 

func (m *FlushNowResponse) GetResults() []*FlushResult

func (*FlushNowResponse) Marshal 

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

func (*FlushNowResponse) MarshalTo 

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

func (*FlushNowResponse) MarshalToSizedBuffer 

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

func (*FlushNowResponse) ProtoMessage 

func (*FlushNowResponse) ProtoMessage()

func (*FlushNowResponse) Reset 

func (m *FlushNowResponse) Reset()

func (*FlushNowResponse) Size 

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

func (*FlushNowResponse) String 

func (m *FlushNowResponse) String() string

func (*FlushNowResponse) Unmarshal 

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

func (*FlushNowResponse) XXX_DiscardUnknown 

func (m *FlushNowResponse) XXX_DiscardUnknown()

func (*FlushNowResponse) XXX_Marshal 

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

func (*FlushNowResponse) XXX_Merge 

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

func (*FlushNowResponse) XXX_Size 

func (m *FlushNowResponse) XXX_Size() int

func (*FlushNowResponse) XXX_Unmarshal 

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

type FlushResult 

type FlushResult struct {
	TaskName     string `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Success      bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

func (*FlushResult) Descriptor 

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

func (*FlushResult) GetErrorMessage 

func (m *FlushResult) GetErrorMessage() string

func (*FlushResult) GetSuccess 

func (m *FlushResult) GetSuccess() bool

func (*FlushResult) GetTaskName 

func (m *FlushResult) GetTaskName() string

func (*FlushResult) Marshal 

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

func (*FlushResult) MarshalTo 

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

func (*FlushResult) MarshalToSizedBuffer 

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

func (*FlushResult) ProtoMessage 

func (*FlushResult) ProtoMessage()

func (*FlushResult) Reset 

func (m *FlushResult) Reset()

func (*FlushResult) Size 

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

func (*FlushResult) String 

func (m *FlushResult) String() string

func (*FlushResult) Unmarshal 

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

func (*FlushResult) XXX_DiscardUnknown 

func (m *FlushResult) XXX_DiscardUnknown()

func (*FlushResult) XXX_Marshal 

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

func (*FlushResult) XXX_Merge 

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

func (*FlushResult) XXX_Size 

func (m *FlushResult) XXX_Size() int

func (*FlushResult) XXX_Unmarshal 

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

type GetLastFlushTSOfRegionRequest 

type GetLastFlushTSOfRegionRequest struct {
	Regions []*RegionIdentity `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
}

func (*GetLastFlushTSOfRegionRequest) Descriptor 

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

func (*GetLastFlushTSOfRegionRequest) GetRegions 

func (m *GetLastFlushTSOfRegionRequest) GetRegions() []*RegionIdentity

func (*GetLastFlushTSOfRegionRequest) Marshal 

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

func (*GetLastFlushTSOfRegionRequest) MarshalTo 

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

func (*GetLastFlushTSOfRegionRequest) MarshalToSizedBuffer 

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

func (*GetLastFlushTSOfRegionRequest) ProtoMessage 

func (*GetLastFlushTSOfRegionRequest) ProtoMessage()

func (*GetLastFlushTSOfRegionRequest) Reset 

func (m *GetLastFlushTSOfRegionRequest) Reset()

func (*GetLastFlushTSOfRegionRequest) Size 

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

func (*GetLastFlushTSOfRegionRequest) String 

func (m *GetLastFlushTSOfRegionRequest) String() string

func (*GetLastFlushTSOfRegionRequest) Unmarshal 

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

func (*GetLastFlushTSOfRegionRequest) XXX_DiscardUnknown 

func (m *GetLastFlushTSOfRegionRequest) XXX_DiscardUnknown()

func (*GetLastFlushTSOfRegionRequest) XXX_Marshal 

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

func (*GetLastFlushTSOfRegionRequest) XXX_Merge 

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

func (*GetLastFlushTSOfRegionRequest) XXX_Size 

func (m *GetLastFlushTSOfRegionRequest) XXX_Size() int

func (*GetLastFlushTSOfRegionRequest) XXX_Unmarshal 

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

type GetLastFlushTSOfRegionResponse 

type GetLastFlushTSOfRegionResponse struct {
	Checkpoints []*RegionCheckpoint `protobuf:"bytes,1,rep,name=checkpoints,proto3" json:"checkpoints,omitempty"`
}

func (*GetLastFlushTSOfRegionResponse) Descriptor 

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

func (*GetLastFlushTSOfRegionResponse) GetCheckpoints 

func (m *GetLastFlushTSOfRegionResponse) GetCheckpoints() []*RegionCheckpoint

func (*GetLastFlushTSOfRegionResponse) Marshal 

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

func (*GetLastFlushTSOfRegionResponse) MarshalTo 

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

func (*GetLastFlushTSOfRegionResponse) MarshalToSizedBuffer 

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

func (*GetLastFlushTSOfRegionResponse) ProtoMessage 

func (*GetLastFlushTSOfRegionResponse) ProtoMessage()

func (*GetLastFlushTSOfRegionResponse) Reset 

func (m *GetLastFlushTSOfRegionResponse) Reset()

func (*GetLastFlushTSOfRegionResponse) Size 

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

func (*GetLastFlushTSOfRegionResponse) String 

func (m *GetLastFlushTSOfRegionResponse) String() string

func (*GetLastFlushTSOfRegionResponse) Unmarshal 

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

func (*GetLastFlushTSOfRegionResponse) XXX_DiscardUnknown 

func (m *GetLastFlushTSOfRegionResponse) XXX_DiscardUnknown()

func (*GetLastFlushTSOfRegionResponse) XXX_Marshal 

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

func (*GetLastFlushTSOfRegionResponse) XXX_Merge 

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

func (*GetLastFlushTSOfRegionResponse) XXX_Size 

func (m *GetLastFlushTSOfRegionResponse) XXX_Size() int

func (*GetLastFlushTSOfRegionResponse) XXX_Unmarshal 

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

type LogBackupClient 

type LogBackupClient interface {
	GetLastFlushTSOfRegion(ctx context.Context, in *GetLastFlushTSOfRegionRequest, opts ...grpc.CallOption) (*GetLastFlushTSOfRegionResponse, error)
	SubscribeFlushEvent(ctx context.Context, in *SubscribeFlushEventRequest, opts ...grpc.CallOption) (LogBackup_SubscribeFlushEventClient, error)
	FlushNow(ctx context.Context, in *FlushNowRequest, opts ...grpc.CallOption) (*FlushNowResponse, error)
}

LogBackupClient is the client API for LogBackup service.

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

func NewLogBackupClient 

func NewLogBackupClient(cc *grpc.ClientConn) LogBackupClient

type LogBackupServer 

type LogBackupServer interface {
	GetLastFlushTSOfRegion(context.Context, *GetLastFlushTSOfRegionRequest) (*GetLastFlushTSOfRegionResponse, error)
	SubscribeFlushEvent(*SubscribeFlushEventRequest, LogBackup_SubscribeFlushEventServer) error
	FlushNow(context.Context, *FlushNowRequest) (*FlushNowResponse, error)
}

LogBackupServer is the server API for LogBackup service.

type LogBackup_SubscribeFlushEventClient 

type LogBackup_SubscribeFlushEventClient interface {
	Recv() (*SubscribeFlushEventResponse, error)
	grpc.ClientStream
}

type LogBackup_SubscribeFlushEventServer 

type LogBackup_SubscribeFlushEventServer interface {
	Send(*SubscribeFlushEventResponse) error
	grpc.ServerStream
}

type RegionCheckpoint 

type RegionCheckpoint struct {
	Err        *errorpb.Error  `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Region     *RegionIdentity `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Checkpoint uint64          `protobuf:"varint,3,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
}

The last flush ts with region information.

func (*RegionCheckpoint) Descriptor 

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

func (*RegionCheckpoint) GetCheckpoint 

func (m *RegionCheckpoint) GetCheckpoint() uint64

func (*RegionCheckpoint) GetErr 

func (m *RegionCheckpoint) GetErr() *errorpb.Error

func (*RegionCheckpoint) GetRegion 

func (m *RegionCheckpoint) GetRegion() *RegionIdentity

func (*RegionCheckpoint) Marshal 

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

func (*RegionCheckpoint) MarshalTo 

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

func (*RegionCheckpoint) MarshalToSizedBuffer 

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

func (*RegionCheckpoint) ProtoMessage 

func (*RegionCheckpoint) ProtoMessage()

func (*RegionCheckpoint) Reset 

func (m *RegionCheckpoint) Reset()

func (*RegionCheckpoint) Size 

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

func (*RegionCheckpoint) String 

func (m *RegionCheckpoint) String() string

func (*RegionCheckpoint) Unmarshal 

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

func (*RegionCheckpoint) XXX_DiscardUnknown 

func (m *RegionCheckpoint) XXX_DiscardUnknown()

func (*RegionCheckpoint) XXX_Marshal 

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

func (*RegionCheckpoint) XXX_Merge 

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

func (*RegionCheckpoint) XXX_Size 

func (m *RegionCheckpoint) XXX_Size() int

func (*RegionCheckpoint) XXX_Unmarshal 

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

type RegionIdentity 

type RegionIdentity struct {
	Id           uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	EpochVersion uint64 `protobuf:"varint,2,opt,name=epoch_version,json=epochVersion,proto3" json:"epoch_version,omitempty"`
}

The minimal information for identify a region.

func (*RegionIdentity) Descriptor 

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

func (*RegionIdentity) GetEpochVersion 

func (m *RegionIdentity) GetEpochVersion() uint64

func (*RegionIdentity) GetId 

func (m *RegionIdentity) GetId() uint64

func (*RegionIdentity) Marshal 

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

func (*RegionIdentity) MarshalTo 

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

func (*RegionIdentity) MarshalToSizedBuffer 

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

func (*RegionIdentity) ProtoMessage 

func (*RegionIdentity) ProtoMessage()

func (*RegionIdentity) Reset 

func (m *RegionIdentity) Reset()

func (*RegionIdentity) Size 

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

func (*RegionIdentity) String 

func (m *RegionIdentity) String() string

func (*RegionIdentity) Unmarshal 

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

func (*RegionIdentity) XXX_DiscardUnknown 

func (m *RegionIdentity) XXX_DiscardUnknown()

func (*RegionIdentity) XXX_Marshal 

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

func (*RegionIdentity) XXX_Merge 

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

func (*RegionIdentity) XXX_Size 

func (m *RegionIdentity) XXX_Size() int

func (*RegionIdentity) XXX_Unmarshal 

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

type SubscribeFlushEventRequest 

type SubscribeFlushEventRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
}

func (*SubscribeFlushEventRequest) Descriptor 

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

func (*SubscribeFlushEventRequest) GetClientId 

func (m *SubscribeFlushEventRequest) GetClientId() string

func (*SubscribeFlushEventRequest) Marshal 

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

func (*SubscribeFlushEventRequest) MarshalTo 

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

func (*SubscribeFlushEventRequest) MarshalToSizedBuffer 

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

func (*SubscribeFlushEventRequest) ProtoMessage 

func (*SubscribeFlushEventRequest) ProtoMessage()

func (*SubscribeFlushEventRequest) Reset 

func (m *SubscribeFlushEventRequest) Reset()

func (*SubscribeFlushEventRequest) Size 

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

func (*SubscribeFlushEventRequest) String 

func (m *SubscribeFlushEventRequest) String() string

func (*SubscribeFlushEventRequest) Unmarshal 

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

func (*SubscribeFlushEventRequest) XXX_DiscardUnknown 

func (m *SubscribeFlushEventRequest) XXX_DiscardUnknown()

func (*SubscribeFlushEventRequest) XXX_Marshal 

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

func (*SubscribeFlushEventRequest) XXX_Merge 

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

func (*SubscribeFlushEventRequest) XXX_Size 

func (m *SubscribeFlushEventRequest) XXX_Size() int

func (*SubscribeFlushEventRequest) XXX_Unmarshal 

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

type SubscribeFlushEventResponse 

type SubscribeFlushEventResponse struct {
	Events []*FlushEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
}

func (*SubscribeFlushEventResponse) Descriptor 

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

func (*SubscribeFlushEventResponse) GetEvents 

func (m *SubscribeFlushEventResponse) GetEvents() []*FlushEvent

func (*SubscribeFlushEventResponse) Marshal 

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

func (*SubscribeFlushEventResponse) MarshalTo 

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

func (*SubscribeFlushEventResponse) MarshalToSizedBuffer 

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

func (*SubscribeFlushEventResponse) ProtoMessage 

func (*SubscribeFlushEventResponse) ProtoMessage()

func (*SubscribeFlushEventResponse) Reset 

func (m *SubscribeFlushEventResponse) Reset()

func (*SubscribeFlushEventResponse) Size 

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

func (*SubscribeFlushEventResponse) String 

func (m *SubscribeFlushEventResponse) String() string

func (*SubscribeFlushEventResponse) Unmarshal 

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

func (*SubscribeFlushEventResponse) XXX_DiscardUnknown 

func (m *SubscribeFlushEventResponse) XXX_DiscardUnknown()

func (*SubscribeFlushEventResponse) XXX_Marshal 

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

func (*SubscribeFlushEventResponse) XXX_Merge 

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

func (*SubscribeFlushEventResponse) XXX_Size 

func (m *SubscribeFlushEventResponse) XXX_Size() int

func (*SubscribeFlushEventResponse) XXX_Unmarshal 

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

type UnimplementedLogBackupServer 

type UnimplementedLogBackupServer struct {
}

UnimplementedLogBackupServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogBackupServer) FlushNow 

func (*UnimplementedLogBackupServer) FlushNow(ctx context.Context, req *FlushNowRequest) (*FlushNowResponse, error)

func (*UnimplementedLogBackupServer) GetLastFlushTSOfRegion 

func (*UnimplementedLogBackupServer) GetLastFlushTSOfRegion(ctx context.Context, req *GetLastFlushTSOfRegionRequest) (*GetLastFlushTSOfRegionResponse, error)

func (*UnimplementedLogBackupServer) SubscribeFlushEvent 

func (*UnimplementedLogBackupServer) SubscribeFlushEvent(req *SubscribeFlushEventRequest, srv LogBackup_SubscribeFlushEventServer) 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.