hybrid

Documentation

Index

• type HybridProxier
  • func NewHybridProxier(unidlingEndpointsHandler proxyconfig.EndpointsHandler, ...) (*HybridProxier, error)
  • func (p *HybridProxier) OnEndpointsAdd(endpoints *corev1.Endpoints)
  • func (p *HybridProxier) OnEndpointsDelete(endpoints *corev1.Endpoints)
  • func (p *HybridProxier) OnEndpointsSynced()
  • func (p *HybridProxier) OnEndpointsUpdate(oldEndpoints, endpoints *corev1.Endpoints)
  • func (p *HybridProxier) OnServiceAdd(service *corev1.Service)
  • func (p *HybridProxier) OnServiceDelete(service *corev1.Service)
  • func (p *HybridProxier) OnServiceSynced()
  • func (p *HybridProxier) OnServiceUpdate(oldService, service *corev1.Service)
  • func (p *HybridProxier) Sync()
  • func (p *HybridProxier) SyncLoop()

Types

type HybridProxier

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

HybridProxier runs an unidling proxy and a primary proxy at the same time, delegating idled services to the unidling proxy and other services to the primary proxy.

func NewHybridProxier

func NewHybridProxier(
	unidlingEndpointsHandler proxyconfig.EndpointsHandler,
	unidlingServiceHandler proxyconfig.ServiceHandler,
	mainEndpointsHandler proxyconfig.EndpointsHandler,
	mainServicesHandler proxyconfig.ServiceHandler,
	mainProxy proxy.ProxyProvider,
	unidlingProxy proxy.ProxyProvider,
	syncPeriod time.Duration,
	serviceLister corev1listers.ServiceLister,
) (*HybridProxier, error)

func (*HybridProxier) OnEndpointsAdd

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

func (*HybridProxier) OnEndpointsDelete

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

func (*HybridProxier) OnEndpointsSynced

func (p *HybridProxier) OnEndpointsSynced()

func (*HybridProxier) OnEndpointsUpdate

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

func (*HybridProxier) OnServiceAdd

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

func (*HybridProxier) OnServiceDelete

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

func (*HybridProxier) OnServiceSynced

func (p *HybridProxier) OnServiceSynced()

func (*HybridProxier) OnServiceUpdate

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

func (*HybridProxier) Sync

func (p *HybridProxier) Sync()

Sync is called to immediately synchronize the proxier state to iptables

func (*HybridProxier) SyncLoop

func (p *HybridProxier) SyncLoop()

SyncLoop runs periodic work. This is expected to run as a goroutine or as the main loop of the app. It does not return.