reconcile

Documentation

Index

• type Worker
  • func NewWorker(scope declared.Scope, syncName string, a syncerreconcile.Applier, ...) *Worker
  • func (w *Worker) Run(ctx context.Context)

Types

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker pulls objects from a work queue and passes them to its reconciler for remediation.

func NewWorker

func NewWorker(scope declared.Scope, syncName string, a syncerreconcile.Applier,
	q *queue.ObjectQueue, d *declared.Resources, fh fight.Handler) *Worker

NewWorker returns a new Worker for the given queue and declared resources.

func (*Worker) Run

func (w *Worker) Run(ctx context.Context)

Run starts the Worker pulling objects from its queue for remediation. This call blocks until the given context is cancelled.