Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DelayingInterface ¶ added in v1.9.0
type DelayingInterface = workqueue.TypedDelayingInterface[any]
type Worker ¶
type Worker interface {
GetQueue() 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( context context.Context, queue DelayingInterface, prober *probe.Prober, client client.Client, recorder vmoprecord.Recorder, ) Worker
NewReadinessWorker creates a new readiness worker to run readiness probes.
Click to show internal directories.
Click to hide internal directories.