daemonsubsystem

type Alert struct {
	Message  string `json:"message"`
	Severity string `json:"severity"`
}

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

type CacheElement[T Cacher] struct {
	Node  string
	Value *T
}

type Cacher interface {
	Collector | Dns | Daemondata | Heartbeat | Listener | RunnerImon | Scheduler
}

type Collector struct {
	Status

	Url string `json:"url"`
}

type Daemon struct {
	// Collector DaemonCollector describes the OpenSVC daemon collector subsystem state,
	// which is responsible for communicating with the collector on behalf
	// of the cluster. Only one node on the cluster is the collector speaker
	Collector Collector `json:"collector"`

	// Daemondata DaemonDaemondata describes the OpenSVC daemon data subsystem state,
	// which is responsible for aggregating data messages and selecting
	// candidate data messages to forward to peer nodes.
	Daemondata Daemondata `json:"daemondata"`

	// Dns describes the OpenSVC daemon dns subsystem state, which is
	// responsible for janitoring and serving the cluster Dns zone.
	// This zone is dynamically populated by ip address allocated for the
	// services (frontend and backend).
	Dns Dns `json:"dns"`

	Heartbeat Heartbeat `json:"heartbeat"`

	// Listener DaemonListener describes the OpenSVC daemon listener subsystem state,
	// which is responsible for serving the API.
	Listener Listener `json:"listener"`

	Nodename string `json:"nodename"`

	// Pid the main daemon process id
	// it is sent on the full hb message, then not anymore changed
	Pid int `json:"pid"`

	// StartedAt is the time when daemon has been started
	// it is sent on the full hb message, then not anymore changed
	StartedAt time.Time `json:"started_at"`

	RunnerImon RunnerImon `json:"runner_imon"`

	// Scheduler DaemonScheduler describes the OpenSVC daemon scheduler subsystem state,
	// which is responsible for executing node and objects scheduled jobs.
	Scheduler Scheduler `json:"scheduler"`
}

type DaemonLocal struct {
	// Nodename is used to identify the nodename that have sent Daemon struct
	Nodename string `json:"nodename"`
	Routines int    `json:"routines"`
}

type Daemondata struct {
	Status

	// QueueSize the subscription queue size
	QueueSize int `json:"queue_size"`
}

type Dns struct {
	Status

	// Nameservers list of nameservers
	Nameservers []string `json:"nameservers"`
}

type Heartbeat struct {

	// LastMessages is the last messages details received from  cluster
	// peer nodes plus the last message details localhost has sent.
	LastMessages []HeartbeatLastMessage `json:"last_messages"`

	// LastMessage is the last message sent from localhost
	LastMessage HeartbeatLastMessage `json:"last_message"`

	// Streams list of daemon heartbeat streams
	Streams []HeartbeatStream `json:"streams"`

	SecretVersion struct {
		Main      uint64 `json:"main"`
		Alternate uint64 `json:"alt"`
	} `json:"secret_version"`

	UpdatedAt time.Time `json:"updated_at"`
}

type HeartbeatLastMessage struct {
	// From a cluster node
	From string `json:"from"`

	// PatchLength the patch queue length when type is patch, else it is 0
	PatchLength int `json:"patch_length"`

	// Type the heartbeat message type used by node
	Type string `json:"type"`
}

type HeartbeatStream struct {
	Status

	// Type of heartbeat stream (unicast, multicast, ...)
	Type string `json:"type"`

	// Peers map of peer names to daemon hb stream peer status
	Peers map[string]HeartbeatStreamPeerStatus `json:"peers"`

	Alerts []Alert `json:"alerts"`
}

type HeartbeatStreamPeerStatus struct {
	Desc      string `json:"desc"`
	IsBeating bool   `json:"is_beating"`

	// ChangedAt is the time of IsBeating value changed
	ChangedAt time.Time `json:"changed_at"`

	// LastBeatingAt is the last beating time
	LastBeatingAt time.Time `json:"last_beating_at"`
}

type HeartbeatStreamPeerStatusTable []HeartbeatStreamPeerStatusTableEntry

type HeartbeatStreamPeerStatusTableEntry struct {
	Node string `json:"node"`
	Peer string `json:"peer"`
	Status
	Type   string  `json:"type"`
	Alerts []Alert `json:"alerts"`
	HeartbeatStreamPeerStatus
	IsSingleNode bool `json:"-"`
}

type Listener struct {
	Status

	Addr string `json:"addr"`

	Port string `json:"port"`

	RateLimiter cluster.RateLimiterConfig `json:"rate_limiter"`
}

type RunnerImon struct {
	Status

	MaxRunning int `json:"max_running"`
}

type Scheduler struct {
	Status

	// Count is the number of defined scheduled jobs
	Count int `json:"count"`

	// MaxRunning is the maximum number of running jobs
	MaxRunning int `json:"max_running"`
}

type Status struct {
	ID string `json:"id"`

	State string `json:"state"`

	ConfiguredAt time.Time `json:"configured_at"`
	CreatedAt    time.Time `json:"created_at"`
	UpdatedAt    time.Time `json:"updated_at"`
}