floatingip

Documentation

Index

• type Controller
  • func NewController(kubeConfig clientcmd.ClientConfig, providers *provider.Registry, ...) (*Controller, error)
  • func (c *Controller) Collect(ch chan<- prometheus.Metric)
  • func (c *Controller) Describe(ch chan<- *prometheus.Desc)
  • func (c *Controller) OnAdd(obj interface{}, _ bool)
  • func (c *Controller) OnDelete(obj interface{})
  • func (c *Controller) OnUpdate(_, newObj interface{})
  • func (c *Controller) Run(ctx context.Context)

Types

type Controller

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

Controller watches for FloatingIPPool resources and reconciles the described state into reality.

func NewController

func NewController(
	kubeConfig clientcmd.ClientConfig,
	providers *provider.Registry,
	log logrus.FieldLogger,
	promRegistry *prometheus.Registry,
) (*Controller, error)

NewController creates a new Controller.

func (*Controller) Collect

func (c *Controller) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*Controller) Describe

func (c *Controller) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector.

func (*Controller) OnAdd

func (c *Controller) OnAdd(obj interface{}, _ bool)

OnAdd implements the shared informer ResourceEventHandler for FloatingIPPools.

func (*Controller) OnDelete

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

OnDelete implements the shared informer ResourceEventHandler for FloatingIPPools.

func (*Controller) OnUpdate

func (c *Controller) OnUpdate(_, newObj interface{})

OnUpdate implements the shared informer ResourceEventHandler for FloatingIPPools.

func (*Controller) Run

func (c *Controller) Run(ctx context.Context)

Run watches for FloatingIPPools and reconciles their state into reality.