runtime

package
v1.12.2 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2026 License: MPL-2.0 Imports: 100 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 BootedEntryController added in v1.11.0 

type BootedEntryController struct {
	V1Alpha1Mode machineruntime.Mode
}

BootedEntryController is a controller that updates the booted entry resource.

func (*BootedEntryController) Inputs added in v1.11.0 

func (ctrl *BootedEntryController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*BootedEntryController) Name added in v1.11.0 

func (ctrl *BootedEntryController) Name() string

Name implements controller.Controller interface.

func (*BootedEntryController) Outputs added in v1.11.0 

func (ctrl *BootedEntryController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*BootedEntryController) Run added in v1.11.0 

func (ctrl *BootedEntryController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error

Run implements controller.Controller interface.

type CRIImageGCController added in v1.4.1 

type CRIImageGCController struct {
	ImageServiceProvider func() (ImageServiceProvider, error)
	// 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 

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

ImageServiceProvider wraps the containerd image service.

type KernelCmdlineController added in v1.11.0 

type KernelCmdlineController struct {
	V1Alpha1Mode machineruntime.Mode
}

KernelCmdlineController presents /proc/cmdline as a resource.

func (*KernelCmdlineController) Inputs added in v1.11.0 

func (ctrl *KernelCmdlineController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*KernelCmdlineController) Name added in v1.11.0 

func (ctrl *KernelCmdlineController) Name() string

Name implements controller.Controller interface.

func (*KernelCmdlineController) Outputs added in v1.11.0 

func (ctrl *KernelCmdlineController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*KernelCmdlineController) Run added in v1.11.0 

func (ctrl *KernelCmdlineController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error

Run implements controller.Controller interface.

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 

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, _ *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 KmsgLogStorageController added in v1.12.0 

type KmsgLogStorageController struct {
	V1Alpha1Logging runtime.LoggingManager
	V1Alpha1Mode    runtime.Mode
}

KmsgLogStorageController presents kernel message log as a 'kernel' log.

func (*KmsgLogStorageController) Inputs added in v1.12.0 

func (ctrl *KmsgLogStorageController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*KmsgLogStorageController) Name added in v1.12.0 

func (ctrl *KmsgLogStorageController) Name() string

Name implements controller.Controller interface.

func (*KmsgLogStorageController) Outputs added in v1.12.0 

func (ctrl *KmsgLogStorageController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*KmsgLogStorageController) Run added in v1.12.0 

func (ctrl *KmsgLogStorageController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type LoadedKernelModuleController added in v1.11.0 

type LoadedKernelModuleController struct {
	V1Alpha1Mode machineruntime.Mode
}

LoadedKernelModuleController presents /proc/modules as a resource.

func (*LoadedKernelModuleController) Inputs added in v1.11.0 

func (ctrl *LoadedKernelModuleController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*LoadedKernelModuleController) Name added in v1.11.0 

func (ctrl *LoadedKernelModuleController) Name() string

Name implements controller.Controller interface.

func (*LoadedKernelModuleController) Outputs added in v1.11.0 

func (ctrl *LoadedKernelModuleController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*LoadedKernelModuleController) Run added in v1.11.0 

func (ctrl *LoadedKernelModuleController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error

Run implements controller.Controller interface.

type LogPersistenceController added in v1.12.0 

type LogPersistenceController struct {
	V1Alpha1Logging runtime.LoggingManager
	// contains filtered or unexported fields
}

LogPersistenceController is a controller that persists logs in files.

func (*LogPersistenceController) Inputs added in v1.12.0 

func (ctrl *LogPersistenceController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*LogPersistenceController) Name added in v1.12.0 

func (ctrl *LogPersistenceController) Name() string

Name implements controller.Controller interface.

func (*LogPersistenceController) Outputs added in v1.12.0 

func (ctrl *LogPersistenceController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*LogPersistenceController) Run added in v1.12.0 

func (ctrl *LogPersistenceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

func (*LogPersistenceController) WriteLog added in v1.12.0 

func (ctrl *LogPersistenceController) WriteLog(id string, line []byte) error

WriteLog writes a single log line into the corresponding file.

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 Module added in v1.11.0 

type Module struct {
	Name           string
	Size           int
	ReferenceCount int
	Dependencies   []string
	State          string
	Address        string
}

Module represents a kernel module parsed from /proc/modules.

func ParseModules added in v1.11.0 

func ParseModules(r io.Reader) ([]Module, error)

ParseModules parses the contents of /proc/modules from the given reader and returns a slice of module structs representing each loaded kernel module.

type MountStatusController added in v1.10.0 

type MountStatusController struct{}

MountStatusController transforms block.MountStatus resources into legacy v1alpha1.MountStatus.

It only exists to provide backwards compatibility with legacy consumers.

func (*MountStatusController) Inputs added in v1.10.0 

func (ctrl *MountStatusController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*MountStatusController) Name added in v1.10.0 

func (ctrl *MountStatusController) Name() string

Name implements controller.Controller interface.

func (*MountStatusController) Outputs added in v1.10.0 

func (ctrl *MountStatusController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*MountStatusController) Run added in v1.10.0 

func (ctrl *MountStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type OOMController added in v1.12.0 

type OOMController struct {
	CgroupRoot      string
	ActionTriggered time.Time
	V1Alpha1Mode    runtime.Mode
	// contains filtered or unexported fields
}

OOMController is a controller that monitors memory PSI and handles near-OOM situations.

func (*OOMController) Inputs added in v1.12.0 

func (ctrl *OOMController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*OOMController) Name added in v1.12.0 

func (ctrl *OOMController) Name() string

Name implements controller.Controller interface.

func (*OOMController) OomAction added in v1.12.0 

func (ctrl *OOMController) OomAction(logger *zap.Logger, root string, scoringExpr cel.Expression) (float64, []string)

OomAction handles out of memory conditions by selecting and killing cgroups based on memory usage data.

func (*OOMController) Outputs added in v1.12.0 

func (ctrl *OOMController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*OOMController) Run added in v1.12.0 

func (ctrl *OOMController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type SBOMItemController added in v1.11.0 

type SBOMItemController struct {
	SPDXPath          string
	ExtensionSPDXPath string
}

SBOMItemController is a controller that publishes Talos SBOMs as resources.

func (*SBOMItemController) Inputs added in v1.11.0 

func (ctrl *SBOMItemController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*SBOMItemController) Name added in v1.11.0 

func (ctrl *SBOMItemController) Name() string

Name implements controller.Controller interface.

func (*SBOMItemController) Outputs added in v1.11.0 

func (ctrl *SBOMItemController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*SBOMItemController) Run added in v1.11.0 

func (ctrl *SBOMItemController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

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 struct{}

UniqueMachineTokenController is a controller that manages SideroLink unique token.

func (*UniqueMachineTokenController) Inputs added in v1.10.0 

func (ctrl *UniqueMachineTokenController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*UniqueMachineTokenController) Name added in v1.10.0 

func (ctrl *UniqueMachineTokenController) Name() string

Name implements controller.Controller interface.

func (*UniqueMachineTokenController) Outputs added in v1.10.0 

func (ctrl *UniqueMachineTokenController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*UniqueMachineTokenController) Run added in v1.10.0 

func (ctrl *UniqueMachineTokenController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error

Run implements controller.Controller interface.

type VersionController added in v1.10.0 

type VersionController struct{}

VersionController populates the version of currently running Talos.

func (*VersionController) Inputs added in v1.10.0 

func (ctrl *VersionController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*VersionController) Name added in v1.10.0 

func (ctrl *VersionController) Name() string

Name implements controller.Controller interface.

func (*VersionController) Outputs added in v1.10.0 

func (ctrl *VersionController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*VersionController) Run added in v1.10.0 

func (ctrl *VersionController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

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

View all Source files

Directories

Path Synopsis
internal
diagnostics
Package diagnostics provides Talos diagnostics specific checks.
 Package diagnostics provides Talos diagnostics specific checks.
filehash
Package filehash implements a specialized file watcher that detects changes in pseudo-files like /proc/modules.
 Package filehash implements a specialized file watcher that detects changes in pseudo-files like /proc/modules.
logfile
Package logfile implements a buffered, rotating log file.
 Package logfile implements a buffered, rotating log file.
oom
Package oom contains utilities for OOM handler.
 Package oom contains utilities for OOM handler.

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.