ingressmonitor

Documentation

Index

• type Operator
  • func NewOperator(kc kubernetes.Interface, imc versioned.Interface, namespace string, ...) (*Operator, error)
  • func (o *Operator) OnAdd(obj interface{})
  • func (o *Operator) OnDelete(obj interface{})
  • func (o *Operator) OnUpdate(old, new interface{})
  • func (o *Operator) Run(stopCh <-chan struct{}) error

Types

type Operator

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

Operator is the operator that handles configuring the Monitors.

func NewOperator

func NewOperator(
	kc kubernetes.Interface, imc versioned.Interface,
	namespace string, resync time.Duration,
	providerFactory provider.FactoryInterface,
	mtrcs *metrics.Metrics) (*Operator, error)

NewOperator sets up a new IngressMonitor Operator which will watch for providers and monitors.

func (*Operator) OnAdd

func (o *Operator) OnAdd(obj interface{})

OnAdd handles adding of IngressMonitors and Ingresses and sets up the appropriate monitor with the configured providers.

func (*Operator) OnDelete

func (o *Operator) OnDelete(obj interface{})

OnDelete handles deletion of IngressMonitors and Ingresses and deletes monitors from the configured providers.

func (*Operator) OnUpdate

func (o *Operator) OnUpdate(old, new interface{})

OnUpdate handles updates of IngressMonitors anad Ingresses and configures the checks with the configured providers.

func (*Operator) Run

func (o *Operator) Run(stopCh <-chan struct{}) error

Run starts the Operator and blocks until a message is received on stopCh.