msgbus

type ArbitratorError struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	Name       string `json:"name" yaml:"name"`
	ErrS       string `json:"error" yaml:"error"`
}

type AuditStart struct {
	pubsub.Msg `yaml:",inline"`
	Q          chan plog.LogMessage `json:"-" yaml:"-"`
	Subsystems []string             `json:"subsystems" yaml:"subsystems"`
}

type AuditStop struct {
	pubsub.Msg `yaml:",inline"`
	Q          chan plog.LogMessage `json:"-" yaml:"-"`
	Subsystems []string             `json:"subsystems" yaml:"subsystems"`
}

type ClientSubscribed struct {
	pubsub.Msg `yaml:",inline"`
	Time       time.Time `json:"at" yaml:"at"`
	Name       string    `json:"name" yaml:"name"`
}

type ClientUnsubscribed struct {
	pubsub.Msg `yaml:",inline"`
	Time       time.Time `json:"at" yaml:"at"`
	Name       string    `json:"name" yaml:"name"`
}

type ClusterConfigUpdated struct {
	pubsub.Msg     `yaml:",inline"`
	Node           string         `json:"node"`
	Value          cluster.Config `json:"cluster_config"`
	NodesAdded     []string       `json:"nodes_added"`
	NodesRemoved   []string       `json:"nodes_removed"`
	NetworkChanged []string       `json:"network_changed"`
}

type ClusterData struct {
	*clusterdump.Data
	// contains filtered or unexported fields
}

type ClusterDataSnapshotRequest struct {
	pubsub.Msg `yaml:",inline"`
	ReplyC     chan *clusterdump.Data `json:"-" yaml:"-"`
}

type ClusterStatusUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string             `json:"node" yaml:"node"`
	Value      clusterdump.Status `json:"cluster_status" yaml:"cluster_status"`
}

type ConfigFileRemoved struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
}

type ConfigFileUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
}

type DaemonCollectorUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`

	Value daemonsubsystem.Collector `json:"collector" yaml:"collector"`
}

type DaemonCtl struct {
	pubsub.Msg `yaml:",inline"`
	Component  string `json:"component" yaml:"component"`
	Action     string `json:"action" yaml:"action"`
}

type DaemonDataUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`

	Value daemonsubsystem.Daemondata `json:"daemondata" yaml:"daemondata"`
}

type DaemonDnsUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`

	Value daemonsubsystem.Dns `json:"dns" yaml:"dns"`
}

type DaemonHeartbeatUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`

	Value daemonsubsystem.Heartbeat `json:"heartbeat" yaml:"heartbeat"`
}

type DaemonListenerUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string                   `json:"node" yaml:"node"`
	Value      daemonsubsystem.Listener `json:"listener" yaml:"listener"`
}

type DaemonRunnerImonUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`

	Value daemonsubsystem.RunnerImon `json:"runner_imon" yaml:"runner_imon"`
}

type DaemonSchedulerUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`

	Value daemonsubsystem.Scheduler `json:"scheduler" yaml:"scheduler"`
}

type DaemonStatusUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	Version    string `json:"version" yaml:"version"`
	Status     string `json:"status" yaml:"status"`
}

type DrbdResourceUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	Res        string `json:"res" yaml:"res"`
}

type EnterOverloadPeriod struct {
	pubsub.Msg `yaml:",inline"`
}

type Exec struct {
	pubsub.Msg `yaml:",inline"`
	Command    string `json:"command" yaml:"command"`
	// Node is the nodename that will call exec
	Node string `json:"node" yaml:"node"`
	// Origin describes the exec caller: example: imon, nmon, scheduler...
	Origin string `json:"origin" yaml:"origin"`
	// RID is the resource the exec is of, when it is of one.
	RID string `json:"rid" yaml:"rid"`
	// StartedAt is when the publisher started the process, measured by
	// the publisher. A subscriber stamping its own arrival time instead
	// would be recording when the bus delivered the news, which is not
	// when the exec began and does not agree with its duration.
	StartedAt time.Time   `json:"started_at" yaml:"started_at"`
	Title     string      `json:"title" yaml:"title"`
	SessionID xsession.ID `json:"session_id" yaml:"session_id"`
	ExecID    xsession.ID `json:"exec_id" yaml:"exec_id"`
	// OrchestrationID is set when the exec is a step of an
	// orchestration, so the execs of one can be found together.
	OrchestrationID xsession.ID `json:"orchestration_id" yaml:"orchestration_id"`
}

