proxy

Documentation

Index

• type Proxier
  • func New(hostname string, informerFactory informers.SharedInformerFactory, ...) *Proxier
  • func (p *Proxier) OnEndpointsAdd(endpoints *corev1.Endpoints)
  • func (p *Proxier) OnEndpointsDelete(endpoints *corev1.Endpoints)
  • func (p *Proxier) OnEndpointsSynced()
  • func (p *Proxier) OnEndpointsUpdate(oldEndpoints, endpoints *corev1.Endpoints)
  • func (p *Proxier) OnServiceAdd(service *corev1.Service)
  • func (p *Proxier) OnServiceDelete(service *corev1.Service)
  • func (p *Proxier) OnServiceSynced()
  • func (p *Proxier) OnServiceUpdate(oldService, service *corev1.Service)
  • func (p *Proxier) Run(stopCh <-chan struct{})
  • func (p *Proxier) SyncLoop()

Types

type Proxier

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

TODO: Add metrics

func New

func New(hostname string, informerFactory informers.SharedInformerFactory, ofClient openflow.Client) *Proxier

func (*Proxier) OnEndpointsAdd

func (p *Proxier) OnEndpointsAdd(endpoints *corev1.Endpoints)

func (*Proxier) OnEndpointsDelete

func (p *Proxier) OnEndpointsDelete(endpoints *corev1.Endpoints)

func (*Proxier) OnEndpointsSynced

func (p *Proxier) OnEndpointsSynced()

func (*Proxier) OnEndpointsUpdate

func (p *Proxier) OnEndpointsUpdate(oldEndpoints, endpoints *corev1.Endpoints)

func (*Proxier) OnServiceAdd

func (p *Proxier) OnServiceAdd(service *corev1.Service)

func (*Proxier) OnServiceDelete

func (p *Proxier) OnServiceDelete(service *corev1.Service)

func (*Proxier) OnServiceSynced

func (p *Proxier) OnServiceSynced()

func (*Proxier) OnServiceUpdate

func (p *Proxier) OnServiceUpdate(oldService, service *corev1.Service)

func (*Proxier) Run

func (p *Proxier) Run(stopCh <-chan struct{})

func (*Proxier) SyncLoop

func (p *Proxier) SyncLoop()