speaker

Documentation

Overview

Package speaker abstracts the BGP speaker controller from MetalLB. This package provides BGP announcements based on K8s object event handling.

Index

• type Speaker
  • func New() *Speaker
  • func (s *Speaker) OnDeleteService(svc *slim_corev1.Service)
  • func (s *Speaker) OnUpdateEndpoints(eps *slim_corev1.Endpoints)
  • func (s *Speaker) OnUpdateNode(node *v1.Node)
  • func (s *Speaker) OnUpdateService(svc *slim_corev1.Service)
  • func (s *Speaker) RegisterSvcCache(cache endpointsGetter)

Types

type Speaker

type Speaker struct {
	*metallbspr.Controller

	lock.Mutex
	// contains filtered or unexported fields
}

Speaker represents the BGP speaker. It integrates Cilium's K8s events with MetalLB's logic for making BGP announcements. It is responsible for announcing BGP messages containing a loadbalancer IP address to peers.

func New

func New() *Speaker

New creates a new MetalLB BGP speaker controller.

func (*Speaker) OnDeleteService

func (s *Speaker) OnDeleteService(svc *slim_corev1.Service)

OnDeleteService notifies the Speaker of a delete of a service.

func (*Speaker) OnUpdateEndpoints

func (s *Speaker) OnUpdateEndpoints(eps *slim_corev1.Endpoints)

OnUpdateEndpoints notifies the Speaker of an update to the backends of a service.

func (*Speaker) OnUpdateNode

func (s *Speaker) OnUpdateNode(node *v1.Node)

OnUpdateNode notifies the Speaker of an update to a node.

func (*Speaker) OnUpdateService

func (s *Speaker) OnUpdateService(svc *slim_corev1.Service)

OnUpdateService notifies the Speaker of an update to a service.

func (*Speaker) RegisterSvcCache

func (s *Speaker) RegisterSvcCache(cache endpointsGetter)

RegisterSvcCache registers the K8s watcher cache with this Speaker.