Documentation
¶
Index ¶
- func EnableDaemon(log *slog.Logger) phases.Task
- func PersistAppliedConfig(log *slog.Logger, machineName string, cfg *config.AgentConfig) phases.Task
- func RecordAgentUpgradeFailureSignal(message string) error
- func RemoveAgentArtifacts(log *slog.Logger) phases.Task
- func RemoveAppliedConfig(log *slog.Logger, machineName string) phases.Task
- func RemoveDaemonUnit(log *slog.Logger) phases.Task
- func ResetAgentResources(log *slog.Logger) phases.Task
- func Run(ctx context.Context, log *slog.Logger) error
- func StopDaemon(log *slog.Logger) phases.Task
- type ActiveMachine
- type BootstrapStatusReporter
- type HostDaemonActivationService
- func (s *HostDaemonActivationService) Preflight(_ context.Context, currentBinaryPath string) (agentbinary.ServicePlan, error)
- func (s *HostDaemonActivationService) Prepare(_ context.Context, currentBinaryPath string) error
- func (s *HostDaemonActivationService) Reload(ctx context.Context) error
- func (s *HostDaemonActivationService) Restart(ctx context.Context) error
- func (s *HostDaemonActivationService) WaitHealthy(ctx context.Context, expectedBinaryPath string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnableDaemon ¶ added in v0.1.1
EnableDaemon returns a task that installs, enables, and starts the unbounded-agent-daemon systemd unit on the host. The unit runs "unbounded-agent daemon" which watches the Machine CR for this node and reconciles the local state to match.
func PersistAppliedConfig ¶ added in v0.1.1
func PersistAppliedConfig(log *slog.Logger, machineName string, cfg *config.AgentConfig) phases.Task
PersistAppliedConfig returns a task that writes the agent config to the applied config file for the nspawn machine. The daemon reads this file on startup to detect configuration drift.
func RecordAgentUpgradeFailureSignal ¶ added in v0.1.4
RecordAgentUpgradeFailureSignal records that the daemon failed after an AgentUpgrade.
func RemoveAgentArtifacts ¶ added in v0.1.1
RemoveAgentArtifacts returns a task that removes the agent binary, install script, legacy uninstall script, config directory, and temp files.
func RemoveAppliedConfig ¶ added in v0.1.1
RemoveAppliedConfig returns a task that removes the applied agent config file and its checksum sidecar for the named machine. Errors are logged but do not fail the task.
func RemoveDaemonUnit ¶ added in v0.1.4
RemoveDaemonUnit returns a task that disables and removes the unbounded-agent-daemon systemd unit without stopping the running service.
func ResetAgentResources ¶ added in v0.1.4
ResetAgentResources returns a task that removes the unbounded-agent and all associated resources without stopping the daemon process.
Types ¶
type ActiveMachine ¶
type ActiveMachine struct {
Name string
Config *provision.AgentConfig
}
ActiveMachine holds the currently active nspawn machine name and its applied agent configuration.
type BootstrapStatusReporter ¶ added in v0.1.20
type BootstrapStatusReporter struct {
// contains filtered or unexported fields
}
BootstrapStatusReporter publishes the agent's initial bootstrap progress to the Machine status. It is best-effort so bootstrap can continue when the cluster is temporarily unavailable or RBAC has not been updated yet.
func NewBootstrapStatusReporter ¶ added in v0.1.20
func NewBootstrapStatusReporter(ctx context.Context, log *slog.Logger, cfg *provision.AgentConfig) *BootstrapStatusReporter
NewBootstrapStatusReporter builds a best-effort Machine status reporter from bootstrap credentials in cfg. When credentials are incomplete, the returned reporter logs and skips updates.
func (*BootstrapStatusReporter) Failed ¶ added in v0.1.20
func (r *BootstrapStatusReporter) Failed(ctx context.Context, reason string, err error)
Failed reports that initial bootstrap failed.
func (*BootstrapStatusReporter) Running ¶ added in v0.1.20
func (r *BootstrapStatusReporter) Running(ctx context.Context)
Running reports that initial bootstrap is in progress.
func (*BootstrapStatusReporter) Succeeded ¶ added in v0.1.20
func (r *BootstrapStatusReporter) Succeeded(ctx context.Context)
Succeeded reports that initial bootstrap completed successfully.
type HostDaemonActivationService ¶ added in v0.2.3
type HostDaemonActivationService struct {
// contains filtered or unexported fields
}
HostDaemonActivationService manages the Unbounded systemd units used by a host-driven agent binary activation.
func NewHostDaemonActivationService ¶ added in v0.2.3
func NewHostDaemonActivationService(log *slog.Logger, paths goalstates.AgentUpgradePaths) *HostDaemonActivationService
NewHostDaemonActivationService returns the Unbounded systemd adapter for host-driven agent activation.
func (*HostDaemonActivationService) Preflight ¶ added in v0.2.3
func (s *HostDaemonActivationService) Preflight(_ context.Context, currentBinaryPath string) (agentbinary.ServicePlan, error)
Preflight reports whether the installed daemon assets differ from the desired assets. It does not change the host.
func (*HostDaemonActivationService) Prepare ¶ added in v0.2.3
func (s *HostDaemonActivationService) Prepare(_ context.Context, currentBinaryPath string) error
Prepare installs the daemon service, recovery service, and recovery script. It does not reload systemd or restart the daemon.
func (*HostDaemonActivationService) Reload ¶ added in v0.2.3
func (s *HostDaemonActivationService) Reload(ctx context.Context) error
Reload reloads systemd configuration.
func (*HostDaemonActivationService) Restart ¶ added in v0.2.3
func (s *HostDaemonActivationService) Restart(ctx context.Context) error
Restart restarts the Unbounded daemon synchronously.
func (*HostDaemonActivationService) WaitHealthy ¶ added in v0.2.3
func (s *HostDaemonActivationService) WaitHealthy(ctx context.Context, expectedBinaryPath string) error
WaitHealthy waits until systemd reports a stable daemon process executing the expected binary target.
Source Files