util

Documentation

Index

• func LogTxn1PCCommitCompleted(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnCommit(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnCommitOnInvalidStatus(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnCommittingCompleted(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnCommittingFailed(logger *zap.Logger, txnMeta txn.TxnMeta, err error)
• func LogTxnCreateOn(logger *zap.Logger, txnMeta txn.TxnMeta, dn metadata.DNShard)
• func LogTxnCreated(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnHandleRequest(logger *zap.Logger, request *txn.TxnRequest)
• func LogTxnHandleResult(logger *zap.Logger, response *txn.TxnResponse)
• func LogTxnNotFoundOn(logger *zap.Logger, txnMeta txn.TxnMeta, dn metadata.DNShard)
• func LogTxnParallelPrepareCompleted(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnParallelPrepareFailed(logger *zap.Logger, txnMeta txn.TxnMeta, err error)
• func LogTxnPrepareCompletedOn(logger *zap.Logger, txnMeta txn.TxnMeta, dn metadata.DNShard, ...)
• func LogTxnPrepareFailedOn(logger *zap.Logger, txnMeta txn.TxnMeta, dn metadata.DNShard, ...)
• func LogTxnRead(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnReadBlockedByUncommittedTxns(logger *zap.Logger, txnMeta txn.TxnMeta, waitTxns [][]byte)
• func LogTxnReadFailed(logger *zap.Logger, txnMeta txn.TxnMeta, err error)
• func LogTxnReceivedResponses(logger *zap.Logger, responses []txn.TxnResponse)
• func LogTxnRollback(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnRollbackCompleted(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnSendRequests(logger *zap.Logger, requests []txn.TxnRequest)
• func LogTxnSendRequestsFailed(logger *zap.Logger, requests []txn.TxnRequest, err error)
• func LogTxnStart1PCCommit(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnStart1PCCommitFailed(logger *zap.Logger, txnMeta txn.TxnMeta, err error)
• func LogTxnStart2PCCommit(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnStartAsyncCommit(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnStartAsyncRollback(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnUpdated(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnWaitUncommittedTxnsFailed(logger *zap.Logger, txnMeta txn.TxnMeta, waitTxns [][]byte, err error)
• func LogTxnWaiterAdded(logger *zap.Logger, txnMeta txn.TxnMeta, waitStatus txn.TxnStatus)
• func LogTxnWrite(logger *zap.Logger, txnMeta txn.TxnMeta)
• func LogTxnWriteFailed(logger *zap.Logger, txnMeta txn.TxnMeta, err error)
• func LogTxnWriteOnInvalidStatus(logger *zap.Logger, txnMeta txn.TxnMeta)
• func TxnDNShardField(dn metadata.DNShard) zap.Field
• func TxnField(txnMeta txn.TxnMeta) zap.Field
• func TxnIDField(txnMeta txn.TxnMeta) zap.Field
• func TxnIDFieldWithID(id []byte) zap.Field
• func TxnIDsField(txnIDs [][]byte) zap.Field

Functions

func LogTxn1PCCommitCompleted

func LogTxn1PCCommitCompleted(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxn1PCCommitCompleted log Txn 1pc commit completed

func LogTxnCommit

func LogTxnCommit(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnCommit log txn commit

func LogTxnCommitOnInvalidStatus

func LogTxnCommitOnInvalidStatus(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnCommitOnInvalidStatus log Txn commit on invalid txn status.

func LogTxnCommittingCompleted

func LogTxnCommittingCompleted(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnCommittingCompleted log Txn Committing completed on coordinator failed

func LogTxnCommittingFailed

func LogTxnCommittingFailed(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	err error)

LogTxnCommittingFailed log Txn Committing failed on coordinator failed

func LogTxnCreateOn

func LogTxnCreateOn(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	dn metadata.DNShard)

LogTxnCreateOn log Txn create on dn shard.

func LogTxnCreated

func LogTxnCreated(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnCreated log txn created

func LogTxnHandleRequest

func LogTxnHandleRequest(
	logger *zap.Logger,
	request *txn.TxnRequest)

LogTxnHandleRequest log txn handle request

func LogTxnHandleResult

func LogTxnHandleResult(
	logger *zap.Logger,
	response *txn.TxnResponse)

LogTxnHandleResult log txn handle request

func LogTxnNotFoundOn

func LogTxnNotFoundOn(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	dn metadata.DNShard)

LogTxnReadFailed log Txn read failed.

func LogTxnParallelPrepareCompleted

func LogTxnParallelPrepareCompleted(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnParallelPrepareCompleted log Txn parallel prepare completed

func LogTxnParallelPrepareFailed

func LogTxnParallelPrepareFailed(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	err error)

LogTxnParallelPrepareFailed log Txn parallel prepare failed

func LogTxnPrepareCompletedOn

func LogTxnPrepareCompletedOn(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	dn metadata.DNShard,
	preparedTS timestamp.Timestamp)

LogTxnPrepareCompletedOn log Tx prepare completed on DNShard

func LogTxnPrepareFailedOn

func LogTxnPrepareFailedOn(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	dn metadata.DNShard,
	err *txn.TxnError)

LogTxnPrepareFailedOn log Tx prepare failed on DNShard

func LogTxnRead

func LogTxnRead(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnRead log txn read

func LogTxnReadBlockedByUncommittedTxns

func LogTxnReadBlockedByUncommittedTxns(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	waitTxns [][]byte)

LogTxnReadBlockedByUncommittedTxns log Txn read blocked by other txns

func LogTxnReadFailed

func LogTxnReadFailed(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	err error)

LogTxnReadFailed log Txn read failed.

func LogTxnReceivedResponses

func LogTxnReceivedResponses(
	logger *zap.Logger,
	responses []txn.TxnResponse)

LogTxnReceivedResponses log received txn responses

func LogTxnRollback

func LogTxnRollback(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnRollback log txn rollback

func LogTxnRollbackCompleted

func LogTxnRollbackCompleted(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnRollbackCompleted log Txn rollback completed

func LogTxnSendRequests

func LogTxnSendRequests(
	logger *zap.Logger,
	requests []txn.TxnRequest)

LogTxnSendRequests log txn send txn requests

func LogTxnSendRequestsFailed

func LogTxnSendRequestsFailed(
	logger *zap.Logger,
	requests []txn.TxnRequest,
	err error)

LogTxnSendRequestsFailed log txn send txn requests failed

func LogTxnStart1PCCommit

func LogTxnStart1PCCommit(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnStart1PCCommit log Txn start 1pc commit

func LogTxnStart1PCCommitFailed

func LogTxnStart1PCCommitFailed(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	err error)

LogTxnStart1PCCommitFailed log Txn 1pc commit failed

func LogTxnStart2PCCommit

func LogTxnStart2PCCommit(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnStart2PCCommit log Txn start 2pc commit

func LogTxnStartAsyncCommit

func LogTxnStartAsyncCommit(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnStartAsyncCommit log start async commit distributed txn task

func LogTxnStartAsyncRollback

func LogTxnStartAsyncRollback(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnStartAsyncRollback log start async rollback txn task

func LogTxnUpdated

func LogTxnUpdated(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnUpdated log txn updated

func LogTxnWaitUncommittedTxnsFailed

func LogTxnWaitUncommittedTxnsFailed(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	waitTxns [][]byte,
	err error)

LogTxnWaitUncommittedTxnsFailed log Txn wait other uncommitted txns change to committed or abortted failed.

func LogTxnWaiterAdded

func LogTxnWaiterAdded(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	waitStatus txn.TxnStatus)

LogTxnWaiterAdded log txn waiter added

func LogTxnWrite

func LogTxnWrite(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnWrite log txn write

func LogTxnWriteFailed

func LogTxnWriteFailed(
	logger *zap.Logger,
	txnMeta txn.TxnMeta,
	err error)

LogTxnWriteFailed log Txn write failed.

func LogTxnWriteOnInvalidStatus

func LogTxnWriteOnInvalidStatus(
	logger *zap.Logger,
	txnMeta txn.TxnMeta)

LogTxnWriteOnInvalidStatus log Txn write on invalid txn status.

func TxnDNShardField

func TxnDNShardField(dn metadata.DNShard) zap.Field

TxnDNShardField returns a dn shard zap field

func TxnField

func TxnField(txnMeta txn.TxnMeta) zap.Field

TxnField returns a txn zap field

func TxnIDField

func TxnIDField(txnMeta txn.TxnMeta) zap.Field

TxnIDField returns a txn id field

func TxnIDFieldWithID

func TxnIDFieldWithID(id []byte) zap.Field

TxnIDFieldWithID returns a txn id field

func TxnIDsField

func TxnIDsField(txnIDs [][]byte) zap.Field

TxnIDsField returns a txn ids field