ciliumenvoyconfig

Documentation

Overview

Package service contains the logic for Cilium Load Balancer Controller via envoy config

Index

• Constants
• func GetLBProtocolModelAnnotation(obj metav1.Object) string
• func IsLBProtocolAnnotationEnabled(obj metav1.Object) bool
• type Manager
  • func New(ctx context.Context, client client.Clientset, indexer cache.Store, ...) (*Manager, error)
  • func (m *Manager) MarkSynced()
  • func (m *Manager) OnAddService(service *slim_corev1.Service) error
  • func (m *Manager) OnDeleteService(_ *slim_corev1.Service) error
  • func (m *Manager) OnUpdateService(_, newObj *slim_corev1.Service) error
  • func (m *Manager) Run(ctx context.Context)

Constants

const Subsys = "envoy-lb-controller"

Functions

func GetLBProtocolModelAnnotation

func GetLBProtocolModelAnnotation(obj metav1.Object) string

GetLBProtocolModelAnnotation returns the load balancer mode

func IsLBProtocolAnnotationEnabled

func IsLBProtocolAnnotationEnabled(obj metav1.Object) bool

IsLBProtocolAnnotationEnabled returns true if the load balancer protocol is enabled

Types

type Manager

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

func New

func New(ctx context.Context, client client.Clientset, indexer cache.Store, ports []string, algorithm string, idleTimeoutSeconds int) (*Manager, error)

New returns a new Manager for CiliumEnvoyConfig

func (*Manager) MarkSynced

func (m *Manager) MarkSynced()

func (*Manager) OnAddService

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

func (*Manager) OnDeleteService

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

func (*Manager) OnUpdateService

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

func (*Manager) Run

func (m *Manager) Run(ctx context.Context)

Run kicks off the controlled loop