servicelb

Documentation

Index

• Constants
• type Manager
  • func NewManager(ctx context.Context, serviceClient ctlCorev1.ServiceClient, ...) *Manager
  • func (m *Manager) DeleteLoadBalancer(lb *lbv1.LoadBalancer) error
  • func (m *Manager) EnsureBackendServers(lb *lbv1.LoadBalancer) ([]pkglb.BackendServer, error)
  • func (m *Manager) EnsureLoadBalancer(lb *lbv1.LoadBalancer) error
  • func (m *Manager) EnsureLoadBalancerServiceIP(lb *lbv1.LoadBalancer) (string, error)
  • func (m *Manager) GetProbeReadyBackendServerCount(lb *lbv1.LoadBalancer) (int, error)
  • func (m *Manager) ListBackendServers(lb *lbv1.LoadBalancer) ([]pkglb.BackendServer, error)
  • func (m *Manager) RegisterHealthCheckHandler(handler pkglb.HealthCheckHandler) error
• type Server
  • func (s *Server) GetAddress() (string, bool)

Constants

const (
	KeyLabel       = loadbalancer.GroupName + "/servicelb"
	KeyServiceName = "kubernetes.io/service-name"
)

Types

type Manager

type Manager struct {
	*prober.Manager
	// contains filtered or unexported fields
}

func NewManager

func NewManager(ctx context.Context, serviceClient ctlCorev1.ServiceClient, serviceCache ctlCorev1.ServiceCache,
	endpointSliceClient ctldiscoveryv1.EndpointSliceClient, endpointSliceCache ctldiscoveryv1.EndpointSliceCache,
	vmiCache ctlkubevirtv1.VirtualMachineInstanceCache) *Manager

func (*Manager) DeleteLoadBalancer

func (m *Manager) DeleteLoadBalancer(lb *lbv1.LoadBalancer) error

func (*Manager) EnsureBackendServers

func (m *Manager) EnsureBackendServers(lb *lbv1.LoadBalancer) ([]pkglb.BackendServer, error)

func (*Manager) EnsureLoadBalancer

func (m *Manager) EnsureLoadBalancer(lb *lbv1.LoadBalancer) error

func (*Manager) EnsureLoadBalancerServiceIP

func (m *Manager) EnsureLoadBalancerServiceIP(lb *lbv1.LoadBalancer) (string, error)

func (*Manager) GetProbeReadyBackendServerCount

func (m *Manager) GetProbeReadyBackendServerCount(lb *lbv1.LoadBalancer) (int, error)

if probe is disabled, then return the endpint count

func (*Manager) ListBackendServers

func (m *Manager) ListBackendServers(lb *lbv1.LoadBalancer) ([]pkglb.BackendServer, error)

func (*Manager) RegisterHealthCheckHandler

func (m *Manager) RegisterHealthCheckHandler(handler pkglb.HealthCheckHandler) error

call only once before controller starts looping on OnChange ...

type Server

type Server struct {
	*kubevirtv1.VirtualMachineInstance
}

func (*Server) GetAddress

func (s *Server) GetAddress() (string, bool)