phys

Documentation

Index

• type DistTxnStat
• type RestoreRSMetrics
• type RestoreShardStat
• type RestoreStat
• type RestoreTxn
  • func (t *RestoreTxn) Decode(b []byte) error
  • func (t RestoreTxn) Encode() []byte
  • func (t RestoreTxn) String() string
• type TxnState

Types

type DistTxnStat

type DistTxnStat struct {
	// Partial is the num of transactions that were allied on other shards
	// but can't be applied on this one since not all prepare messages got
	// into the oplog (shouldn't happen).
	Partial int `bson:"partial" json:"partial"`
	// ShardUncommitted is the number of uncommitted transactions before
	// the sync. Basically, the transaction is full but no commit message
	// in the oplog of this shard.
	ShardUncommitted int `bson:"shard_uncommitted" json:"shard_uncommitted"`
	// LeftUncommitted is the num of transactions that remain uncommitted
	// after the sync. The transaction is full but no commit message in the
	// oplog of any shard.
	LeftUncommitted int `bson:"left_uncommitted" json:"left_uncommitted"`
}

type RestoreRSMetrics

type RestoreRSMetrics struct {
	DistTxn  DistTxnStat     `bson:"txn,omitempty" json:"txn,omitempty"`
	Download s3.DownloadStat `bson:"download,omitempty" json:"download,omitempty"`
}

type RestoreShardStat

type RestoreShardStat struct {
	Txn DistTxnStat      `json:"txn"`
	D   *s3.DownloadStat `json:"d"`
}

type RestoreStat

type RestoreStat struct {
	RS map[string]map[string]RestoreRSMetrics `bson:"rs,omitempty" json:"rs,omitempty"`
}

type RestoreTxn

type RestoreTxn struct {
	ID    string              `bson:"id" json:"id"`
	Ctime primitive.Timestamp `bson:"ts" json:"ts"` // commit timestamp of the transaction
	State TxnState            `bson:"state" json:"state"`
}

func (*RestoreTxn) Decode

func (t *RestoreTxn) Decode(b []byte) error

func (RestoreTxn) Encode

func (t RestoreTxn) Encode() []byte

func (RestoreTxn) String

func (t RestoreTxn) String() string

type TxnState

type TxnState string

const (
	TxnCommit  TxnState = "commit"
	TxnPrepare TxnState = "prepare"
	TxnAbort   TxnState = "abort"
	TxnUnknown TxnState = ""
)