logbackup

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

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

LogBackupServer is the server API for LogBackup service.

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

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.