cmd

Apr 12, 2023

Changes in this version

+ const ClusterConfigEnv

+ const ClusterNameEnv

+ const GuestClassLabel

+ const IngressClassNameAnnotation

+ const IngressFinalizer

+ const ServiceFinalizer

+ func ConvertPort(namespace, name string, port *corev1.ServicePort) corev1.ServicePort

+ func GetClassName(ing *netv1.Ingress) (string, bool)

+ func PortName(namespace, name string, port *corev1.ServicePort) string

+ type IngressController struct

+ ClassIngresses map[string]map[string]map[string]struct{}

+ Guest client.Client

+ Host client.Client

+ IngressClasses map[string]map[string]string

+ IngressPaths map[string]map[string]map[string][]netv1.HTTPIngressPath

+ Log logr.Logger

+ Targets map[string]*netv1.Ingress

+ func (i *IngressController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ type IngressControllerRun struct

+ Ctx context.Context

+ GuestClass string

+ Ingress *netv1.Ingress

+ Log logr.Logger

+ MappedClass *cfg.LoadBalancerIngressClassMapping

+ func (i *IngressControllerRun) CreateOrUpdateHostIngress(guestClass string) error

+ func (i *IngressControllerRun) GenerateHostIngress() error

+ func (i *IngressControllerRun) GenerateHostIngressMetadata()

+ func (i *IngressControllerRun) HandleFinalizer() (deleted bool, err error)

+ func (i *IngressControllerRun) RemovePaths()

+ func (i *IngressControllerRun) UpsertPaths() (oldClass string)

+ type ServiceController struct

+ Guest client.Client

+ Host client.Client

+ LBSvc *corev1.Service

+ Log logr.Logger

+ NodePorts map[int32]corev1.ServicePort

+ ServiceNodePorts map[string]map[string][]int32

+ func (s *ServiceController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (s *ServiceController) SetHostLBMetadata()

+ type ServiceControllerRun struct

+ Ctx context.Context

+ Log logr.Logger

+ Svc *corev1.Service

+ func (s *ServiceControllerRun) CreateOrUpdateHostLB() error

+ func (s *ServiceControllerRun) GenerateHostLB()

+ func (s *ServiceControllerRun) HandleFinalizer() (deleted bool, err error)

+ func (s *ServiceControllerRun) RemovePorts()

+ func (s *ServiceControllerRun) SetLBIngress() error

+ func (s *ServiceControllerRun) UpsertPorts()

Nov 5, 2022

Changes in this version

+ func Execute()