runtime

Documentation

Overview

Package runtime provides the runtime implementation.

Index

• type EventsSinkController
  • func (ctrl *EventsSinkController) Inputs() []controller.Input
  • func (ctrl *EventsSinkController) Name() string
  • func (ctrl *EventsSinkController) Outputs() []controller.Output
  • func (ctrl *EventsSinkController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) (err 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
  • func (ctrl *ExtensionStatusController) Inputs() []controller.Input
  • func (ctrl *ExtensionStatusController) Name() string
  • func (ctrl *ExtensionStatusController) Outputs() []controller.Output
  • func (ctrl *ExtensionStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
• 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, logger *zap.Logger) error
• type KernelModuleSpecController
  • func (ctrl *KernelModuleSpecController) Inputs() []controller.Input
  • func (ctrl *KernelModuleSpecController) Name() string
  • func (ctrl *KernelModuleSpecController) Outputs() []controller.Output
  • func (ctrl *KernelModuleSpecController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
• 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, logger *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, logger *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 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) (err error)
• type MachineStatusController
  • func (ctrl *MachineStatusController) Inputs() []controller.Input
  • func (ctrl *MachineStatusController) Name() string
  • func (ctrl *MachineStatusController) Outputs() []controller.Output
  • func (ctrl *MachineStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
• 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, logger *zap.Logger) error
• type ServiceManager

Types

type EventsSinkController

type EventsSinkController struct {
	V1Alpha1Events runtime.Watcher
	Cmdline        *procfs.Cmdline
	Drainer        *runtime.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) (err error)

Run implements controller.Controller interface.

type ExtensionServiceController

type ExtensionServiceController struct {
	V1Alpha1Services ServiceManager
	ConfigPath       string
}

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 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 KmsgLogDeliveryController

type KmsgLogDeliveryController struct {
	Cmdline *procfs.Cmdline
	Drainer *runtime.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) (err 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 ServiceManager

type ServiceManager interface {
	Load(services ...system.Service) []string
	Start(serviceIDs ...string) error
}

ServiceManager is the interface to the v1alpha1 services subsystems.