podscaler

Documentation

Index

• func Module() fx.Option
• func NewConfigSyncOptions(podScalerProto *policylangv1.PodScaler, componentID runtime.ComponentID, ...) (fx.Option, error)
• func NewScaleActuatorAndOptions(scaleActuatorProto *policyprivatev1.PodScaleActuator, _ runtime.ComponentID, ...) (runtime.Component, fx.Option, error)
• func NewScaleReporterAndOptions(podScaleReporterProto *policyprivatev1.PodScaleReporter, _ runtime.ComponentID, ...) (runtime.Component, fx.Option, error)
• func ParsePodScaler(podScaler *policylangv1.PodScaler, componentID runtime.ComponentID, ...) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)
• type ScaleActuator
  • func (sa *ScaleActuator) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
  • func (sa *ScaleActuator) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)
  • func (*ScaleActuator) IsActuator() bool
  • func (*ScaleActuator) Name() string
  • func (sa *ScaleActuator) ShortDescription() string
  • func (*ScaleActuator) Type() runtime.ComponentType
• type ScaleReporter
  • func (sr *ScaleReporter) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
  • func (sr *ScaleReporter) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)
  • func (*ScaleReporter) IsActuator() bool
  • func (*ScaleReporter) Name() string
  • func (sr *ScaleReporter) ShortDescription() string
  • func (sr *ScaleReporter) Type() runtime.ComponentType

Functions

func Module

func Module() fx.Option

Module returns the fx options for horizontal pod scaler in the main app.

func NewConfigSyncOptions

func NewConfigSyncOptions(
	podScalerProto *policylangv1.PodScaler,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (fx.Option, error)

NewConfigSyncOptions creates fx options for syncing PodScaler with an agent group.

func NewScaleActuatorAndOptions

func NewScaleActuatorAndOptions(
	scaleActuatorProto *policyprivatev1.PodScaleActuator,
	_ runtime.ComponentID,
	policyReadAPI iface.Policy,
) (runtime.Component, fx.Option, error)

NewScaleActuatorAndOptions creates scale actuator and its fx options.

func NewScaleReporterAndOptions

func NewScaleReporterAndOptions(
	podScaleReporterProto *policyprivatev1.PodScaleReporter,
	_ runtime.ComponentID,
	policyReadAPI iface.Policy,
) (runtime.Component, fx.Option, error)

NewScaleReporterAndOptions returns a new ScaleReporter and its fx options.

func ParsePodScaler

func ParsePodScaler(
	podScaler *policylangv1.PodScaler,
	componentID runtime.ComponentID,
	_ iface.Policy,
) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)

ParsePodScaler parses a PodScaler component and returns its nested circuit representation.

Types

type ScaleActuator

type ScaleActuator struct {
	// contains filtered or unexported fields
}

ScaleActuator struct.

func (*ScaleActuator) DynamicConfigUpdate

func (sa *ScaleActuator) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)

DynamicConfigUpdate implements runtime.Component.DynamicConfigUpdate.

func (*ScaleActuator) Execute

func (sa *ScaleActuator) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)

Execute implements runtime.Component.Execute.

func (*ScaleActuator) IsActuator

func (*ScaleActuator) IsActuator() bool

IsActuator implements runtime.Component.

func (*ScaleActuator) Name

func (*ScaleActuator) Name() string

Name implements runtime.Component.

func (*ScaleActuator) ShortDescription

func (sa *ScaleActuator) ShortDescription() string

ShortDescription implements runtime.Component.

func (*ScaleActuator) Type

func (*ScaleActuator) Type() runtime.ComponentType

Type implements runtime.Component.

type ScaleReporter

type ScaleReporter struct {
	// contains filtered or unexported fields
}

ScaleReporter struct.

func (*ScaleReporter) DynamicConfigUpdate

func (sr *ScaleReporter) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)

DynamicConfigUpdate is a no-op for this component.

func (*ScaleReporter) Execute

func (sr *ScaleReporter) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)

Execute implements runtime.Component.

func (*ScaleReporter) IsActuator

func (*ScaleReporter) IsActuator() bool

IsActuator implements runtime.Component.

func (*ScaleReporter) Name

func (*ScaleReporter) Name() string

Name implements runtime.Component.Name.

func (*ScaleReporter) ShortDescription

func (sr *ScaleReporter) ShortDescription() string

ShortDescription implements runtime.Component.ShortDescription.

func (*ScaleReporter) Type

func (sr *ScaleReporter) Type() runtime.ComponentType

Type implements runtime.Component.Type.