Documentation ¶
Overview ¶
Package runtime provides the runtime implementation.
Index ¶
- Constants
- func WaitForDevicesReady(ctx context.Context, r controller.Runtime, nextInputs []controller.Input) error
- type CRIImageGCController
- type DevicesStatusController
- type DiagnosticsController
- type DiagnosticsLoggerController
- func (ctrl *DiagnosticsLoggerController) Inputs() []controller.Input
- func (ctrl *DiagnosticsLoggerController) Name() string
- func (ctrl *DiagnosticsLoggerController) Outputs() []controller.Output
- func (ctrl *DiagnosticsLoggerController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
- type DropUpgradeFallbackController
- func (ctrl *DropUpgradeFallbackController) Inputs() []controller.Input
- func (ctrl *DropUpgradeFallbackController) Name() string
- func (ctrl *DropUpgradeFallbackController) Outputs() []controller.Output
- func (ctrl *DropUpgradeFallbackController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
- type EventsSinkConfigController
- func (ctrl *EventsSinkConfigController) Inputs() []controller.Input
- func (ctrl *EventsSinkConfigController) Name() string
- func (ctrl *EventsSinkConfigController) Outputs() []controller.Output
- func (ctrl *EventsSinkConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) (err error)
- type EventsSinkController
- type ExtensionServiceConfigController
- func (ctrl *ExtensionServiceConfigController) Inputs() []controller.Input
- func (ctrl *ExtensionServiceConfigController) Name() string
- func (ctrl *ExtensionServiceConfigController) Outputs() []controller.Output
- func (ctrl *ExtensionServiceConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type ExtensionServiceConfigFilesController
- func (ctrl *ExtensionServiceConfigFilesController) Inputs() []controller.Input
- func (ctrl *ExtensionServiceConfigFilesController) Name() string
- func (ctrl *ExtensionServiceConfigFilesController) Outputs() []controller.Output
- func (ctrl *ExtensionServiceConfigFilesController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type ExtensionServiceController
- func (ctrl *ExtensionServiceController) Inputs() []controller.Input
- func (ctrl *ExtensionServiceController) Name() string
- func (ctrl *ExtensionServiceController) Outputs() []controller.Output
- func (ctrl *ExtensionServiceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
- type ExtensionStatusController
- type ImageServiceProvider
- type KernelModuleConfigController
- func (ctrl *KernelModuleConfigController) Inputs() []controller.Input
- func (ctrl *KernelModuleConfigController) Name() string
- func (ctrl *KernelModuleConfigController) Outputs() []controller.Output
- func (ctrl *KernelModuleConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type KernelModuleSpecController
- type KernelParamConfigController
- func (ctrl *KernelParamConfigController) Inputs() []controller.Input
- func (ctrl *KernelParamConfigController) Name() string
- func (ctrl *KernelParamConfigController) Outputs() []controller.Output
- func (ctrl *KernelParamConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type KernelParamDefaultsController
- func (ctrl *KernelParamDefaultsController) Inputs() []controller.Input
- func (ctrl *KernelParamDefaultsController) Name() string
- func (ctrl *KernelParamDefaultsController) Outputs() []controller.Output
- func (ctrl *KernelParamDefaultsController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type KernelParamSpecController
- func (ctrl *KernelParamSpecController) Inputs() []controller.Input
- func (ctrl *KernelParamSpecController) Name() string
- func (ctrl *KernelParamSpecController) Outputs() []controller.Output
- func (ctrl *KernelParamSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
- type KmsgLogConfigController
- type KmsgLogDeliveryController
- func (ctrl *KmsgLogDeliveryController) Inputs() []controller.Input
- func (ctrl *KmsgLogDeliveryController) Name() string
- func (ctrl *KmsgLogDeliveryController) Outputs() []controller.Output
- func (ctrl *KmsgLogDeliveryController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
- type MachineStatusController
- type MachineStatusPublisherController
- func (ctrl *MachineStatusPublisherController) Inputs() []controller.Input
- func (ctrl *MachineStatusPublisherController) Name() string
- func (ctrl *MachineStatusPublisherController) Outputs() []controller.Output
- func (ctrl *MachineStatusPublisherController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type MaintenanceConfigController
- func (ctrl *MaintenanceConfigController) Inputs() []controller.Input
- func (ctrl *MaintenanceConfigController) Name() string
- func (ctrl *MaintenanceConfigController) Outputs() []controller.Output
- func (ctrl *MaintenanceConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
- type MaintenanceServiceController
- func (ctrl *MaintenanceServiceController) Inputs() []controller.Input
- func (ctrl *MaintenanceServiceController) Name() string
- func (ctrl *MaintenanceServiceController) Outputs() []controller.Output
- func (ctrl *MaintenanceServiceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
- type MetaProvider
- type SecurityStateController
- type ServiceManager
- type UniqueMachineTokenController
- type WatchdogTimerConfigController
- func (ctrl *WatchdogTimerConfigController) Inputs() []controller.Input
- func (ctrl *WatchdogTimerConfigController) Name() string
- func (ctrl *WatchdogTimerConfigController) Outputs() []controller.Output
- func (ctrl *WatchdogTimerConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) (err error)
- type WatchdogTimerController
Constants ¶
const ImageCleanupInterval = 15 * time.Minute
ImageCleanupInterval is the interval at which the image GC controller runs.
const ImageGCGracePeriod = 4 * ImageCleanupInterval
ImageGCGracePeriod is the minimum age of an image before it can be deleted.
Variables ¶
This section is empty.
Functions ¶
func WaitForDevicesReady ¶ added in v1.5.0
func WaitForDevicesReady(ctx context.Context, r controller.Runtime, nextInputs []controller.Input) error
WaitForDevicesReady waits for devices to be ready.
It is a helper function for controllers.
Types ¶
type CRIImageGCController ¶ added in v1.4.1
type CRIImageGCController struct { ImageServiceProvider func() (ImageServiceProvider, error) Clock clock.Clock // contains filtered or unexported fields }
CRIImageGCController renders manifests based on templates and config/secrets.
func (*CRIImageGCController) Inputs ¶ added in v1.4.1
func (ctrl *CRIImageGCController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*CRIImageGCController) Name ¶ added in v1.4.1
func (ctrl *CRIImageGCController) Name() string
Name implements controller.Controller interface.
func (*CRIImageGCController) Outputs ¶ added in v1.4.1
func (ctrl *CRIImageGCController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*CRIImageGCController) Run ¶ added in v1.4.1
func (ctrl *CRIImageGCController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type DevicesStatusController ¶ added in v1.5.0
type DevicesStatusController struct {
V1Alpha1Mode machineruntime.Mode
}
DevicesStatusController loads extensions.yaml and updates DevicesStatus resources.
func (*DevicesStatusController) Inputs ¶ added in v1.5.0
func (ctrl *DevicesStatusController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*DevicesStatusController) Name ¶ added in v1.5.0
func (ctrl *DevicesStatusController) Name() string
Name implements controller.Controller interface.
func (*DevicesStatusController) Outputs ¶ added in v1.5.0
func (ctrl *DevicesStatusController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*DevicesStatusController) Run ¶ added in v1.5.0
func (ctrl *DevicesStatusController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type DiagnosticsController ¶ added in v1.8.0
type DiagnosticsController struct{}
DiagnosticsController analyzes state of Talos Linux system and provides warnings on common problems.
func (*DiagnosticsController) Inputs ¶ added in v1.8.0
func (ctrl *DiagnosticsController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*DiagnosticsController) Name ¶ added in v1.8.0
func (ctrl *DiagnosticsController) Name() string
Name implements controller.Controller interface.
func (*DiagnosticsController) Outputs ¶ added in v1.8.0
func (ctrl *DiagnosticsController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*DiagnosticsController) Run ¶ added in v1.8.0
func (ctrl *DiagnosticsController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type DiagnosticsLoggerController ¶ added in v1.8.0
type DiagnosticsLoggerController struct{}
DiagnosticsLoggerController logs warnings generated by DiagnosticsController.
func (*DiagnosticsLoggerController) Inputs ¶ added in v1.8.0
func (ctrl *DiagnosticsLoggerController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*DiagnosticsLoggerController) Name ¶ added in v1.8.0
func (ctrl *DiagnosticsLoggerController) Name() string
Name implements controller.Controller interface.
func (*DiagnosticsLoggerController) Outputs ¶ added in v1.8.0
func (ctrl *DiagnosticsLoggerController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*DiagnosticsLoggerController) Run ¶ added in v1.8.0
func (ctrl *DiagnosticsLoggerController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type DropUpgradeFallbackController ¶ added in v1.5.0
type DropUpgradeFallbackController struct {
MetaProvider MetaProvider
}
DropUpgradeFallbackController removes upgrade fallback key once machine reaches ready & running.
func (*DropUpgradeFallbackController) Inputs ¶ added in v1.5.0
func (ctrl *DropUpgradeFallbackController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*DropUpgradeFallbackController) Name ¶ added in v1.5.0
func (ctrl *DropUpgradeFallbackController) Name() string
Name implements controller.Controller interface.
func (*DropUpgradeFallbackController) Outputs ¶ added in v1.5.0
func (ctrl *DropUpgradeFallbackController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*DropUpgradeFallbackController) Run ¶ added in v1.5.0
func (ctrl *DropUpgradeFallbackController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type EventsSinkConfigController ¶ added in v1.5.0
type EventsSinkConfigController struct { Cmdline *procfs.Cmdline V1Alpha1Mode v1alpha1runtime.Mode }
EventsSinkConfigController generates configuration for kmsg log delivery.
func (*EventsSinkConfigController) Inputs ¶ added in v1.5.0
func (ctrl *EventsSinkConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*EventsSinkConfigController) Name ¶ added in v1.5.0
func (ctrl *EventsSinkConfigController) Name() string
Name implements controller.Controller interface.
func (*EventsSinkConfigController) Outputs ¶ added in v1.5.0
func (ctrl *EventsSinkConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*EventsSinkConfigController) Run ¶ added in v1.5.0
func (ctrl *EventsSinkConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) (err error)
Run implements controller.Controller interface.
type EventsSinkController ¶
type EventsSinkController struct { V1Alpha1Events machinedruntime.Watcher Drainer *machinedruntime.Drainer // contains filtered or unexported fields }
EventsSinkController watches events and forwards them to the events sink server if it's configured.
func (*EventsSinkController) Inputs ¶
func (ctrl *EventsSinkController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*EventsSinkController) Name ¶
func (ctrl *EventsSinkController) Name() string
Name implements controller.Controller interface.
func (*EventsSinkController) Outputs ¶
func (ctrl *EventsSinkController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*EventsSinkController) Run ¶
func (ctrl *EventsSinkController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type ExtensionServiceConfigController ¶ added in v1.7.0
type ExtensionServiceConfigController struct{}
ExtensionServiceConfigController watches v1alpha1.Config, creates/updates/deletes extension services config.
func (*ExtensionServiceConfigController) Inputs ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ExtensionServiceConfigController) Name ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigController) Name() string
Name implements controller.Controller interface.
func (*ExtensionServiceConfigController) Outputs ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ExtensionServiceConfigController) Run ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type ExtensionServiceConfigFilesController ¶ added in v1.7.0
type ExtensionServiceConfigFilesController struct { V1Alpha1Mode v1alpha1runtime.Mode ExtensionsConfigBaseDir string }
ExtensionServiceConfigFilesController writes down the config files for extension services.
func (*ExtensionServiceConfigFilesController) Inputs ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigFilesController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ExtensionServiceConfigFilesController) Name ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigFilesController) Name() string
Name implements controller.Controller interface.
func (*ExtensionServiceConfigFilesController) Outputs ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigFilesController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ExtensionServiceConfigFilesController) Run ¶ added in v1.7.0
func (ctrl *ExtensionServiceConfigFilesController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type ExtensionServiceController ¶
type ExtensionServiceController struct { V1Alpha1Services ServiceManager ConfigPath string // contains filtered or unexported fields }
ExtensionServiceController creates extension services based on the extension service configuration found in the rootfs.
func (*ExtensionServiceController) Inputs ¶
func (ctrl *ExtensionServiceController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ExtensionServiceController) Name ¶
func (ctrl *ExtensionServiceController) Name() string
Name implements controller.Controller interface.
func (*ExtensionServiceController) Outputs ¶
func (ctrl *ExtensionServiceController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ExtensionServiceController) Run ¶
func (ctrl *ExtensionServiceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type ExtensionStatusController ¶
type ExtensionStatusController struct{}
ExtensionStatusController loads extensions.yaml and updates ExtensionStatus resources.
func (*ExtensionStatusController) Inputs ¶
func (ctrl *ExtensionStatusController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ExtensionStatusController) Name ¶
func (ctrl *ExtensionStatusController) Name() string
Name implements controller.Controller interface.
func (*ExtensionStatusController) Outputs ¶
func (ctrl *ExtensionStatusController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ExtensionStatusController) Run ¶
func (ctrl *ExtensionStatusController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type ImageServiceProvider ¶ added in v1.4.1
ImageServiceProvider wraps the containerd image service.
type KernelModuleConfigController ¶
type KernelModuleConfigController struct{}
KernelModuleConfigController watches v1alpha1.Config, creates/updates/deletes kernel module specs.
func (*KernelModuleConfigController) Inputs ¶
func (ctrl *KernelModuleConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KernelModuleConfigController) Name ¶
func (ctrl *KernelModuleConfigController) Name() string
Name implements controller.Controller interface.
func (*KernelModuleConfigController) Outputs ¶
func (ctrl *KernelModuleConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KernelModuleConfigController) Run ¶
func (ctrl *KernelModuleConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type KernelModuleSpecController ¶
type KernelModuleSpecController struct {
V1Alpha1Mode v1alpha1runtime.Mode
}
KernelModuleSpecController watches KernelModuleSpecs, sets/resets kernel params.
func (*KernelModuleSpecController) Inputs ¶
func (ctrl *KernelModuleSpecController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KernelModuleSpecController) Name ¶
func (ctrl *KernelModuleSpecController) Name() string
Name implements controller.Controller interface.
func (*KernelModuleSpecController) Outputs ¶
func (ctrl *KernelModuleSpecController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KernelModuleSpecController) Run ¶
func (ctrl *KernelModuleSpecController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type KernelParamConfigController ¶
type KernelParamConfigController struct{}
KernelParamConfigController watches v1alpha1.Config, creates/updates/deletes kernel param specs.
func (*KernelParamConfigController) Inputs ¶
func (ctrl *KernelParamConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KernelParamConfigController) Name ¶
func (ctrl *KernelParamConfigController) Name() string
Name implements controller.Controller interface.
func (*KernelParamConfigController) Outputs ¶
func (ctrl *KernelParamConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KernelParamConfigController) Run ¶
func (ctrl *KernelParamConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type KernelParamDefaultsController ¶
type KernelParamDefaultsController struct {
V1Alpha1Mode v1alpha1runtime.Mode
}
KernelParamDefaultsController creates default kernel params.
func (*KernelParamDefaultsController) Inputs ¶
func (ctrl *KernelParamDefaultsController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KernelParamDefaultsController) Name ¶
func (ctrl *KernelParamDefaultsController) Name() string
Name implements controller.Controller interface.
func (*KernelParamDefaultsController) Outputs ¶
func (ctrl *KernelParamDefaultsController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KernelParamDefaultsController) Run ¶
func (ctrl *KernelParamDefaultsController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type KernelParamSpecController ¶
type KernelParamSpecController struct {
// contains filtered or unexported fields
}
KernelParamSpecController watches KernelParamSpecs, sets/resets kernel params.
func (*KernelParamSpecController) Inputs ¶
func (ctrl *KernelParamSpecController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KernelParamSpecController) Name ¶
func (ctrl *KernelParamSpecController) Name() string
Name implements controller.Controller interface.
func (*KernelParamSpecController) Outputs ¶
func (ctrl *KernelParamSpecController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KernelParamSpecController) Run ¶
func (ctrl *KernelParamSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type KmsgLogConfigController ¶ added in v1.5.0
KmsgLogConfigController generates configuration for kmsg log delivery.
func (*KmsgLogConfigController) Inputs ¶ added in v1.5.0
func (ctrl *KmsgLogConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KmsgLogConfigController) Name ¶ added in v1.5.0
func (ctrl *KmsgLogConfigController) Name() string
Name implements controller.Controller interface.
func (*KmsgLogConfigController) Outputs ¶ added in v1.5.0
func (ctrl *KmsgLogConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KmsgLogConfigController) Run ¶ added in v1.5.0
func (ctrl *KmsgLogConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) (err error)
Run implements controller.Controller interface.
type KmsgLogDeliveryController ¶
type KmsgLogDeliveryController struct { Drainer *machinedruntime.Drainer // contains filtered or unexported fields }
KmsgLogDeliveryController watches events and forwards them to the events sink server if it's configured.
func (*KmsgLogDeliveryController) Inputs ¶
func (ctrl *KmsgLogDeliveryController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KmsgLogDeliveryController) Name ¶
func (ctrl *KmsgLogDeliveryController) Name() string
Name implements controller.Controller interface.
func (*KmsgLogDeliveryController) Outputs ¶
func (ctrl *KmsgLogDeliveryController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KmsgLogDeliveryController) Run ¶
func (ctrl *KmsgLogDeliveryController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type MachineStatusController ¶
type MachineStatusController struct { V1Alpha1Events v1alpha1runtime.Watcher // contains filtered or unexported fields }
MachineStatusController watches MachineStatuss, sets/resets kernel params.
func (*MachineStatusController) Inputs ¶
func (ctrl *MachineStatusController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*MachineStatusController) Name ¶
func (ctrl *MachineStatusController) Name() string
Name implements controller.Controller interface.
func (*MachineStatusController) Outputs ¶
func (ctrl *MachineStatusController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*MachineStatusController) Run ¶
func (ctrl *MachineStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type MachineStatusPublisherController ¶
type MachineStatusPublisherController struct {
V1Alpha1Events v1alpha1runtime.Publisher
}
MachineStatusPublisherController watches MachineStatusPublishers, sets/resets kernel params.
func (*MachineStatusPublisherController) Inputs ¶
func (ctrl *MachineStatusPublisherController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*MachineStatusPublisherController) Name ¶
func (ctrl *MachineStatusPublisherController) Name() string
Name implements controller.Controller interface.
func (*MachineStatusPublisherController) Outputs ¶
func (ctrl *MachineStatusPublisherController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*MachineStatusPublisherController) Run ¶
func (ctrl *MachineStatusPublisherController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type MaintenanceConfigController ¶ added in v1.5.0
type MaintenanceConfigController struct{}
MaintenanceConfigController manages Maintenance Service config: which address it should listen on, etc.
func (*MaintenanceConfigController) Inputs ¶ added in v1.5.0
func (ctrl *MaintenanceConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*MaintenanceConfigController) Name ¶ added in v1.5.0
func (ctrl *MaintenanceConfigController) Name() string
Name implements controller.Controller interface.
func (*MaintenanceConfigController) Outputs ¶ added in v1.5.0
func (ctrl *MaintenanceConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*MaintenanceConfigController) Run ¶ added in v1.5.0
func (ctrl *MaintenanceConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type MaintenanceServiceController ¶ added in v1.5.0
type MaintenanceServiceController struct { SiderolinkPeerCheckFunc authz.SideroLinkPeerCheckFunc V1Alpha1Mode machinedruntime.Mode }
MaintenanceServiceController runs the maintenance service based on the configuration.
func (*MaintenanceServiceController) Inputs ¶ added in v1.5.0
func (ctrl *MaintenanceServiceController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*MaintenanceServiceController) Name ¶ added in v1.5.0
func (ctrl *MaintenanceServiceController) Name() string
Name implements controller.Controller interface.
func (*MaintenanceServiceController) Outputs ¶ added in v1.5.0
func (ctrl *MaintenanceServiceController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*MaintenanceServiceController) Run ¶ added in v1.5.0
func (ctrl *MaintenanceServiceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type MetaProvider ¶ added in v1.5.0
type MetaProvider interface {
Meta() machineruntime.Meta
}
MetaProvider wraps acquiring meta.
type SecurityStateController ¶ added in v1.5.0
type SecurityStateController struct {
V1Alpha1Mode machineruntime.Mode
}
SecurityStateController is a controller that updates the security state of Talos.
func (*SecurityStateController) Inputs ¶ added in v1.5.0
func (ctrl *SecurityStateController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*SecurityStateController) Name ¶ added in v1.5.0
func (ctrl *SecurityStateController) Name() string
Name implements controller.Controller interface.
func (*SecurityStateController) Outputs ¶ added in v1.5.0
func (ctrl *SecurityStateController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*SecurityStateController) Run ¶ added in v1.5.0
func (ctrl *SecurityStateController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
Run implements controller.Controller interface.
type ServiceManager ¶
type ServiceManager interface { IsRunning(id string) (system.Service, bool, error) Load(services ...system.Service) []string Stop(ctx context.Context, serviceIDs ...string) (err error) Start(serviceIDs ...string) error }
ServiceManager is the interface to the v1alpha1 services subsystems.
type UniqueMachineTokenController ¶ added in v1.6.0
type UniqueMachineTokenController = transform.Controller[*runtime.MetaLoaded, *runtime.UniqueMachineToken]
UniqueMachineTokenController provides a unique token the machine.
func NewUniqueMachineTokenController ¶ added in v1.6.0
func NewUniqueMachineTokenController() *UniqueMachineTokenController
NewUniqueMachineTokenController instanciates the controller.
type WatchdogTimerConfigController ¶ added in v1.7.0
type WatchdogTimerConfigController struct{}
WatchdogTimerConfigController generates configuration for watchdog timers.
func (*WatchdogTimerConfigController) Inputs ¶ added in v1.7.0
func (ctrl *WatchdogTimerConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*WatchdogTimerConfigController) Name ¶ added in v1.7.0
func (ctrl *WatchdogTimerConfigController) Name() string
Name implements controller.Controller interface.
func (*WatchdogTimerConfigController) Outputs ¶ added in v1.7.0
func (ctrl *WatchdogTimerConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*WatchdogTimerConfigController) Run ¶ added in v1.7.0
func (ctrl *WatchdogTimerConfigController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) (err error)
Run implements controller.Controller interface.
type WatchdogTimerController ¶ added in v1.7.0
type WatchdogTimerController struct{}
WatchdogTimerController watches v1alpha1.Config, creates/updates/deletes kernel module specs.
func (*WatchdogTimerController) Inputs ¶ added in v1.7.0
func (ctrl *WatchdogTimerController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*WatchdogTimerController) Name ¶ added in v1.7.0
func (ctrl *WatchdogTimerController) Name() string
Name implements controller.Controller interface.
func (*WatchdogTimerController) Outputs ¶ added in v1.7.0
func (ctrl *WatchdogTimerController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*WatchdogTimerController) Run ¶ added in v1.7.0
func (ctrl *WatchdogTimerController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
Source Files ¶
- cri_image_gc.go
- devices_status.go
- diagnostics.go
- diagnostics_logger.go
- drop_upgrade_fallback.go
- events_sink.go
- events_sink_config.go
- extension_service.go
- extension_service_config.go
- extension_service_config_files.go
- extension_status.go
- kernel_module_config.go
- kernel_module_spec.go
- kernel_param_config.go
- kernel_param_defaults.go
- kernel_param_spec.go
- kmsg_log.go
- kmsg_log_config.go
- machine_status.go
- machine_status_publisher.go
- maintenance_config.go
- maintenance_service.go
- runtime.go
- security_state.go
- unique_token.go
- utils.go
- watchdog_timer.go
- watchdog_timer_config.go
Directories ¶
Path | Synopsis |
---|---|
internal
|
|
diagnostics
Package diagnostics provides Talos diagnostics specific checks.
|
Package diagnostics provides Talos diagnostics specific checks. |