type ExecFailed struct {
	pubsub.Msg `yaml:",inline"`
	Command    string        `json:"command" yaml:"command"`
	Duration   time.Duration `json:"duration" yaml:"duration"`
	ErrS       string        `json:"error" yaml:"error"`
	// ExitCode is what the process exited with, 128 + the signal number
	// when a signal ended it, and -1 when it never ran at all.
	ExitCode int `json:"exit_code" yaml:"exit_code"`
	// Node is the nodename that called exec
	Node string `json:"node" yaml:"node"`
	// Origin describes the exec caller: example: imon, nmon, scheduler...
	Origin    string      `json:"origin" yaml:"origin"`
	Title     string      `json:"title" yaml:"title"`
	SessionID xsession.ID `json:"session_id" yaml:"session_id"`
	ExecID    xsession.ID `json:"exec_id" yaml:"exec_id"`
	// OrchestrationID is set when the exec is a step of an
	// orchestration, so the sessions of one can be found together.
	OrchestrationID xsession.ID `json:"orchestration_id" yaml:"orchestration_id"`
}

type ExecSuccess struct {
	pubsub.Msg `yaml:",inline"`
	Command    string        `json:"command" yaml:"command"`
	Duration   time.Duration `json:"duration" yaml:"duration"`
	// ExitCode is what the process exited with. Usually zero, but a
	// command given WithIgnoredExitCodes succeeds with others.
	ExitCode int `json:"exit_code" yaml:"exit_code"`
	// Node is the nodename that called exec
	Node string `json:"node" yaml:"node"`
	// Origin describes the exec caller: example: imon, nmon, scheduler...
	Origin    string      `json:"origin" yaml:"origin"`
	Title     string      `json:"title" yaml:"title"`
	SessionID xsession.ID `json:"session_id" yaml:"session_id"`
	ExecID    xsession.ID `json:"exec_id" yaml:"exec_id"`
	// OrchestrationID is set when the exec is a step of an
	// orchestration, so the sessions of one can be found together.
	OrchestrationID xsession.ID `json:"orchestration_id" yaml:"orchestration_id"`
}

type Exit struct {
	Path naming.Path `json:"path" yaml:"path"`
	File string      `json:"file" yaml:"file"`
}

type FSMounted struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	MountPoint string `json:"mount_point" yaml:"mount_point"`
	FSType     string `json:"fs_type" yaml:"fs_type"`
	Source     string `json:"source" yaml:"source"`
	Options    string `json:"options" yaml:"options"`
}

type FSRemounted struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	MountPoint string `json:"mount_point" yaml:"mount_point"`
	FSType     string `json:"fs_type" yaml:"fs_type"`
	Source     string `json:"source" yaml:"source"`
	Options    string `json:"options" yaml:"options"`
}

type FSUmounted struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	MountPoint string `json:"mount_point" yaml:"mount_point"`
	FSType     string `json:"fs_type" yaml:"fs_type"`
	Source     string `json:"source" yaml:"source"`
	Options    string `json:"options" yaml:"options"`
}

type ForgetPeer struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
}

type HeartbeatAlive struct {
	pubsub.Msg `yaml:",inline"`
	Nodename   string    `json:"node" yaml:"node"`
	HbID       string    `json:"hb_id" yaml:"hb_id"`
	Time       time.Time `json:"at" yaml:"at"`
}

type HeartbeatMessageTypeUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string   `json:"node" yaml:"node"`
	From       string   `json:"old_type" yaml:"old_type"`
	To         string   `json:"new_type" yaml:"new_type"`
	Nodes      []string `json:"nodes" yaml:"nodes"`

	// JoinedNodes are nodes with hb message type patch
	JoinedNodes []string `json:"joined_nodes" yaml:"joined_nodes"`

	// InstalledGens are the current installed node gens
	InstalledGens node.Gen `json:"installed_gens" yaml:"installed_gens"`
}

type HeartbeatRotateError struct {
	pubsub.Msg `yaml:",inline"`
	ID         uuid.UUID `json:"id" yaml:"id"`
	Reason     string    `json:"reason" yaml:"reason"`
}

type HeartbeatRotateRequest struct {
	pubsub.Msg `yaml:",inline"`
	ID         uuid.UUID `json:"id" yaml:"id"`
}

type HeartbeatRotateSuccess struct {
	pubsub.Msg `yaml:",inline"`
	ID         uuid.UUID `json:"id" yaml:"id"`
}

type HeartbeatSecretUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Nodename   string          `json:"nodename" yaml:"nodename"`
	Value      hbsecret.Secret `json:"hb_secret" yaml:"hb_secret"`
}

