committer

Documentation

Index

• type AriaLikeBatchCommitter
  • func NewAriaLikeBatchCommitter() *AriaLikeBatchCommitter
  • func (ptc *AriaLikeBatchCommitter) Commit(batchExecutionResult *BatchExecutionResult) *storage.BatchCommittedResult
• type BatchCommitter
• type BatchExecutionResult

Types

type AriaLikeBatchCommitter

type AriaLikeBatchCommitter struct {
	// contains filtered or unexported fields
}

func NewAriaLikeBatchCommitter

func NewAriaLikeBatchCommitter() *AriaLikeBatchCommitter

func (*AriaLikeBatchCommitter) Commit

func (ptc *AriaLikeBatchCommitter) Commit(batchExecutionResult *BatchExecutionResult) *storage.BatchCommittedResult

type BatchCommitter

type BatchCommitter interface {
	// Commit checks the transaction conflict and generate transaction commit status.
	Commit(batchExecutionResult *BatchExecutionResult) *storage.BatchCommittedResult
}

type BatchExecutionResult

type BatchExecutionResult struct {
	TransactionContexts []*transaction.Context
	BatchNum            int64
	BatchMetadata       []byte
	ReserveWritesTable  *sync.Map
}