egress

Documentation

Index

• type Manager
  • func NewEgressManager(kubeClient kubernetes.Interface, kubeExtClient apiextensionclientset.Interface, ...) *Manager
  • func (m *Manager) Run(stopCh <-chan struct{})
  • func (m *Manager) Start(informer egressCRDinformers.SharedInformerFactory, stopCh <-chan struct{})
  • func (m *Manager) WaitForLoxiEgressCRDCreation(stopCh <-chan struct{})

Types

type Manager

type Manager struct {
	EgressInformer     crdInformer.EgressInformer
	EgressLister       crdLister.EgressLister
	EgressListerSynced cache.InformerSynced
	LoxiClients        *api.LoxiClientPool

	ClientAliveCh chan *api.LoxiClient
	// contains filtered or unexported fields
}

func NewEgressManager

func NewEgressManager(
	kubeClient kubernetes.Interface,
	kubeExtClient apiextensionclientset.Interface,
	crdClient versioned.Interface,
	networkConfig *config.NetworkConfig,
	EgressInformer crdInformer.EgressInformer,
	LoxiClients *api.LoxiClientPool,
) *Manager

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

func (*Manager) Run

func (m *Manager) Run(stopCh <-chan struct{})

func (*Manager) Start

func (m *Manager) Start(informer egressCRDinformers.SharedInformerFactory, stopCh <-chan struct{})

func (*Manager) WaitForLoxiEgressCRDCreation

func (m *Manager) WaitForLoxiEgressCRDCreation(stopCh <-chan struct{})