actuator

Documentation

Index

• func NewService(env env.Interface, log *logrus.Entry, dialer proxy.Dialer, dbg actuatorDBs, ...) *service
• type Actuator
  • func NewActuator(ctx context.Context, _env env.Interface, log *logrus.Entry, ...) (Actuator, error)
• type Runnable

Functions

func NewService

func NewService(env env.Interface, log *logrus.Entry, dialer proxy.Dialer, dbg actuatorDBs, m metrics.Emitter) *service

Types

type Actuator

type Actuator interface {
	Process(context.Context) (bool, error)
	AddMaintenanceTasks(map[string]tasks.MaintenanceTask)
}

func NewActuator

func NewActuator(
	ctx context.Context,
	_env env.Interface,
	log *logrus.Entry,
	clusterResourceID string,
	oc database.OpenShiftClusters,
	mmf database.MaintenanceManifests,
	now func() time.Time) (Actuator, error)

type Runnable

type Runnable interface {
	Run(context.Context, <-chan struct{}, chan<- struct{}) error
}