operator

Documentation

Index

• type AppMetricsDbPruner
  • func NewAppMetricsDbPruner(appMetricsDb db.AppMetricDB, cutoffDuration time.Duration, clock clock.Clock, ...) *AppMetricsDbPruner
  • func (amdp AppMetricsDbPruner) Operate()
• type ApplicationSynchronizer
  • func NewApplicationSynchronizer(cfClient cf.CFClient, policyDb db.PolicyDB, logger lager.Logger) *ApplicationSynchronizer
  • func (as ApplicationSynchronizer) Operate()
• type InstanceMetricsDbPruner
  • func NewInstanceMetricsDbPruner(instanceMetricsDb db.InstanceMetricsDB, cutoffDuration time.Duration, ...) *InstanceMetricsDbPruner
  • func (idp InstanceMetricsDbPruner) Operate()
• type Operator
• type OperatorRunner
  • func NewOperatorRunner(operator Operator, interval time.Duration, clock clock.Clock, ...) *OperatorRunner
  • func (opr *OperatorRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type ScalingEngineDbPruner
  • func NewScalingEngineDbPruner(scalingEngineDb db.ScalingEngineDB, cutoffDuration time.Duration, ...) *ScalingEngineDbPruner
  • func (sdp ScalingEngineDbPruner) Operate()
• type ScheduleSynchronizer
  • func NewScheduleSynchronizer(client *http.Client, url string, clock clock.Clock, logger lager.Logger) *ScheduleSynchronizer
  • func (s ScheduleSynchronizer) Operate()

Types

type AppMetricsDbPruner

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

func NewAppMetricsDbPruner

func NewAppMetricsDbPruner(appMetricsDb db.AppMetricDB, cutoffDuration time.Duration, clock clock.Clock, logger lager.Logger) *AppMetricsDbPruner

func (AppMetricsDbPruner) Operate

func (amdp AppMetricsDbPruner) Operate()

type ApplicationSynchronizer

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

func NewApplicationSynchronizer

func NewApplicationSynchronizer(cfClient cf.CFClient, policyDb db.PolicyDB, logger lager.Logger) *ApplicationSynchronizer

func (ApplicationSynchronizer) Operate

func (as ApplicationSynchronizer) Operate()

type InstanceMetricsDbPruner

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

func NewInstanceMetricsDbPruner

func NewInstanceMetricsDbPruner(instanceMetricsDb db.InstanceMetricsDB, cutoffDuration time.Duration, clock clock.Clock, logger lager.Logger) *InstanceMetricsDbPruner

func (InstanceMetricsDbPruner) Operate

func (idp InstanceMetricsDbPruner) Operate()

type Operator

type Operator interface {
	Operate()
}

type OperatorRunner

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

func NewOperatorRunner

func NewOperatorRunner(operator Operator, interval time.Duration, clock clock.Clock, logger lager.Logger) *OperatorRunner

func (*OperatorRunner) Run

func (opr *OperatorRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type ScalingEngineDbPruner

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

func NewScalingEngineDbPruner

func NewScalingEngineDbPruner(scalingEngineDb db.ScalingEngineDB, cutoffDuration time.Duration, clock clock.Clock, logger lager.Logger) *ScalingEngineDbPruner

func (ScalingEngineDbPruner) Operate

func (sdp ScalingEngineDbPruner) Operate()

type ScheduleSynchronizer

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

func NewScheduleSynchronizer

func NewScheduleSynchronizer(client *http.Client, url string, clock clock.Clock, logger lager.Logger) *ScheduleSynchronizer

func (ScheduleSynchronizer) Operate

func (s ScheduleSynchronizer) Operate()