controller

Documentation

Index

• Constants
• func CreateCellOwnerRef(obj metav1.Object) *metav1.OwnerReference
• func CreateComponentOwnerRef(obj metav1.Object) *metav1.OwnerReference
• func CreateCompositeOwnerRef(obj metav1.Object) *metav1.OwnerReference
• func CreateGatewayOwnerRef(obj metav1.Object) *metav1.OwnerReference
• func CreateTokenServiceOwnerRef(obj metav1.Object) *metav1.OwnerReference
• type Controller
  • func New(r Reconciler, logger *zap.SugaredLogger, workQueueName string) *Controller
  • func (c *Controller) Enqueue(obj interface{})
  • func (c *Controller) EnqueueControllerOf(obj interface{})
  • func (c *Controller) EnqueueKey(key string)
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{})
• type ReconcileErrors
  • func (re *ReconcileErrors) Add(err error)
  • func (re *ReconcileErrors) Empty() bool
  • func (re *ReconcileErrors) Error() string
• type Reconciler

Constants

const (
	// Cellery ConfigMap
	CelleryConfigMapName = "cellery-config"

	// Istio
	IstioSidecarInjectAnnotation = "sidecar.istio.io/inject"

	// Names
	HTTPServiceName = "http"
)

Functions

func CreateCellOwnerRef

func CreateCellOwnerRef(obj metav1.Object) *metav1.OwnerReference

func CreateComponentOwnerRef

func CreateComponentOwnerRef(obj metav1.Object) *metav1.OwnerReference

func CreateCompositeOwnerRef

func CreateCompositeOwnerRef(obj metav1.Object) *metav1.OwnerReference

func CreateGatewayOwnerRef

func CreateGatewayOwnerRef(obj metav1.Object) *metav1.OwnerReference

func CreateTokenServiceOwnerRef

func CreateTokenServiceOwnerRef(obj metav1.Object) *metav1.OwnerReference

Types

type Controller

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

func New

func New(r Reconciler, logger *zap.SugaredLogger, workQueueName string) *Controller

func (*Controller) Enqueue

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

func (*Controller) EnqueueControllerOf

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

func (*Controller) EnqueueKey

func (c *Controller) EnqueueKey(key string)

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{})

type ReconcileErrors

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

func (*ReconcileErrors) Add

func (re *ReconcileErrors) Add(err error)

func (*ReconcileErrors) Empty

func (re *ReconcileErrors) Empty() bool

func (*ReconcileErrors) Error

func (re *ReconcileErrors) Error() string

type Reconciler

type Reconciler interface {
	Reconcile(key string) error
}