restore

Documentation

Index

• Constants
• 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 ShouldSleep

func ShouldSleep(err error) bool

Types

type BinaryRecordReplayRequest

type BinaryRecordReplayRequest struct {
	Record             []byte
	Timestamp          int64
	TableName          string
	DiscardDataVersion 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
}

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
}