workmanager

Documentation

Index

• func StartWorkerRunners(log vzlog.VerrazzanoLogger) error
• type WorkerRunner
  • func NewRunner(worker spi.Worker, conf config.CommonConfig, log vzlog.VerrazzanoLogger) (WorkerRunner, error)

Functions

func StartWorkerRunners

func StartWorkerRunners(log vzlog.VerrazzanoLogger) error

StartWorkerRunners starts the workerRunner threads, each which runs a worker in a loop

Types

type WorkerRunner

type WorkerRunner interface {
	// RunWorker runs the worker use case in a loop
	RunWorker(config.CommonConfig, vzlog.VerrazzanoLogger) error

	// WorkerMetricsProvider is an interface to get prometheus metrics information for the worker to do work
	spi.WorkerMetricsProvider
}

WorkerRunner interface specifies a workerRunner that loops calling a worker

func NewRunner

func NewRunner(worker spi.Worker, conf config.CommonConfig, log vzlog.VerrazzanoLogger) (WorkerRunner, error)

NewRunner creates a new workerRunner