status

type CNInstance struct {
	UUID      string
	TxnClient client.TxnClient
}

type CNStatus struct {
	UUID            string          `json:"uuid"`
	TxnClientStatus TxnClientStatus `json:"txn_client_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 LogtailServerStatus struct {
	Sessions        []SessionStatus  `json:"session_status"`
	DeletedSessions []DeletedSession `json:"deleted_sessions"`
}

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"`
	CNStatus            []CNStatus          `json:"cn_status"`
}

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