restore

Documentation

Index

• Constants
• func GetAutoIncrementPkIndex(meta *tablestore.TableMeta) int
• func ShouldSleep(err error) bool
• type BinaryRecordReplayRequest
• type BinaryRecordReplayResponse
  • func BinaryRecordRestore(client *tablestore.TableStoreClient, request *BinaryRecordReplayRequest) (*BinaryRecordReplayResponse, error)
• type RecordReplayRequest
• type RecordReplayResponse
  • func RecordRestore(client *tablestore.TableStoreClient, request *RecordReplayRequest) (*RecordReplayResponse, error)
• type ResponseInfo

Constants

const DefaultBatchWriteRowCount = 200

Functions

func GetAutoIncrementPkIndex

func GetAutoIncrementPkIndex(meta *tablestore.TableMeta) int

func ShouldSleep

func ShouldSleep(err error) bool

ShouldSleep Provided for HBR use

Types

type BinaryRecordReplayRequest

type BinaryRecordReplayRequest struct {
	Record []byte
	//stream record end timestamp, if the record exceeds this timestamp, it won't be replayed.
	//when timestamp is 0, all records will be replayed.
	Timestamp            int64
	TableName            string
	DiscardDataVersion   bool //whether to discard data version
	AutoIncrementPKIndex int  //The index of the autoIncrement pk column
	//whether the server needs to regenerate the autoIncrement column
	ReGenerateAutoIncrementPK bool
}

type BinaryRecordReplayResponse

type BinaryRecordReplayResponse struct {
	RecordRestoreCount int
	HasTimeoutRecord   bool
	ResponseInfo
}

func BinaryRecordRestore

func BinaryRecordRestore(client *tablestore.TableStoreClient, request *BinaryRecordReplayRequest) (*BinaryRecordReplayResponse, error)

type RecordReplayRequest

type RecordReplayRequest struct {
	Record []*tunnel.Record
	//stream record end timestamp, if the record exceeds this timestamp, it won't be replayed.
	//when timestamp is 0, all records will be replayed.
	Timestamp            int64
	TableName            string
	DiscardDataVersion   bool //whether to discard data version
	AutoIncrementPKIndex int  //the index of the autoIncrement pk column
	//whether the server needs to regenerate the autoIncrement column
	ReGenerateAutoIncrementPK bool
}

type RecordReplayResponse

type RecordReplayResponse struct {
	RecordRestoreCount int
	HasTimeoutRecord   bool //whether to include record that exceeds timestamp in recordReplayRequest
	ResponseInfo
}

func RecordRestore

func RecordRestore(client *tablestore.TableStoreClient, request *RecordReplayRequest) (*RecordReplayResponse, error)

type ResponseInfo

type ResponseInfo struct {
	RequestId string
}