runtime

package
v1.8.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 13, 2024 License: MPL-2.0 Imports: 85 Imported by: 0

Documentation

Overview

Package runtime provides the runtime implementation.

Index

Constants

View Source 
const ImageCleanupInterval = 15 * time.Minute

ImageCleanupInterval is the interval at which the image GC controller runs.

View Source 
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, logger *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, logger *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, logger *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, logger *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, logger *zap.Logger) error

Run implements controller.Controller interface.

type ImageServiceProvider added in v1.4.1 

type ImageServiceProvider interface {
	ImageService() images.Store
	Close() error
}

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, logger *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, logger *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, logger *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, logger *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 

type KmsgLogConfigController struct {
	Cmdline *procfs.Cmdline
}

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, logger *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, logger *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, logger *zap.Logger) error

Run implements controller.Controller interface.

type MaintenanceServiceController added in v1.5.0 

type MaintenanceServiceController struct {
	SiderolinkPeerCheckFunc authz.SideroLinkPeerCheckFunc
}

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, logger *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, logger *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

View all Source files

Directories

Path Synopsis
internal
diagnostics
Package diagnostics provides Talos diagnostics specific checks.
 Package diagnostics provides Talos diagnostics specific checks.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.