logbackup

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

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

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 GetLastFlushTSOfRegionRequest 

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

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

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

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
}

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

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

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

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

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