util

func GetLogger ¶ added in v0.8.0

func GetLogger(sid string) *log.MOLogger

func LogTimestampWaiterCanceled ¶ added in v1.0.0

func LogTimestampWaiterCanceled(
	logger *log.MOLogger,
)

func LogTxn1PCCommitCompleted ¶ added in v0.6.0

func LogTxn1PCCommitCompleted(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxn1PCCommitCompleted log Txn 1pc commit completed

func LogTxnCommit ¶ added in v0.6.0

func LogTxnCommit(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnCommit log txn commit

func LogTxnCommitOnInvalidStatus ¶ added in v0.6.0

func LogTxnCommitOnInvalidStatus(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnCommitOnInvalidStatus log Txn commit on invalid txn status.

func LogTxnCommittingCompleted ¶ added in v0.6.0

func LogTxnCommittingCompleted(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnCommittingCompleted log Txn Committing completed on coordinator failed

func LogTxnCommittingFailed ¶ added in v0.6.0

func LogTxnCommittingFailed(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	err error,
)

LogTxnCommittingFailed log Txn Committing failed on coordinator failed

func LogTxnCreateOn ¶ added in v0.6.0

func LogTxnCreateOn(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	tn metadata.TNShard,
)

LogTxnCreateOn log Txn create on tn shard.

func LogTxnCreated ¶ added in v0.6.0

func LogTxnCreated(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnCreated log txn created

func LogTxnHandleRequest ¶ added in v0.6.0

func LogTxnHandleRequest(
	logger *log.MOLogger,
	request *txn.TxnRequest,
)

LogTxnHandleRequest log txn handle request

func LogTxnHandleResult ¶ added in v0.6.0

func LogTxnHandleResult(
	logger *log.MOLogger,
	response *txn.TxnResponse,
)

LogTxnHandleResult log txn handle request

func LogTxnNotFoundOn ¶ added in v0.6.0

func LogTxnNotFoundOn(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	tn metadata.TNShard,
)

LogTxnReadFailed log Txn read failed.

func LogTxnParallelPrepareCompleted ¶ added in v0.6.0

func LogTxnParallelPrepareCompleted(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnParallelPrepareCompleted log Txn parallel prepare completed

func LogTxnParallelPrepareFailed ¶ added in v0.6.0

func LogTxnParallelPrepareFailed(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	err error,
)

LogTxnParallelPrepareFailed log Txn parallel prepare failed

func LogTxnPrepareCompletedOn ¶ added in v0.6.0

func LogTxnPrepareCompletedOn(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	tn metadata.TNShard,
	preparedTS timestamp.Timestamp,
)

LogTxnPrepareCompletedOn log Tx prepare completed on DNShard

func LogTxnPrepareFailedOn ¶ added in v0.6.0

func LogTxnPrepareFailedOn(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	tn metadata.TNShard,
	err *txn.TxnError,
)

LogTxnPrepareFailedOn log Tx prepare failed on DNShard

func LogTxnPushedTimestampUpdated ¶ added in v0.8.0

func LogTxnPushedTimestampUpdated(
	logger *log.MOLogger,
	value timestamp.Timestamp,
)

LogTxnPushedTimestampUpdated log tn pushed timestamp updated

func LogTxnRead ¶ added in v0.6.0

func LogTxnRead(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnRead log txn read

func LogTxnReadBlockedByUncommittedTxns ¶ added in v0.6.0

func LogTxnReadBlockedByUncommittedTxns(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	waitTxns [][]byte,
)

LogTxnReadBlockedByUncommittedTxns log Txn read blocked by other txns

func LogTxnReadFailed ¶ added in v0.6.0

func LogTxnReadFailed(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	err error,
)

LogTxnReadFailed log Txn read failed.

func LogTxnReceivedResponses ¶ added in v0.6.0

func LogTxnReceivedResponses(
	logger *log.MOLogger,
	responses []txn.TxnResponse,
)

LogTxnReceivedResponses log received txn responses

func LogTxnRollback ¶ added in v0.6.0

func LogTxnRollback(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnRollback log txn rollback

func LogTxnRollbackCompleted ¶ added in v0.6.0

func LogTxnRollbackCompleted(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnRollbackCompleted log Txn rollback completed

func LogTxnSendRequests ¶ added in v0.6.0

func LogTxnSendRequests(
	logger *log.MOLogger,
	requests []txn.TxnRequest,
)

LogTxnSendRequests log txn send txn requests

func LogTxnSendRequestsFailed ¶ added in v0.6.0

func LogTxnSendRequestsFailed(
	logger *log.MOLogger,
	requests []txn.TxnRequest,
	err error,
)

LogTxnSendRequestsFailed log txn send txn requests failed

func LogTxnSnapshotTimestamp ¶ added in v0.8.0

func LogTxnSnapshotTimestamp(
	logger *log.MOLogger,
	min timestamp.Timestamp,
	latest timestamp.Timestamp,
)

LogTxnSnapshotTimestamp log txn snapshot ts use pushed latest commit ts

func LogTxnStart1PCCommit ¶ added in v0.6.0

func LogTxnStart1PCCommit(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnStart1PCCommit log Txn start 1pc commit

func LogTxnStart1PCCommitFailed ¶ added in v0.6.0

func LogTxnStart1PCCommitFailed(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	err error,
)

LogTxnStart1PCCommitFailed log Txn 1pc commit failed

func LogTxnStart2PCCommit ¶ added in v0.6.0

func LogTxnStart2PCCommit(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnStart2PCCommit log Txn start 2pc commit

func LogTxnStartAsyncCommit ¶ added in v0.6.0

func LogTxnStartAsyncCommit(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnStartAsyncCommit log start async commit distributed txn task

func LogTxnStartAsyncRollback ¶ added in v0.6.0

func LogTxnStartAsyncRollback(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnStartAsyncRollback log start async rollback txn task

func LogTxnUpdated ¶ added in v0.6.0

func LogTxnUpdated(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnUpdated log txn updated

func LogTxnWaitUncommittedTxnsFailed ¶ added in v0.6.0

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

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

func LogTxnWaiterAdded ¶ added in v0.6.0

func LogTxnWaiterAdded(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	waitStatus txn.TxnStatus,
)

LogTxnWaiterAdded log txn waiter added

func LogTxnWrite ¶ added in v0.6.0

func LogTxnWrite(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnWrite log txn write

func LogTxnWriteFailed ¶ added in v0.6.0

func LogTxnWriteFailed(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
	err error,
)

LogTxnWriteFailed log Txn write failed.

func LogTxnWriteOnInvalidStatus ¶ added in v0.6.0

func LogTxnWriteOnInvalidStatus(
	logger *log.MOLogger,
	txnMeta txn.TxnMeta,
)

LogTxnWriteOnInvalidStatus log Txn write on invalid txn status.

func TxnField ¶ added in v0.5.1

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 ¶ added in v0.5.1

func TxnIDFieldWithID(id []byte) zap.Field

TxnIDFieldWithID returns a txn id field

func TxnIDsField ¶ added in v0.6.0

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

TxnIDsField returns a txn ids field

func TxnTNShardField ¶ added in v1.0.0

func TxnTNShardField(tn metadata.TNShard) zap.Field

TxnTNShardField returns a tn shard zap field