daemon

type MachinaMachineOperationReconciler struct {
	// contains filtered or unexported fields
}

type MachineOperation struct {
	// Name is the operation name in its source system.
	Name string

	// Kind is the requested host-local operation kind.
	Kind machinav1alpha3.OperationKind

	// Parameters contains operation-specific inputs, such as an AgentUpgrade download URL.
	Parameters map[string]string
}

type MachineOperationHandler[TGeneration comparable] func(context.Context, MachineOperationStore[TGeneration], MachineOperation) (ctrl.Result, error)

type MachineOperationHandlers map[machinav1alpha3.OperationKind]MachineOperationHandler[int64]

type MachineOperationRequestReconciler interface {
	// SetupController registers MachineOperation watches on builder.
	SetupController(*builder.TypedBuilder[Request]) *builder.TypedBuilder[Request]

	// ReconcileMachineOperation handles req, which identifies a MachineOperation
	// object queued by controller-runtime.
	ReconcileMachineOperation(context.Context, string) (ctrl.Result, error)
}

type MachineOperationResult[TGeneration comparable] struct {
	// Phase is the resulting operation phase.
	Phase machinav1alpha3.OperationPhase

	// Reason is a stable, machine-readable reason for the result.
	Reason string

	// Message is a human-readable result description.
	Message string

	// ObservedMachineGeneration records the machine generation acted on by the operation.
	ObservedMachineGeneration TGeneration
}

type MachineOperationStore[TGeneration comparable] interface {
	// MarkInProgress records that op has started execution with message as the
	// human-readable in-progress status.
	MarkInProgress(context.Context, MachineOperation, string) error

	// Finish records the terminal or non-terminal result for op. The result
	// carries the desired phase, reason, message, observed generation, and any
	// controller-runtime requeue request.
	Finish(context.Context, MachineOperation, MachineOperationResult[TGeneration]) error
}

type RepaveReconciler interface {
	// SetupController registers repave watches on builder.
	SetupController(*builder.TypedBuilder[Request]) *builder.TypedBuilder[Request]

	// ReconcileRepave handles req, which identifies a local repave trigger queued
	// by controller-runtime.
	ReconcileRepave(context.Context, string) (ctrl.Result, error)
}

type Request struct {
	// contains filtered or unexported fields
}