controller

Documentation

Index

• Constants
• type Controller
  • func New(kubeclientset kubernetes.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
  • func (c *Controller) SetConfigMapSynced(value cache.InformerSynced)
  • func (c *Controller) SetRecorder(r record.EventRecorder)
  • func (c *Controller) SyncHandler(key string) error

Constants

const (
	SuccessSynced             = "Synced"
	MessageResourceSynced     = "configMap synced successfully"
	ErrCallingURL             = "Fail to retrieve message from URL"
	ErrParsingAnnotationValue = "Cannot parse x-k8s.io/curl-me-that annotation value"
)

Event messages

Types

type Controller

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

Controller struct for curlme controller

func New

func New(
	kubeclientset kubernetes.Interface,
	configMapInformer cmInformer.ConfigMapInformer) *Controller

New initiate a new controller

func (*Controller) Run

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

Run start controller reconciliation loop

func (*Controller) SetConfigMapSynced

func (c *Controller) SetConfigMapSynced(value cache.InformerSynced)

SetConfigMapSynced setter for cache synced

func (*Controller) SetRecorder

func (c *Controller) SetRecorder(r record.EventRecorder)

SetRecorder setter for recorder

func (*Controller) SyncHandler

func (c *Controller) SyncHandler(key string) error

SyncHandler reconciliation loop