hybrid

Documentation

Index

• type EndpointsConfigHandler
• type HybridProxier
  • func NewHybridProxier(unidlingLoadBalancer EndpointsConfigHandler, unidlingProxy *userspace.Proxier, ...) (*HybridProxier, error)
  • func (p *HybridProxier) OnEndpointsUpdate(endpoints []*api.Endpoints)
  • func (p *HybridProxier) OnServiceUpdate(services []*api.Service)
  • func (p *HybridProxier) Sync()
  • func (p *HybridProxier) SyncLoop()
• type ServiceConfigHandler

Types

type EndpointsConfigHandler

type EndpointsConfigHandler interface {
	// OnEndpointsUpdate gets called when endpoints configuration is changed for a given
	// service on any of the configuration sources. An example is when a new
	// service comes up, or when containers come up or down for an existing service.
	OnEndpointsUpdate(endpoints []*api.Endpoints)
}

EndpointsConfigHandler is an abstract interface of objects which receive update notifications for the set of endpoints.

type HybridProxier

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

func NewHybridProxier

func NewHybridProxier(
	unidlingLoadBalancer EndpointsConfigHandler,
	unidlingProxy *userspace.Proxier,
	mainEndpointsHandler EndpointsConfigHandler,
	mainProxy proxy.ProxyProvider,
	mainServicesHandler ServiceConfigHandler,
	syncPeriod time.Duration,
	serviceLister kcorelisters.ServiceLister,
) (*HybridProxier, error)

func (*HybridProxier) OnEndpointsUpdate

func (p *HybridProxier) OnEndpointsUpdate(endpoints []*api.Endpoints)

func (*HybridProxier) OnServiceUpdate

func (p *HybridProxier) OnServiceUpdate(services []*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.

type ServiceConfigHandler

type ServiceConfigHandler interface {
	// OnServiceUpdate gets called when a configuration has been changed by one of the sources.
	// This is the union of all the configuration sources.
	OnServiceUpdate(services []*api.Service)
}

ServiceConfigHandler is an abstract interface of objects which receive update notifications for the set of services.