manager

Documentation

Overview

Package manager provides functionality relating to the integration between Cilium and MetalLB, namely providing abstractions that help manage MetalLB from Cilium.

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

Index

• type Controller
• type Manager
  • func New(ctx context.Context, indexer cache.Store) (*Manager, error)
  • func (m *Manager) MarkSynced()
  • func (m *Manager) OnAddService(obj *slim_corev1.Service) error
  • func (m *Manager) OnDeleteService(obj *slim_corev1.Service) error
  • func (m *Manager) OnUpdateService(oldObj, newObj *slim_corev1.Service) error

Types

type Controller

type Controller interface {
	SetBalancer(name string, srvRo *v1.Service, eps k8s.EpsOrSlices) types.SyncState
	MarkSynced()
}

Controller provides a method set for interfacing with a BGP Controller.

This interface is heavily modeled after MetalLB's controller as it's the first BGP integration for Cilium's use cases.

If other BGP integrations are desired, consider building out custom types and a more abstracted method set.

type Manager

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

Manager represents the BGP manager. It integrates Cilium with the MetalLB logic for allocating LB IPs for service objects of type LoadBalancer.

This manager also subscribes and handles K8s services events from the watcher and pushes them into a queue. From the queue, they are processed by the reconciliation logic of MetalLB for LB IP allocation. To do this, Manager implements github.com/cilium/cilium/pkg/k8s/watchers/subscriber.Service and therefore is registered as a subscriber to the subscriber package to be called from the K8s watcher.

Note that the LB IP allocation occurs only for services of type LoadBalancer in the service.Status.LoadBalancerStatus.Ingress field.

func New

func New(ctx context.Context, indexer cache.Store) (*Manager, error)

New creates a new BGP MetalLB manager. It contains the MetalLB service IP controller, which contains the allocator.

New requires access to a cache.Store associated with the service watcher.

func (*Manager) MarkSynced

func (m *Manager) MarkSynced()

func (*Manager) OnAddService

func (m *Manager) OnAddService(obj *slim_corev1.Service) error

OnAddService handles an add event for services. It implements github.com/cilium/cilium/pkg/k8s/watchers/subscriber.ServiceHandler.

func (*Manager) OnDeleteService

func (m *Manager) OnDeleteService(obj *slim_corev1.Service) error

OnDeleteService handles a delete event for services. It implements github.com/cilium/cilium/pkg/k8s/watchers/subscriber.ServiceHandler.

func (*Manager) OnUpdateService

func (m *Manager) OnUpdateService(oldObj, newObj *slim_corev1.Service) error

OnUpdateService handles an update event for services. It implements github.com/cilium/cilium/pkg/k8s/watchers/subscriber.ServiceHandler.