checkpointspb

package
v1.1.0-beta.0...-6d74071 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthFileCheckpoints        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFileCheckpoints          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFileCheckpoints = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type CheckpointsModel 

type CheckpointsModel struct {
	// key is table_name
	Checkpoints    map[string]*TableCheckpointModel `` /* 163-byte string literal not displayed */
	TaskCheckpoint *TaskCheckpointModel             `protobuf:"bytes,2,opt,name=task_checkpoint,json=taskCheckpoint,proto3" json:"task_checkpoint,omitempty"`
}

func (*CheckpointsModel) Descriptor 

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

func (*CheckpointsModel) Marshal 

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

func (*CheckpointsModel) MarshalTo 

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

func (*CheckpointsModel) MarshalToSizedBuffer 

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

func (*CheckpointsModel) ProtoMessage 

func (*CheckpointsModel) ProtoMessage()

func (*CheckpointsModel) Reset 

func (m *CheckpointsModel) Reset()

func (*CheckpointsModel) Size 

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

func (*CheckpointsModel) String 

func (m *CheckpointsModel) String() string

func (*CheckpointsModel) Unmarshal 

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

func (*CheckpointsModel) XXX_DiscardUnknown 

func (m *CheckpointsModel) XXX_DiscardUnknown()

func (*CheckpointsModel) XXX_Marshal 

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

func (*CheckpointsModel) XXX_Merge 

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

func (*CheckpointsModel) XXX_Size 

func (m *CheckpointsModel) XXX_Size() int

func (*CheckpointsModel) XXX_Unmarshal 

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

type ChunkCheckpointModel 

