actuator

package
v0.0.0-...-c8bead7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 14, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DetermineBuckets 

func DetermineBuckets(env env.Core, hostnameFunc func() (string, error)) []int

DetermineBuckets uses the hostname to figure out which subset of buckets we should be serving.

func NewService 

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

Types

type Actuator 

type Actuator interface {
	Process(context.Context) (bool, error)
	AddMaintenanceTasks(map[api.MIMOTaskID]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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.