loadbalancer

Documentation

Index

• Constants
• func GenKey(ns, name string) string
• func GenSPKey(IPString string, Port uint16, Protocol string) string
• type LbArgs
• type LbCacheEntry
• type LbCacheKey
• type LbCacheTable
• type LbModelEnt
• type LbServicePairEntry
• type Manager
  • func NewLoadBalancerManager(kubeClient clientset.Interface, loxiClients []*api.LoxiClient, ...) *Manager
  • func (m *Manager) DeleteAllLoadBalancer()
  • func (m *Manager) DiscoverLoxiLBPeerServices(loxiLBAliveCh chan *api.LoxiClient, loxiLBDeadCh chan struct{}, ...)
  • func (m *Manager) DiscoverLoxiLBServices(loxiLBAliveCh chan *api.LoxiClient, loxiLBDeadCh chan struct{}, ...)
  • func (m *Manager) Run(stopCh <-chan struct{}, loxiLBLiveCh chan *api.LoxiClient, ...)
  • func (m *Manager) SelectLoxiLBRoles(sendSigCh bool, loxiLBSelMasterEvent chan bool)
• type SvcPair
  • func (s SvcPair) String() string

Constants

const (
	LoxiMaxWeight               = 10
	LoxiMultusServiceAnnotation = "loxilb.io/multus-nets"

	MaxExternalSecondaryIPsNum = 4
)

Functions

func GenKey

func GenKey(ns, name string) string

GenKey generate key for cache

func GenSPKey

func GenSPKey(IPString string, Port uint16, Protocol string) string

GenSPKey generate key for cache

Types

type LbArgs

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

type LbCacheEntry

type LbCacheEntry struct {
	LbMode         int
	Timeout        int
	ActCheck       bool
	PrefLocal      bool
	Addr           string
	State          string
	ProbeType      string
	ProbePort      uint16
	ProbeReq       string
	ProbeResp      string
	SecIPs         []string
	LbServicePairs map[string]*LbServicePairEntry
}

type LbCacheKey

type LbCacheKey struct {
	Namespace string
	Name      string
}

type LbCacheTable

type LbCacheTable map[string]*LbCacheEntry

type LbModelEnt

type LbModelEnt struct {
	LbModel api.LoadBalancerModel
}

type LbServicePairEntry

type LbServicePairEntry struct {
	ExternalIP  string
	Port        uint16
	Protocol    string
	StaticIP    bool
	InRange     bool
	IdentIPAM   string
	LbModelList []api.LoadBalancerModel
}

type Manager

type Manager struct {
	LoxiClients     []*api.LoxiClient
	LoxiPeerClients []*api.LoxiClient

	ExternalIPPool       *ippool.IPPool
	ExtSecondaryIPPools  []*ippool.IPPool
	ExternalIP6Pool      *ippool.IPPool
	ExtSecondaryIP6Pools []*ippool.IPPool
	ElectionRunOnce      bool
	// contains filtered or unexported fields
}

func NewLoadBalancerManager

func NewLoadBalancerManager(
	kubeClient clientset.Interface,
	loxiClients []*api.LoxiClient,
	loxiPeerClients []*api.LoxiClient,
	externalIPPool *ippool.IPPool,
	externalSecondaryIPPools []*ippool.IPPool,
	externalIP6Pool *ippool.IPPool,
	externalSecondaryIP6Pools []*ippool.IPPool,
	networkConfig *config.NetworkConfig,
	informerFactory informers.SharedInformerFactory) *Manager

Create and Init Manager. Manager is called by kube-loxilb when k8s service is created & updated.

func (*Manager) DeleteAllLoadBalancer

func (m *Manager) DeleteAllLoadBalancer()

func (*Manager) DiscoverLoxiLBPeerServices

func (m *Manager) DiscoverLoxiLBPeerServices(loxiLBAliveCh chan *api.LoxiClient, loxiLBDeadCh chan struct{}, loxiLBPurgeCh chan *api.LoxiClient)

func (*Manager) DiscoverLoxiLBServices

func (m *Manager) DiscoverLoxiLBServices(loxiLBAliveCh chan *api.LoxiClient, loxiLBDeadCh chan struct{}, loxiLBPurgeCh chan *api.LoxiClient)

func (*Manager) Run

func (m *Manager) Run(stopCh <-chan struct{}, loxiLBLiveCh chan *api.LoxiClient, loxiLBPurgeCh chan *api.LoxiClient, masterEventCh <-chan bool)

func (*Manager) SelectLoxiLBRoles

func (m *Manager) SelectLoxiLBRoles(sendSigCh bool, loxiLBSelMasterEvent chan bool)

type SvcPair

type SvcPair struct {
	IPString   string
	Port       int32
	Protocol   string
	InRange    bool
	StaticIP   bool
	IdentIPAM  string
	IPAllocd   bool
	K8sSvcPort corev1.ServicePort
}

func (SvcPair) String

func (s SvcPair) String() string