type HeartbeatStale struct {
	pubsub.Msg `yaml:",inline"`
	Nodename   string    `json:"node" yaml:"node"`
	HbID       string    `json:"hb_id" yaml:"hb_id"`
	Time       time.Time `json:"at" yaml:"at"`
}

type InstanceActionPending struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path           `json:"path" yaml:"path"`
	Node       string                `json:"node" yaml:"node"`
	Phase      collector.ActionPhase `json:"phase" yaml:"phase"`
	Action     collector.Action      `json:"action" yaml:"action"`

	// UUID is the collector uuid of the begin, when the end is announced
	// after the begin was acknowledged.
	UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
}

type InstanceActionSent struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path           `json:"path" yaml:"path"`
	Node       string                `json:"node" yaml:"node"`
	ExecID     uuid.UUID             `json:"exec_id" yaml:"exec_id"`
	Phase      collector.ActionPhase `json:"phase" yaml:"phase"`

	// UUID is the collector uuid of the begin.
	UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
}

type InstanceConfigDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
}

type InstanceConfigDeleting struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
}

type InstanceConfigFor struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
	// Orchestrate is the config orchestrate value. it may be used by peers
	// just after installation of fetched instance config file
	Orchestrate string `json:"orchestrate" yaml:"orchestrate"`
	// Scope is the list of nodes that have to fetch this config
	Scope []string `json:"scope" yaml:"scope"`
	// UpdatedAt is the config file time stamp
	UpdatedAt time.Time `json:"updated_at" yaml:"updated_at"`
}

type InstanceConfigManagerDone struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
}

type InstanceConfigUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path     `json:"path" yaml:"path"`
	Node       string          `json:"node" yaml:"node"`
	Value      instance.Config `json:"instance_config" yaml:"instance_config"`
}

type InstanceFrozenFileRemoved struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
	At         time.Time   `json:"at" yaml:"at"`
}

type InstanceFrozenFileUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
	At         time.Time   `json:"at" yaml:"at"`

	// Scope is the scope of the freeze the flag records.
	Scope freeze.Scope `json:"scope,omitempty" yaml:"scope,omitempty"`
}

type InstanceMonitorAction struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path            `json:"path" yaml:"path"`
	Node       string                 `json:"node" yaml:"node"`
	Action     instance.MonitorAction `json:"action" yaml:"action"`
	RID        string                 `json:"rid" yaml:"rid"`
}

type InstanceMonitorDeleted struct {
	pubsub.Msg       `yaml:",inline"`
	Path             naming.Path             `json:"path" yaml:"path"`
	Node             string                  `json:"node" yaml:"node"`
	OrchestrationEnd *ObjectOrchestrationEnd `json:"orchestration_end" yaml:"orchestration_end"`
}

type InstanceMonitorUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path      `json:"path" yaml:"path"`
	Node       string           `json:"node" yaml:"node"`
	Value      instance.Monitor `json:"instance_monitor" yaml:"instance_monitor"`
}

type InstanceResourceInfoUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
	Checksum   string      `json:"checksum" yaml:"checksum"`
	UpdatedAt  time.Time   `json:"updated_at" yaml:"updated_at"`
}

type InstanceStateFileUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
	File       string      `json:"file" yaml:"file"`
}

type InstanceStatusDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
	PeerDropAt time.Time   `json:"peer_drop_at"`
}

type InstanceStatusPost struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path     `json:"path" yaml:"path"`
	Node       string          `json:"node" yaml:"node"`
	Value      instance.Status `json:"instance_status" yaml:"instance_status"`
}

type InstanceStatusUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path     `json:"path" yaml:"path"`
	Node       string          `json:"node" yaml:"node"`
	Value      instance.Status `json:"instance_status" yaml:"instance_status"`
}

type InstanceStoppedFileRemoved struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
	At         time.Time   `json:"at" yaml:"at"`
}

type InstanceStoppedFileUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
	At         time.Time   `json:"at" yaml:"at"`
}

type JoinError struct {
	pubsub.Msg `yaml:",inline"`
	// CandidateNode is the candidate node that can't be added to cluster config nodes
	CandidateNode string `json:"candidate_node" yaml:"candidate_node"`
	Reason        string `json:"reason" yaml:"reason"`
}

type JoinIgnored struct {
	pubsub.Msg `yaml:",inline"`
	// CandidateNode is a candidate node that is already present in cluster config nodes
	CandidateNode string `json:"candidate_node" yaml:"candidate_node"`
}

