package
25.1.0+incompatible
Repository: https://github.com/cockroachdb/cockroach.git
Documentation: pkg.go.dev
# Functions
CanPushWithPriority returns true if the pusher can perform the specified push type on the pushee, based on the two txns' isolation levels, their priorities, and the pushee's status.
IsExpired is true if the given transaction is expired.
NewMetrics creates a new Metrics instance with all related metric fields.
NewQueue instantiates a new Queue.
ShouldPushImmediately returns whether the PushTxn request should proceed without queueing.
TestingOverrideTxnLivenessThreshold allows tests to override the transaction liveness threshold.
TxnExpiration computes the timestamp after which the transaction will be considered expired.
# Variables
TxnLivenessHeartbeatMultiplier specifies what multiple the transaction liveness threshold should be of the transaction heartbeat interval.
TxnLivenessThreshold is the maximum duration between transaction heartbeats before the transaction is considered expired by Queue.
# Structs
Config contains the dependencies to construct a Queue.
Metrics contains all the txnqueue related metrics.
Queue enqueues PushTxn requests which are waiting on extant txns with conflicting intents to abort or commit.
TestingKnobs represents testing knobs for a Queue.