hybrid

package
v3.10.0-rc.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 15, 2018 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 kcorelisters.ServiceLister,
) (*HybridProxier, error)

func (*HybridProxier) OnEndpointsAdd

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

func (*HybridProxier) OnEndpointsDelete

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

func (*HybridProxier) OnEndpointsSynced

func (p *HybridProxier) OnEndpointsSynced()

func (*HybridProxier) OnEndpointsUpdate

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

func (*HybridProxier) OnServiceAdd

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

func (*HybridProxier) OnServiceDelete

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

func (*HybridProxier) OnServiceSynced

func (p *HybridProxier) OnServiceSynced()

func (*HybridProxier) OnServiceUpdate

func (p *HybridProxier) OnServiceUpdate(oldService, service *api.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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL