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) HandleEvents()
  • func (lb *LoadBalancer) Snapshot()
  • func (lb *LoadBalancer) SvcTrigger(eventType LBEventType, svc *corev1.Service)
  • func (lb *LoadBalancer) Trigger(evt LBEvent)

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

	Config        cache.SnapshotCache
	ConfigVersion int32
	EnvoyConfig   config.EnvoyConfig
	// 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) *LoadBalancer

func (*LoadBalancer) Close

func (lb *LoadBalancer) Close()

func (*LoadBalancer) HandleEvents

func (lb *LoadBalancer) HandleEvents()

func (*LoadBalancer) Snapshot

func (lb *LoadBalancer) Snapshot()

func (*LoadBalancer) SvcTrigger

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

func (*LoadBalancer) Trigger

func (lb *LoadBalancer) Trigger(evt LBEvent)