envoy

Documentation

Index

• type Hasher
  • func (h Hasher) ID(node *core.Node) string
• type LBEvent
• type LBEventType
• type LoadBalancer
  • func NewLB(nodeID string, envoyConfig config.EnvoyConfig, ...) *LoadBalancer
  • func (lb *LoadBalancer) Close()
  • func (lb *LoadBalancer) EndpointTrigger()
  • func (lb *LoadBalancer) GetCache() cache.SnapshotCache
  • func (lb *LoadBalancer) GetCacheVersion() int32
  • func (lb *LoadBalancer) GetUpstreams() map[string]kube.Service
  • func (lb *LoadBalancer) HandleEvents()
  • func (lb *LoadBalancer) InitializeUpstream(serviceList *corev1.ServiceList)
  • func (lb *LoadBalancer) SnapshotRunner()
  • func (lb *LoadBalancer) SvcTrigger(eventType LBEventType, svc *corev1.Service)
  • func (lb *LoadBalancer) Trigger(evt LBEvent)
• type Logger
  • func (logger Logger) Errorf(format string, args ...interface{})
  • func (logger Logger) Infof(format string, args ...interface{})

Types

type Hasher

type Hasher struct {
}

Hasher returns node ID as an ID

func (Hasher) ID

func (h Hasher) ID(node *core.Node) string

ID function

type LBEvent

type LBEvent struct {
	Svc       kube.Service
	EventType LBEventType
}

LBEvent is the event triggered by kubernetes service changes

type LBEventType

type LBEventType int32

LBEventType is the type of event impacting the LB

const (
	//ADDED represents a service create event
	ADDED LBEventType = iota
	//UPDATED represents a service updated event
	UPDATED
	//DELETED represents a service updated event
	DELETED
)

type LoadBalancer

type LoadBalancer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

LoadBalancer represents the current state of upstreams for a load balancer

func NewLB

func NewLB(nodeID string, envoyConfig config.EnvoyConfig, snapshotCache cache.SnapshotCache, autoRefreshConn bool) *LoadBalancer

func (*LoadBalancer) Close

func (lb *LoadBalancer) Close()

func (*LoadBalancer) EndpointTrigger

func (lb *LoadBalancer) EndpointTrigger()

func (*LoadBalancer) GetCache

func (lb *LoadBalancer) GetCache() cache.SnapshotCache

func (*LoadBalancer) GetCacheVersion

func (lb *LoadBalancer) GetCacheVersion() int32

func (*LoadBalancer) GetUpstreams

func (lb *LoadBalancer) GetUpstreams() map[string]kube.Service

func (*LoadBalancer) HandleEvents

func (lb *LoadBalancer) HandleEvents()

func (*LoadBalancer) InitializeUpstream

func (lb *LoadBalancer) InitializeUpstream(serviceList *corev1.ServiceList)

func (*LoadBalancer) SnapshotRunner

func (lb *LoadBalancer) SnapshotRunner()

func (*LoadBalancer) SvcTrigger

func (lb *LoadBalancer) SvcTrigger(eventType LBEventType, svc *corev1.Service)

func (*LoadBalancer) Trigger

func (lb *LoadBalancer) Trigger(evt LBEvent)

type Logger

type Logger struct{}

func (Logger) Errorf

func (logger Logger) Errorf(format string, args ...interface{})

func (Logger) Infof

func (logger Logger) Infof(format string, args ...interface{})