runtime

Documentation

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

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