Documentation ¶
Index ¶
- type EventsSinkController
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventsSinkController ¶ added in v0.14.0
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 ¶ added in v0.14.0
func (ctrl *EventsSinkController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*EventsSinkController) Name ¶ added in v0.14.0
func (ctrl *EventsSinkController) Name() string
Name implements controller.Controller interface.
func (*EventsSinkController) Outputs ¶ added in v0.14.0
func (ctrl *EventsSinkController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*EventsSinkController) Run ¶ added in v0.14.0
func (ctrl *EventsSinkController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) (err error)
Run implements controller.Controller interface.
type ExtensionServiceController ¶ added in v1.0.0
type ExtensionServiceController struct { V1Alpha1Services ServiceManager ConfigPath string }
ExtensionServiceController creates extension services based on the extension service configuration found in the rootfs.
func (*ExtensionServiceController) Inputs ¶ added in v1.0.0
func (ctrl *ExtensionServiceController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ExtensionServiceController) Name ¶ added in v1.0.0
func (ctrl *ExtensionServiceController) Name() string
Name implements controller.Controller interface.
func (*ExtensionServiceController) Outputs ¶ added in v1.0.0
func (ctrl *ExtensionServiceController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ExtensionServiceController) Run ¶ added in v1.0.0
func (ctrl *ExtensionServiceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type ExtensionStatusController ¶ added in v1.0.0
type ExtensionStatusController struct{}
ExtensionStatusController loads extensions.yaml and updates ExtensionStatus resources.
func (*ExtensionStatusController) Inputs ¶ added in v1.0.0
func (ctrl *ExtensionStatusController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ExtensionStatusController) Name ¶ added in v1.0.0
func (ctrl *ExtensionStatusController) Name() string
Name implements controller.Controller interface.
func (*ExtensionStatusController) Outputs ¶ added in v1.0.0
func (ctrl *ExtensionStatusController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ExtensionStatusController) Run ¶ added in v1.0.0
func (ctrl *ExtensionStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type KernelModuleConfigController ¶ added in v1.0.0
type KernelModuleConfigController struct{}
KernelModuleConfigController watches v1alpha1.Config, creates/updates/deletes kernel module specs.
func (*KernelModuleConfigController) Inputs ¶ added in v1.0.0
func (ctrl *KernelModuleConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KernelModuleConfigController) Name ¶ added in v1.0.0
func (ctrl *KernelModuleConfigController) Name() string
Name implements controller.Controller interface.
func (*KernelModuleConfigController) Outputs ¶ added in v1.0.0
func (ctrl *KernelModuleConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KernelModuleConfigController) Run ¶ added in v1.0.0
func (ctrl *KernelModuleConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type KernelModuleSpecController ¶ added in v1.0.0
type KernelModuleSpecController struct {
V1Alpha1Mode v1alpha1runtime.Mode
}
KernelModuleSpecController watches KernelModuleSpecs, sets/resets kernel params.
func (*KernelModuleSpecController) Inputs ¶ added in v1.0.0
func (ctrl *KernelModuleSpecController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KernelModuleSpecController) Name ¶ added in v1.0.0
func (ctrl *KernelModuleSpecController) Name() string
Name implements controller.Controller interface.
func (*KernelModuleSpecController) Outputs ¶ added in v1.0.0
func (ctrl *KernelModuleSpecController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KernelModuleSpecController) Run ¶ added in v1.0.0
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 ¶ added in v0.14.0
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 ¶ added in v0.14.0
func (ctrl *KmsgLogDeliveryController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*KmsgLogDeliveryController) Name ¶ added in v0.14.0
func (ctrl *KmsgLogDeliveryController) Name() string
Name implements controller.Controller interface.
func (*KmsgLogDeliveryController) Outputs ¶ added in v0.14.0
func (ctrl *KmsgLogDeliveryController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*KmsgLogDeliveryController) Run ¶ added in v0.14.0
func (ctrl *KmsgLogDeliveryController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) (err error)
Run implements controller.Controller interface.
type MachineStatusController ¶ added in v1.2.0
type MachineStatusController struct { V1Alpha1Events v1alpha1runtime.Watcher // contains filtered or unexported fields }
MachineStatusController watches MachineStatuss, sets/resets kernel params.
func (*MachineStatusController) Inputs ¶ added in v1.2.0
func (ctrl *MachineStatusController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*MachineStatusController) Name ¶ added in v1.2.0
func (ctrl *MachineStatusController) Name() string
Name implements controller.Controller interface.
func (*MachineStatusController) Outputs ¶ added in v1.2.0
func (ctrl *MachineStatusController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*MachineStatusController) Run ¶ added in v1.2.0
func (ctrl *MachineStatusController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type MachineStatusPublisherController ¶ added in v1.2.0
type MachineStatusPublisherController struct {
V1Alpha1Events v1alpha1runtime.Publisher
}
MachineStatusPublisherController watches MachineStatusPublishers, sets/resets kernel params.
func (*MachineStatusPublisherController) Inputs ¶ added in v1.2.0
func (ctrl *MachineStatusPublisherController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*MachineStatusPublisherController) Name ¶ added in v1.2.0
func (ctrl *MachineStatusPublisherController) Name() string
Name implements controller.Controller interface.
func (*MachineStatusPublisherController) Outputs ¶ added in v1.2.0
func (ctrl *MachineStatusPublisherController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*MachineStatusPublisherController) Run ¶ added in v1.2.0
func (ctrl *MachineStatusPublisherController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.