node

type ArbitratorStatus struct {
	URL    string   `json:"url"`
	Status status.T `json:"status"`
	Weight int      `json:"weight"`
}

type Config struct {
	Collector              *collector.Config `json:"collector,omitempty"`
	Env                    string            `json:"env"`
	Hooks                  Hooks             `json:"hooks"`
	Labels                 label.M           `json:"labels"`
	MaintenanceGracePeriod time.Duration     `json:"maintenance_grace_period"`
	MaxParallel            int               `json:"max_parallel"`
	MaxKeySize             int64             `json:"max_key_size"`
	MinAvailMemPct         int               `json:"min_avail_mem_pct"`
	MinAvailSwapPct        int               `json:"min_avail_swap_pct"`
	ReadyPeriod            time.Duration     `json:"ready_period"`
	RejoinGracePeriod      time.Duration     `json:"rejoin_grace_period"`
	Schedules              []schedule.Config `json:"schedules"`
	SplitAction            string            `json:"split_action"`
	SSHKey                 string            `json:"sshkey"`
	PRKey                  string            `json:"prkey"`

	// Issues are the configuration faults found on this node that
	// a human has to correct, as the cluster configuration has its
	// own. They are found by the node they name, and travel with
	// its configuration so that a peer, om mon and the tui can
	// report them without repeating the search.
	Issues []string `json:"issues"`
}

type Data[T Dataer] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type DataElement[T Dataer] struct {
	Node  string
	Value *T
}

type Dataer interface {
	Config | Monitor | san.Paths | Stats | Status | Gen
}

type Gen map[string]uint64

type Hook struct {
	Name    string   `json:"name"`
	Events  []string `json:"events"`
	Command []string `json:"command"`
}

type Hooks []Hook

type Instances struct {
	Config  map[string]instance.Config  `json:"config"`
	Status  map[string]instance.Status  `json:"status"`
	Monitor map[string]instance.Monitor `json:"monitor"`
}

type Monitor struct {
	GlobalExpect MonitorGlobalExpect `json:"global_expect"`
	LocalExpect  MonitorLocalExpect  `json:"local_expect"`
	State        MonitorState        `json:"state"`

	GlobalExpectUpdatedAt time.Time `json:"global_expect_updated_at"`
	LocalExpectUpdatedAt  time.Time `json:"local_expect_updated_at"`
	StateUpdatedAt        time.Time `json:"state_updated_at"`
	UpdatedAt             time.Time `json:"updated_at"`

	OrchestrationID     uuid.UUID `json:"orchestration_id"`
	OrchestrationIsDone bool      `json:"orchestration_is_done"`
	SessionID           uuid.UUID `json:"session_id"`

	IsPreserved bool `json:"preserved"`
}

type MonitorGlobalExpect int

type MonitorLocalExpect int

type MonitorState int

type MonitorUpdate struct {
	State        *MonitorState        `json:"state"`
	LocalExpect  *MonitorLocalExpect  `json:"local_expect"`
	GlobalExpect *MonitorGlobalExpect `json:"global_expect"`

	// CandidateOrchestrationID is a candidate orchestration id for a new imon orchestration.
	CandidateOrchestrationID uuid.UUID `json:"orchestration_id"`
}

type Node struct {
	Instance map[string]instance.Instance `json:"instance"`
	Pool     map[string]pool.Status       `json:"pool"`
	Monitor  Monitor                      `json:"monitor"`
	Stats    Stats                        `json:"stats"`
	Status   Status                       `json:"status"`
	Os       Os                           `json:"os"`
	Config   Config                       `json:"config"`

	Daemon daemonsubsystem.Daemon `json:"daemon"`
}

type Os struct {
	Paths san.Paths `json:"paths"`
}

type Stats struct {
	Load15M      float64 `json:"load_15m"`
	MemAvailPct  int     `json:"mem_avail"`
	MemTotalMB   uint64  `json:"mem_total"`
	Score        int     `json:"score"`
	SwapAvailPct int     `json:"swap_avail"`
	SwapTotalMB  uint64  `json:"swap_total"`
}

type Status struct {
	Agent        string                      `json:"agent"`
	API          uint64                      `json:"api"`
	Arbitrators  map[string]ArbitratorStatus `json:"arbitrators"`
	Compat       uint64                      `json:"compat"`
	FrozenAt     time.Time                   `json:"frozen_at"`
	Gen          Gen                         `json:"gen"`
	IsLeader     bool                        `json:"is_leader"`
	IsOverloaded bool                        `json:"is_overloaded"`
	BootedAt     time.Time                   `json:"booted_at"`

	// LeftAt is the last time the nmon advanced the last_shutdown file,
	// i.e. the last time it proved it was alive and rejoined.
	LeftAt time.Time `json:"left_at"`

	// RejoinedAt is the time nmon state transitioned from rejoin to idle.
	// This happens either when the rejoin_grace_period expires or when
	// we received data from all peers.
	RejoinedAt time.Time `json:"rejoined_at"`
}