type JoinRequest struct {
	pubsub.Msg `yaml:",inline"`
	// CandidateNode is a candidate node to add to cluster config nodes
	CandidateNode string `json:"candidate_node" yaml:"candidate_node"`
}

type JoinSuccess struct {
	pubsub.Msg `yaml:",inline"`
	// AddedNode is a node that has been successfully added to the cluster config nodes
	// after join request or sysadmin cluster config nodes update.
	AddedNode string `json:"added_node" yaml:"added_node"`
}

type Keyer interface {
	Key() string
}

type LeaveError struct {
	pubsub.Msg `yaml:",inline"`
	// CandidateNode is a candidate node that can't be removed from cluster config nodes
	CandidateNode string `json:"candidate_node" yaml:"candidate_node"`
	Reason        string
}

type LeaveIgnored struct {
	pubsub.Msg `yaml:",inline"`
	// CandidateNode is a candidate node that is not a cluster config node
	CandidateNode string `json:"candidate_node" yaml:"candidate_node"`
}

type LeaveOverloadPeriod struct {
	pubsub.Msg `yaml:",inline"`
}

type LeaveRequest struct {
	pubsub.Msg `yaml:",inline"`
	// CandidateNode is a node to remove to cluster config nodes
	CandidateNode string `json:"candidate_node" yaml:"candidate_node"`
}

type LeaveSuccess struct {
	pubsub.Msg `yaml:",inline"`
	// RemovedNode is the successfully removed node from cluster config nodes
	RemovedNode string `json:"removed_node" yaml:"removed_node"`
}

type Log struct {
	pubsub.Msg `yaml:",inline"`
	Message    string `json:"message" yaml:"message"`
	Level      string `json:"level" yaml:"level"`
}

type NetIPAddrAdded struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	LinkIndex  int    `json:"link_index" yaml:"link_index"`
	LinkName   string `json:"link_name" yaml:"link_name"`
	Address    string `json:"address" yaml:"address"`
}

type NetIPAddrDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	LinkIndex  int    `json:"link_index" yaml:"link_index"`
	LinkName   string `json:"link_name" yaml:"link_name"`
	Address    string `json:"address" yaml:"address"`
}

type NetLinkDown struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	LinkIndex  int    `json:"link_index" yaml:"link_index"`
	LinkName   string `json:"link_name" yaml:"link_name"`
}

type NetLinkUp struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	LinkIndex  int    `json:"link_index" yaml:"link_index"`
	LinkName   string `json:"link_name" yaml:"link_name"`
}

type NodeAlive struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
}

type NodeConfigUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string      `json:"node" yaml:"node"`
	Value      node.Config `json:"node_config" yaml:"node_config"`
}

type NodeDataUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string    `json:"node" yaml:"node"`
	Value      node.Node `json:"node_data" yaml:"node_data"`
}

