util

package
v1.0.0-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetLogger added in v0.8.0 

func GetLogger() *log.MOLogger

GetLogger get logger

func LogTxn1PCCommitCompleted added in v0.6.0 

func LogTxn1PCCommitCompleted(txnMeta txn.TxnMeta)

LogTxn1PCCommitCompleted log Txn 1pc commit completed

func LogTxnCommit added in v0.6.0 

func LogTxnCommit(txnMeta txn.TxnMeta)

LogTxnCommit log txn commit

func LogTxnCommitOnInvalidStatus added in v0.6.0 

func LogTxnCommitOnInvalidStatus(txnMeta txn.TxnMeta)

LogTxnCommitOnInvalidStatus log Txn commit on invalid txn status.

func LogTxnCommittingCompleted added in v0.6.0 

func LogTxnCommittingCompleted(txnMeta txn.TxnMeta)

LogTxnCommittingCompleted log Txn Committing completed on coordinator failed

func LogTxnCommittingFailed added in v0.6.0 

func LogTxnCommittingFailed(
	txnMeta txn.TxnMeta,
	err error)

LogTxnCommittingFailed log Txn Committing failed on coordinator failed

func LogTxnCreateOn added in v0.6.0 

func LogTxnCreateOn(txnMeta txn.TxnMeta,
	tn metadata.TNShard)

LogTxnCreateOn log Txn create on tn shard.

func LogTxnCreated added in v0.6.0 

func LogTxnCreated(txnMeta txn.TxnMeta)

LogTxnCreated log txn created

func LogTxnHandleRequest added in v0.6.0 

func LogTxnHandleRequest(request *txn.TxnRequest)

LogTxnHandleRequest log txn handle request

func LogTxnHandleResult added in v0.6.0 

func LogTxnHandleResult(response *txn.TxnResponse)

LogTxnHandleResult log txn handle request

func LogTxnNotFoundOn added in v0.6.0 

func LogTxnNotFoundOn(txnMeta txn.TxnMeta,
	tn metadata.TNShard)

LogTxnReadFailed log Txn read failed.

func LogTxnParallelPrepareCompleted added in v0.6.0 

func LogTxnParallelPrepareCompleted(txnMeta txn.TxnMeta)

LogTxnParallelPrepareCompleted log Txn parallel prepare completed

func LogTxnParallelPrepareFailed added in v0.6.0 

func LogTxnParallelPrepareFailed(
	txnMeta txn.TxnMeta,
	err error)

LogTxnParallelPrepareFailed log Txn parallel prepare failed

func LogTxnPrepareCompletedOn added in v0.6.0 

func LogTxnPrepareCompletedOn(
	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(
	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(
	value timestamp.Timestamp)

LogTxnPushedTimestampUpdated log tn pushed timestamp updated

func LogTxnRead added in v0.6.0 

func LogTxnRead(txnMeta txn.TxnMeta)

LogTxnRead log txn read

func LogTxnReadBlockedByUncommittedTxns added in v0.6.0 

func LogTxnReadBlockedByUncommittedTxns(txnMeta txn.TxnMeta,
	waitTxns [][]byte)

LogTxnReadBlockedByUncommittedTxns log Txn read blocked by other txns

func LogTxnReadFailed added in v0.6.0 

func LogTxnReadFailed(
	txnMeta txn.TxnMeta,
	err error)

LogTxnReadFailed log Txn read failed.

func LogTxnReceivedResponses added in v0.6.0 

func LogTxnReceivedResponses(responses []txn.TxnResponse)

LogTxnReceivedResponses log received txn responses

func LogTxnRollback added in v0.6.0 

func LogTxnRollback(txnMeta txn.TxnMeta)

LogTxnRollback log txn rollback

func LogTxnRollbackCompleted added in v0.6.0 

func LogTxnRollbackCompleted(txnMeta txn.TxnMeta)

LogTxnRollbackCompleted log Txn rollback completed

func LogTxnSendRequests added in v0.6.0 

func LogTxnSendRequests(requests []txn.TxnRequest)

LogTxnSendRequests log txn send txn requests

func LogTxnSendRequestsFailed added in v0.6.0 

func LogTxnSendRequestsFailed(requests []txn.TxnRequest,
	err error)

LogTxnSendRequestsFailed log txn send txn requests failed

func LogTxnSnapshotTimestamp added in v0.8.0 

func LogTxnSnapshotTimestamp(
	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(txnMeta txn.TxnMeta)

LogTxnStart1PCCommit log Txn start 1pc commit

func LogTxnStart1PCCommitFailed added in v0.6.0 

func LogTxnStart1PCCommitFailed(
	txnMeta txn.TxnMeta,
	err error)

LogTxnStart1PCCommitFailed log Txn 1pc commit failed

func LogTxnStart2PCCommit added in v0.6.0 

func LogTxnStart2PCCommit(txnMeta txn.TxnMeta)

LogTxnStart2PCCommit log Txn start 2pc commit

func LogTxnStartAsyncCommit added in v0.6.0 

func LogTxnStartAsyncCommit(txnMeta txn.TxnMeta)

LogTxnStartAsyncCommit log start async commit distributed txn task

func LogTxnStartAsyncRollback added in v0.6.0 

func LogTxnStartAsyncRollback(txnMeta txn.TxnMeta)

LogTxnStartAsyncRollback log start async rollback txn task

func LogTxnUpdated added in v0.6.0 

func LogTxnUpdated(txnMeta txn.TxnMeta)

LogTxnUpdated log txn updated

func LogTxnWaitUncommittedTxnsFailed added in v0.6.0 

func LogTxnWaitUncommittedTxnsFailed(txnMeta txn.TxnMeta,
	waitTxns [][]byte,
	err error)

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

func LogTxnWaiterAdded added in v0.6.0 

func LogTxnWaiterAdded(txnMeta txn.TxnMeta,
	waitStatus txn.TxnStatus)

LogTxnWaiterAdded log txn waiter added

func LogTxnWrite added in v0.6.0 

func LogTxnWrite(txnMeta txn.TxnMeta)

LogTxnWrite log txn write

func LogTxnWriteFailed added in v0.6.0 

func LogTxnWriteFailed(
	txnMeta txn.TxnMeta,
	err error)

LogTxnWriteFailed log Txn write failed.

func LogTxnWriteOnInvalidStatus added in v0.6.0 

func LogTxnWriteOnInvalidStatus(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

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.