controller

Documentation

Overview

Package controller contains implementation and defition to create kubernetes controllers.

Index

• type Controller
  • func NewConcurrent(concurrentWorkers int, resync time.Duration, handler handler.Handler, ...) (Controller, error)
  • func NewSequential(resync time.Duration, handler handler.Handler, retriever retrieve.Retriever, ...) Controller

Types

type Controller

type Controller interface {
	// Run runs the controller, it receives a channel that when receiving a signal it will stop the controller,
	// Run will block until it's stopped.
	Run(stopper <-chan struct{}) error
}

Controller is the object that will implement the different kinds of controllers that will be running on the application.

func NewConcurrent

func NewConcurrent(concurrentWorkers int, resync time.Duration, handler handler.Handler, retriever retrieve.Retriever, metricRecorder metrics.Recorder, logger log.Logger) (Controller, error)

NewConcurrent creates a new controller that will process the received events concurrently.

func NewSequential

func NewSequential(resync time.Duration, handler handler.Handler, retriever retrieve.Retriever, metricRecorder metrics.Recorder, logger log.Logger) Controller

NewSequential creates a new controller that will process the received events sequentially.