worker

Documentation

Index

• func NewFakeWorker(queue workqueue.DelayingInterface) worker.Worker
• type FakeWorker
  • func (w *FakeWorker) CreateProbeContext(vm *vmopv1.VirtualMachine) (*context.ProbeContext, error)
  • func (w *FakeWorker) DoProbe(ctx *context.ProbeContext) error
  • func (w *FakeWorker) GetQueue() workqueue.DelayingInterface
  • func (w *FakeWorker) ProcessProbeResult(ctx *context.ProbeContext, res probe.Result, err error) error
  • func (w *FakeWorker) Reset()

Functions

func NewFakeWorker

func NewFakeWorker(queue workqueue.DelayingInterface) worker.Worker

Types

type FakeWorker

type FakeWorker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*FakeWorker) CreateProbeContext

func (w *FakeWorker) CreateProbeContext(vm *vmopv1.VirtualMachine) (*context.ProbeContext, error)

func (*FakeWorker) DoProbe

func (w *FakeWorker) DoProbe(ctx *context.ProbeContext) error

func (*FakeWorker) GetQueue

func (w *FakeWorker) GetQueue() workqueue.DelayingInterface

func (*FakeWorker) ProcessProbeResult

func (w *FakeWorker) ProcessProbeResult(ctx *context.ProbeContext, res probe.Result, err error) error

func (*FakeWorker) Reset

func (w *FakeWorker) Reset()