reconciler

Documentation

Index

• Constants
• type Controller
  • func NewController(name string, queue workqueue.RateLimitingInterface) *Controller
  • func (c *Controller) Enqueue(obj interface{})
  • func (c *Controller) EnqueueAfter(obj interface{}, dur time.Duration)
  • func (c *Controller) Start(ctx context.Context, numThreads int)
• type ControllerConfig
  • func (c *ControllerConfig) GetName(defaultName string) string

Constants

const (
	WorkQueueSubsystem         = "workqueue"
	DepthKey                   = "depth"
	AddsKey                    = "adds_total"
	QueueLatencyKey            = "queue_duration_seconds"
	WorkDurationKey            = "work_duration_seconds"
	UnfinishedWorkKey          = "unfinished_work_seconds"
	LongestRunningProcessorKey = "longest_running_processor_seconds"
	RetriesKey                 = "retries_total"
)

Metrics subsystem and all keys used by the workqueue.

const LABEL_HCG_MANAGED = "kuadrant.dev/hcg.managed"

Types

type Controller

type Controller struct {
	Name    string
	Queue   workqueue.RateLimitingInterface
	Process func(context.Context, string) error
	Logger  logr.Logger
}

func NewController

func NewController(name string, queue workqueue.RateLimitingInterface) *Controller

func (*Controller) Enqueue

func (c *Controller) Enqueue(obj interface{})

func (*Controller) EnqueueAfter

func (c *Controller) EnqueueAfter(obj interface{}, dur time.Duration)

func (*Controller) Start

func (c *Controller) Start(ctx context.Context, numThreads int)

type ControllerConfig

type ControllerConfig struct {
	NameSuffix string
}

func (*ControllerConfig) GetName

func (c *ControllerConfig) GetName(defaultName string) string