type ChunkCheckpointModel struct {
	Path              string  `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Offset            int64   `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	ColumnPermutation []int32 `protobuf:"varint,12,rep,packed,name=column_permutation,json=columnPermutation,proto3" json:"column_permutation,omitempty"`
	EndOffset         int64   `protobuf:"varint,5,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	Pos               int64   `protobuf:"varint,6,opt,name=pos,proto3" json:"pos,omitempty"`
	PrevRowidMax      int64   `protobuf:"varint,7,opt,name=prev_rowid_max,json=prevRowidMax,proto3" json:"prev_rowid_max,omitempty"`
	RowidMax          int64   `protobuf:"varint,8,opt,name=rowid_max,json=rowidMax,proto3" json:"rowid_max,omitempty"`
	KvcBytes          uint64  `protobuf:"varint,9,opt,name=kvc_bytes,json=kvcBytes,proto3" json:"kvc_bytes,omitempty"`
	KvcKvs            uint64  `protobuf:"varint,10,opt,name=kvc_kvs,json=kvcKvs,proto3" json:"kvc_kvs,omitempty"`
	KvcChecksum       uint64  `protobuf:"fixed64,11,opt,name=kvc_checksum,json=kvcChecksum,proto3" json:"kvc_checksum,omitempty"`
	Timestamp         int64   `protobuf:"fixed64,13,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Type              int32   `protobuf:"varint,14,opt,name=type,proto3" json:"type,omitempty"`
	Compression       int32   `protobuf:"varint,15,opt,name=compression,proto3" json:"compression,omitempty"`
	SortKey           string  `protobuf:"bytes,16,opt,name=sort_key,json=sortKey,proto3" json:"sort_key,omitempty"`
	FileSize          int64   `protobuf:"varint,17,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
}

func (*ChunkCheckpointModel) Descriptor 

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

func (*ChunkCheckpointModel) Marshal 

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

func (*ChunkCheckpointModel) MarshalTo 

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

func (*ChunkCheckpointModel) MarshalToSizedBuffer 

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

func (*ChunkCheckpointModel) ProtoMessage 

func (*ChunkCheckpointModel) ProtoMessage()

func (*ChunkCheckpointModel) Reset 

func (m *ChunkCheckpointModel) Reset()

func (*ChunkCheckpointModel) Size 

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

func (*ChunkCheckpointModel) String 

func (m *ChunkCheckpointModel) String() string

func (*ChunkCheckpointModel) Unmarshal 

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

func (*ChunkCheckpointModel) XXX_DiscardUnknown 

func (m *ChunkCheckpointModel) XXX_DiscardUnknown()

func (*ChunkCheckpointModel) XXX_Marshal 

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

func (*ChunkCheckpointModel) XXX_Merge 

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

func (*ChunkCheckpointModel) XXX_Size 

func (m *ChunkCheckpointModel) XXX_Size() int

func (*ChunkCheckpointModel) XXX_Unmarshal 

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

type EngineCheckpointModel 

type EngineCheckpointModel struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// key is "$path:$offset"
	Chunks map[string]*ChunkCheckpointModel `` /* 153-byte string literal not displayed */
}

func (*EngineCheckpointModel) Descriptor 

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

func (*EngineCheckpointModel) Marshal 

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

func (*EngineCheckpointModel) MarshalTo 

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

func (*EngineCheckpointModel) MarshalToSizedBuffer 

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

func (*EngineCheckpointModel) ProtoMessage 

func (*EngineCheckpointModel) ProtoMessage()

func (*EngineCheckpointModel) Reset 

func (m *EngineCheckpointModel) Reset()

func (*EngineCheckpointModel) Size 

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

func (*EngineCheckpointModel) String 

func (m *EngineCheckpointModel) String() string

func (*EngineCheckpointModel) Unmarshal 

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

func (*EngineCheckpointModel) XXX_DiscardUnknown 

func (m *EngineCheckpointModel) XXX_DiscardUnknown()

func (*EngineCheckpointModel) XXX_Marshal 

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

func (*EngineCheckpointModel) XXX_Merge 

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

func (*EngineCheckpointModel) XXX_Size 

func (m *EngineCheckpointModel) XXX_Size() int

func (*EngineCheckpointModel) XXX_Unmarshal 

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

type TableCheckpointModel 

type TableCheckpointModel struct {
	Hash       []byte                           `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Status     uint32                           `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	Engines    map[int32]*EngineCheckpointModel `` /* 158-byte string literal not displayed */
	TableID    int64                            `protobuf:"varint,9,opt,name=tableID,proto3" json:"tableID,omitempty"`
	KvBytes    uint64                           `protobuf:"varint,10,opt,name=kv_bytes,json=kvBytes,proto3" json:"kv_bytes,omitempty"`
	KvKvs      uint64                           `protobuf:"varint,11,opt,name=kv_kvs,json=kvKvs,proto3" json:"kv_kvs,omitempty"`
	KvChecksum uint64                           `protobuf:"fixed64,12,opt,name=kv_checksum,json=kvChecksum,proto3" json:"kv_checksum,omitempty"`
	TableInfo  []byte                           `protobuf:"bytes,13,opt,name=table_info,json=tableInfo,proto3" json:"table_info,omitempty"`
	// used to record the max auto random ID without the sharding bits that has been used.
	AutoRandBase int64 `protobuf:"varint,14,opt,name=autoRandBase,proto3" json:"autoRandBase,omitempty"`
	// used to record the max auto increment ID that has been used.
	AutoIncrBase int64 `protobuf:"varint,15,opt,name=autoIncrBase,proto3" json:"autoIncrBase,omitempty"`
	// used to record the max auto row ID that has been used.
	AutoRowIDBase int64 `protobuf:"varint,16,opt,name=autoRowIDBase,proto3" json:"autoRowIDBase,omitempty"`
}

func (*TableCheckpointModel) Descriptor 

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

func (*TableCheckpointModel) Marshal 

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

func (*TableCheckpointModel) MarshalTo 

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

func (*TableCheckpointModel) MarshalToSizedBuffer 

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

func (*TableCheckpointModel) ProtoMessage 

func (*TableCheckpointModel) ProtoMessage()

func (*TableCheckpointModel) Reset 

func (m *TableCheckpointModel) Reset()

func (*TableCheckpointModel) Size 

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

func (*TableCheckpointModel) String 

func (m *TableCheckpointModel) String() string

func (*TableCheckpointModel) Unmarshal 

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

func (*TableCheckpointModel) XXX_DiscardUnknown 

func (m *TableCheckpointModel) XXX_DiscardUnknown()

func (*TableCheckpointModel) XXX_Marshal 

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

func (*TableCheckpointModel) XXX_Merge 

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

func (*TableCheckpointModel) XXX_Size 

func (m *TableCheckpointModel) XXX_Size() int

func (*TableCheckpointModel) XXX_Unmarshal 

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

type TaskCheckpointModel 

type TaskCheckpointModel struct {
	TaskId       int64  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	SourceDir    string `protobuf:"bytes,2,opt,name=source_dir,json=sourceDir,proto3" json:"source_dir,omitempty"`
	Backend      string `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`
	ImporterAddr string `protobuf:"bytes,4,opt,name=importer_addr,json=importerAddr,proto3" json:"importer_addr,omitempty"`
	TidbHost     string `protobuf:"bytes,5,opt,name=tidb_host,json=tidbHost,proto3" json:"tidb_host,omitempty"`
	TidbPort     int32  `protobuf:"varint,6,opt,name=tidb_port,json=tidbPort,proto3" json:"tidb_port,omitempty"`
	PdAddr       string `protobuf:"bytes,7,opt,name=pd_addr,json=pdAddr,proto3" json:"pd_addr,omitempty"`
	SortedKvDir  string `protobuf:"bytes,8,opt,name=sorted_kv_dir,json=sortedKvDir,proto3" json:"sorted_kv_dir,omitempty"`
	LightningVer string `protobuf:"bytes,9,opt,name=lightning_ver,json=lightningVer,proto3" json:"lightning_ver,omitempty"`
}

func (*TaskCheckpointModel) Descriptor 

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

func (*TaskCheckpointModel) Marshal 

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

func (*TaskCheckpointModel) MarshalTo 

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

func (*TaskCheckpointModel) MarshalToSizedBuffer 

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

func (*TaskCheckpointModel) ProtoMessage 

func (*TaskCheckpointModel) ProtoMessage()

func (*TaskCheckpointModel) Reset 

func (m *TaskCheckpointModel) Reset()

func (*TaskCheckpointModel) Size 

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

func (*TaskCheckpointModel) String 

func (m *TaskCheckpointModel) String() string

func (*TaskCheckpointModel) Unmarshal 

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

func (*TaskCheckpointModel) XXX_DiscardUnknown 

func (m *TaskCheckpointModel) XXX_DiscardUnknown()

func (*TaskCheckpointModel) XXX_Marshal 

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

func (*TaskCheckpointModel) XXX_Merge 

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

func (*TaskCheckpointModel) XXX_Size 

func (m *TaskCheckpointModel) XXX_Size() int

func (*TaskCheckpointModel) XXX_Unmarshal 

func (m *TaskCheckpointModel) 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.