type NodeFrozen struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`

	// Status is true when frozen, else false
	Status bool `json:"is_frozen" yaml:"is_frozen"`

	// FrozenAt is the time when node has been frozen or zero when not frozen
	FrozenAt time.Time `json:"frozen_at" yaml:"frozen_at"`
}

type NodeFrozenFileRemoved struct {
	pubsub.Msg `yaml:",inline"`
	File       string `json:"file" yaml:"file"`
}

type NodeFrozenFileUpdated struct {
	pubsub.Msg `yaml:",inline"`
	File       string    `json:"file" yaml:"file"`
	At         time.Time `json:"at" yaml:"at"`
}

type NodeLabelsCommited struct {
	pubsub.Msg `yaml:",inline"`
	Node       string  `json:"node" yaml:"node"`
	Value      label.M `json:"node_labels" yaml:"node_labels"`
}

type NodeLabelsUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string  `json:"node" yaml:"node"`
	Value      label.M `json:"node_labels" yaml:"node_labels"`
}

type NodeMonitorDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
}

type NodeMonitorUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string       `json:"node" yaml:"node"`
	Value      node.Monitor `json:"node_monitor" yaml:"node_monitor"`
}

type NodeOrchestrationAccepted struct {
	pubsub.Msg `yaml:",inline"`
	ID         string `json:"id" yaml:"id"`
	Node       string `json:"node" yaml:"node"`
	// Expect is the state the orchestration is for. A node is asked to
	// freeze by a global expect and to drain by a local one, so this is
	// whichever of the two the request set.
	Expect                string                   `json:"expect" yaml:"expect"`
	GlobalExpect          node.MonitorGlobalExpect `json:"global_expect" yaml:"global_expect"`
	GlobalExpectUpdatedAt time.Time                `json:"global_expect_updated_at" yaml:"global_expect_updated_at"`
}

type NodeOrchestrationEnd struct {
	pubsub.Msg            `yaml:",inline"`
	ID                    string                   `json:"id" yaml:"id"`
	Node                  string                   `json:"node" yaml:"node"`
	Expect                string                   `json:"expect" yaml:"expect"`
	GlobalExpect          node.MonitorGlobalExpect `json:"global_expect" yaml:"global_expect"`
	GlobalExpectUpdatedAt time.Time                `json:"global_expect_updated_at" yaml:"global_expect_updated_at"`
	Aborted               bool                     `json:"aborted" yaml:"aborted"`

	// Failed says the orchestration gave up rather than reached what it
	// was for, and Error says what it ended on. An orchestration ends
	// either way, so the end is not the verdict by itself, and a client
	// waiting on the id would otherwise have to read the states back and
	// judge for itself.
	Failed bool   `json:"failed" yaml:"failed"`
	Error  string `json:"error,omitempty" yaml:"error,omitempty"`
}

type NodeOrchestrationRefused struct {
	pubsub.Msg   `yaml:",inline"`
	ID           string                    `json:"id" yaml:"id"`
	Node         string                    `json:"node" yaml:"node"`
	Reason       string                    `json:"reason" yaml:"reason"`
	GlobalExpect *node.MonitorGlobalExpect `json:"global_expect" yaml:"global_expect"`
}

type NodeOsPathsUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string    `json:"node" yaml:"node"`
	Value      san.Paths `json:"san_paths" yaml:"san_paths"`
}

type NodePoolStatusDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
	Name       string `json:"name" yaml:"name"`
}

type NodePoolStatusUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string      `json:"node" yaml:"node"`
	Name       string      `json:"name" yaml:"name"`
	Value      pool.Status `json:"pool_status" yaml:"pool_status"`
}

type NodeRejoin struct {
	pubsub.Msg     `yaml:",inline"`
	IsUpgrading    bool
	LastShutdownAt time.Time
	Nodes          []string
}

type NodeSplitAction struct {
	pubsub.Msg      `yaml:",inline"`
	Node            string `json:"node" yaml:"node"`
	Action          string `json:"action" yaml:"action"`
	NodeVotes       int    `json:"node_votes" yaml:"node_votes"`
	ArbitratorVotes int    `json:"arbitrator_votes" yaml:"arbitrator_votes"`
	Voting          int    `json:"voting" yaml:"voting"`
	ProVoters       int    `json:"pro_voters" yaml:"pro_voters"`
}

type NodeStale struct {
	pubsub.Msg `yaml:",inline"`
	Node       string `json:"node" yaml:"node"`
}

type NodeStatsUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string     `json:"node" yaml:"node"`
	Value      node.Stats `json:"node_stats" yaml:"node_stats"`
}

type NodeStatusArbitratorsUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string                           `json:"node" yaml:"node"`
	Value      map[string]node.ArbitratorStatus `json:"arbitrator_status" yaml:"arbitrator_status"`
}

type NodeStatusGenUpdates struct {
	pubsub.Msg `yaml:",inline"`
	Node       string
	// Value is Node.Status.Gen
	Value node.Gen `json:"gens" yaml:"gens"`
}

type NodeStatusUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Node       string      `json:"node" yaml:"node"`
	Value      node.Status `json:"node_status" yaml:"node_status"`
}

type ObjectCreated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
}

type ObjectDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
}

type ObjectOrchestrationAccepted struct {
	pubsub.Msg            `yaml:",inline"`
	ID                    string                       `json:"id" yaml:"id"`
	Node                  string                       `json:"node" yaml:"node"`
	Path                  naming.Path                  `json:"path" yaml:"path"`
	GlobalExpect          instance.MonitorGlobalExpect `json:"global_expect" yaml:"global_expect"`
	GlobalExpectUpdatedAt time.Time                    `json:"global_expect_updated_at" yaml:"global_expect_updated_at"`
}

type ObjectOrchestrationEnd struct {
	pubsub.Msg            `yaml:",inline"`
	ID                    string                       `json:"id" yaml:"id"`
	Node                  string                       `json:"node" yaml:"node"`
	Path                  naming.Path                  `json:"path" yaml:"path"`
	GlobalExpect          instance.MonitorGlobalExpect `json:"global_expect" yaml:"global_expect"`
	GlobalExpectUpdatedAt time.Time                    `json:"global_expect_updated_at" yaml:"global_expect_updated_at"`
	Aborted               bool                         `json:"aborted" yaml:"aborted"`

	// Failed says the orchestration ended with instances that did not
	// reach what it was for, and Error names them and the state they
	// ended on. An orchestration ends when every node is done with it,
	// whether it did what was asked or gave up, so the end is not the
	// verdict by itself, and a client waiting on the id would otherwise
	// have to read the instance states back and judge for itself.
	Failed bool   `json:"failed" yaml:"failed"`
	Error  string `json:"error,omitempty" yaml:"error,omitempty"`
}

type ObjectOrchestrationRefused struct {
	pubsub.Msg   `yaml:",inline"`
	ID           string                        `json:"id" yaml:"id"`
	Node         string                        `json:"node" yaml:"node"`
	Path         naming.Path                   `json:"path" yaml:"path"`
	Reason       string                        `json:"reason" yaml:"reason"`
	GlobalExpect *instance.MonitorGlobalExpect `json:"global_expect" yaml:"global_expect"`
}

type ObjectStatusDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
}

type ObjectStatusDone struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
}

type ObjectStatusUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path   `json:"path" yaml:"path"`
	Node       string        `json:"node" yaml:"node"`
	Value      object.Status `json:"object_status" yaml:"object_status"`
	SrcEv      any           `json:"source_event" yaml:"source_event"`
}

type ProgressInstanceMonitor struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path           `json:"path" yaml:"path"`
	Node       string                `json:"node" yaml:"node"`
	State      instance.MonitorState `json:"instance_monitor_state" yaml:"instance_monitor_state"`
	SessionID  xsession.ID           `json:"session_id" yaml:"session_id"`
	IsPartial  bool                  `json:"is_partial" yaml:"is_partial"`
}

type RemoteFileConfig struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
	File       string      `json:"file" yaml:"file"`

	// MarkStopped asks that the instance the fetched configuration
	// creates be flagged stopped on purpose, so the daemon does not
	// start it as soon as the configuration lands, before the operator
	// asked for anything.
	MarkStopped bool `json:"mark_stopped" yaml:"mark_stopped"`

	UpdatedAt time.Time       `json:"updated_at" yaml:"updated_at"`
	Ctx       context.Context `json:"-" yaml:"-"`
	Err       chan error      `json:"-" yaml:"-"`
}

type RunFileRemoved struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
	RID        string      `json:"rid" yaml:"rid"`
	At         time.Time   `json:"at" yaml:"at"`
}

type RunFileUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	File       string      `json:"file" yaml:"file"`
	RID        string      `json:"rid" yaml:"rid"`
	At         time.Time   `json:"at" yaml:"at"`
}

type SetInstanceMonitor struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path               `json:"path" yaml:"path"`
	Node       string                    `json:"node" yaml:"node"`
	Value      instance.MonitorUpdate    `json:"instance_monitor_update" yaml:"instance_monitor_update"`
	Err        errcontext.ErrCloseSender `json:"-" yaml:"-"`
}

type SetInstanceMonitorRefused struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path            `json:"path" yaml:"path"`
	Node       string                 `json:"node" yaml:"node"`
	Value      instance.MonitorUpdate `json:"instance_monitor_update" yaml:"instance_monitor_update"`
}

type SetNodeMonitor struct {
	pubsub.Msg `yaml:",inline"`
	Node       string                    `json:"node" yaml:"node"`
	Value      node.MonitorUpdate        `json:"node_monitor_update" yaml:"node_monitor_update"`
	Err        errcontext.ErrCloseSender `json:"-" yaml:"-"`
}

type WatchDog struct {
	pubsub.Msg `yaml:",inline"`
	Bus        string `json:"bus" yaml:"bus"`
}

type ZoneRecordDeleted struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
	Name       string      `json:"name" yaml:"name"`
	Type       string      `json:"type" yaml:"type"`
	TTL        int         `json:"ttl" yaml:"ttl"`
	Content    string      `json:"content" yaml:"content"`
}

type ZoneRecordUpdated struct {
	pubsub.Msg `yaml:",inline"`
	Path       naming.Path `json:"path" yaml:"path"`
	Node       string      `json:"node" yaml:"node"`
	Name       string      `json:"name" yaml:"name"`
	Type       string      `json:"type" yaml:"type"`
	TTL        int         `json:"ttl" yaml:"ttl"`
	Content    string      `json:"content" yaml:"content"`
}