worker

Documentation

Index

• type Worker
  • func NewReadinessWorker(queue workqueue.DelayingInterface, prober *probe.Prober, client client.Client, ...) Worker

Types

type Worker

type Worker interface {
	GetQueue() workqueue.DelayingInterface
	CreateProbeContext(vm *vmopv1.VirtualMachine) (*context.ProbeContext, error)
	DoProbe(ctx *context.ProbeContext) error
	ProcessProbeResult(ctx *context.ProbeContext, res probe.Result, resErr error) error
}

Worker represents a prober worker interface.

func NewReadinessWorker

func NewReadinessWorker(
	queue workqueue.DelayingInterface,
	prober *probe.Prober,
	client client.Client,
	recorder vmoprecord.Recorder,
) Worker

NewReadinessWorker creates a new readiness worker to run readiness probes.