status

type CNInstance struct {
	TxnClient   client.TxnClient
	LockService lockservice.LockService
	// contains filtered or unexported fields
}

type CNStatus struct {
	TxnClientStatus TxnClientStatus `json:"txn_client_status"`
	LockStatus      LockStatus      `json:"lock_status"`
	LogtailStatus   LogtailStatus   `json:"logtail_status"`
}

type DeletedSession struct {
	Address   string    `json:"address"`
	DeletedAt time.Time `json:"deleted_at"`
}

type HAKeeperStatus struct {
	Nodes        []NodeStatus `json:"nodes"`
	DeletedNodes []NodeStatus `json:"deleted_nodes"`
	ErrMsg       string       `json:"err_msg"`
}

type LockItem struct {
	TableID  uint64   `json:"table_id"`
	Keys     [][]byte `json:"keys"`
	LockInfo string   `json:"lock_info"`
}

type LockStatus struct {
	Locks []LockItem `json:"locks"`
}

type LogtailServerStatus struct {
	Sessions        []SessionStatus  `json:"session_status"`
	DeletedSessions []DeletedSession `json:"deleted_sessions"`
}

type LogtailStatus struct {
	LatestTS         timestamp.Timestamp       `json:"latest_ts"`
	SubscribedTables map[string]SubTableStatus `json:"subscribed_tables"`
}

type NodeStatus struct {
	NodeID    string                        `json:"node_id"`
	NodeType  string                        `json:"node_type"`
	Address   string                        `json:"address"`
	Labels    map[string]metadata.LabelList `json:"Labels"`
	WorkState metadata.WorkState            `json:"WorkState"`
	Resource  pb.Resource                   `json:"Resource"`
	UpTime    time.Time                     `json:"up_time"`
	DownTime  time.Time                     `json:"down_time"`
}

type Server struct {
	// contains filtered or unexported fields
}

type SessionStatus struct {
	ClientAddress    string    `json:"client_address"`
	LastBeforeSend   time.Time `json:"last_before_send"`
	LastAfterSend    time.Time `json:"last_after_send"`
	Active           int       `json:"active"`
	TableStatusCount int       `json:"table_status_count"`
}

type Status struct {
	LogtailServerStatus LogtailServerStatus  `json:"logtail_server_status"`
	HAKeeperStatus      HAKeeperStatus       `json:"hakeeper_status"`
	CNUUIDStatus        map[string]*CNStatus `json:"cn_uuid_status"`
}

type SubTableID struct {
	DatabaseID uint64 `json:"database_id"`
	TableID    uint64 `json:"table_id"`
}

type SubTableStatus struct {
	SubState   int32     `json:"sub_state"`
	LatestTime time.Time `json:"latest_time"`
}

type TxnClientStatus struct {
	// indicate whether the CN can provide service normally.
	// 0 means paused, 1 means normal.
	State int `json:"state"`
	// number of user active transactions.
	UserTxnNum int `json:"user_txn_num"`
	// all active txns
	ActiveTxns     []string `json:"active_txns"`
	ActiveTxnCount int      `json:"active_txn_count"`
	// FIFO queue for ready to active txn
	WaitActiveTxns     []string `json:"wait_active_txns"`
	WaitActiveTxnCount int      `json:"wait_active_txn_count"`
	// LatestTS is the latest TS for the txn client.
	LatestTS timestamp.Timestamp `json:"latest_ts"`
}