stream

Documentation

Index

• func GetInterfaceNamePrefix() string
• func New(stream *nspAPI.Stream, targetRegistryClient nspAPI.TargetRegistryClient, ...) (types.Stream, error)
• func NewTarget(nspTarget *nspAPI.Target, netUtils networking.Utils, ...) (types.Target, error)
• func SetInterfaceNamePrefix(ns string)
• type Defrag
  • func NewDefrag(excludedIfPrefix string) (*Defrag, error)
  • func (d *Defrag) Delete() error
• type ForwardingAvailabilityService
  • func NewForwardingAvailabilityService(ctx context.Context, target *lbAPI.Target) *ForwardingAvailabilityService
  • func (fas *ForwardingAvailabilityService) Register(name string)
  • func (fas *ForwardingAvailabilityService) Stop()
  • func (fas *ForwardingAvailabilityService) Unregister(name string)
  • func (fas *ForwardingAvailabilityService) Watch(_ *emptypb.Empty, watcher lbAPI.StreamAvailabilityService_WatchServer) error
• type LoadBalancer
  • func (lb *LoadBalancer) AddTarget(target types.Target) error
  • func (lb *LoadBalancer) Delete() error
  • func (lb *LoadBalancer) GetTargets() []types.Target
  • func (lb *LoadBalancer) InterfaceCreated(intf networking.Iface)
  • func (lb *LoadBalancer) InterfaceDeleted(intf networking.Iface)
  • func (lb *LoadBalancer) RemoveTarget(identifier int) error
  • func (lb *LoadBalancer) Start(ctx context.Context) error
  • func (lb *LoadBalancer) TargetExists(identifier int) bool

Functions

func GetInterfaceNamePrefix

func GetInterfaceNamePrefix() string

GetInterfaceNamePrefix -

func New

func New(
	stream *nspAPI.Stream,
	targetRegistryClient nspAPI.TargetRegistryClient,
	configurationManagerClient nspAPI.ConfigurationManagerClient,
	nfqueue int,
	netUtils networking.Utils,
	lbFactory types.NFQueueLoadBalancerFactory,
	identifierOffset int,
	targetHitsMetrics *targetMetrics.HitsMetrics,
	neighborReachDetector *neighbor.NeighborReachabilityDetector,
	forwardingAvailabilityService *ForwardingAvailabilityService,
) (types.Stream, error)

func NewTarget

func NewTarget(nspTarget *nspAPI.Target, netUtils networking.Utils, targetHitsMetrics *targetMetrics.HitsMetrics, identifierOffset int) (types.Target, error)

func SetInterfaceNamePrefix

func SetInterfaceNamePrefix(ns string)

SetInterfaceNamePrefix - Derives the NSM v1.2-rc1 (same as v1.1.1) interface name prefix based on the Network Service name of the NSE.

Note: By letting NSM name the NSE interface there's no need for a custom interfacename.NewServer chain component.

Types

type Defrag

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

func NewDefrag

func NewDefrag(excludedIfPrefix string) (*Defrag, error)

NewDefrag - -Load kernel's defragmentation via conntrack. Needed by Flow rules to match L4 information - applied on packets arriving from outside world. -Do not allow defragmentation of packets from the direction of targets. Thus outbound IPv4 packets can leave the LB reflecting their originating source's PMTU information. -Forbid conntrack to do "book-keeping" in order to not "litter" memory.

func (*Defrag) Delete

func (d *Defrag) Delete() error

type ForwardingAvailabilityService

type ForwardingAvailabilityService struct {
	lbAPI.UnimplementedStreamAvailabilityServiceServer
	// contains filtered or unexported fields
}

ForwardingAvailabilityService keeps track of forwarding plane availability towards application targets.

It aggregates path informatation received form invidual Streams, and updates Watch clients based on the accumulated information whether the loadbalancer is capable of forwarding incoming traffic.

Update is performed using a custom loadbalancer Target. There is one common loadbalancer Target for all local forwarding paths. (That is, the forwarding capability is not distinguished on Stream level currently.)

func NewForwardingAvailabilityService

func NewForwardingAvailabilityService(ctx context.Context,
	target *lbAPI.Target) *ForwardingAvailabilityService

NewForwardingAvailabilityService - Creates a new forwarding availability service.

func (*ForwardingAvailabilityService) Register

func (fas *ForwardingAvailabilityService) Register(name string)

Register - Registers a new forwarding path. In case of the first forwarding path update() is called to inform Watch clients the LB is ready to forward traffic.

func (*ForwardingAvailabilityService) Stop

func (fas *ForwardingAvailabilityService) Stop()

Stop - Stops further user interaction via Register/Unregister calls. Also informs clients that the loadbalancer target is no longer available.

func (*ForwardingAvailabilityService) Unregister

func (fas *ForwardingAvailabilityService) Unregister(name string)

Unregister - Unregisters a forfarding path. In case there are no remaining forwarding paths, update informs the Watch clients.

func (*ForwardingAvailabilityService) Watch

func (fas *ForwardingAvailabilityService) Watch(_ *emptypb.Empty, watcher lbAPI.StreamAvailabilityService_WatchServer) error

type LoadBalancer

type LoadBalancer struct {
	*nspAPI.Stream
	TargetRegistryClient       nspAPI.TargetRegistryClient
	ConfigurationManagerClient nspAPI.ConfigurationManagerClient
	IdentifierOffset           int
	// contains filtered or unexported fields
}

LoadBalancer -

func (*LoadBalancer) AddTarget

func (lb *LoadBalancer) AddTarget(target types.Target) error

AddTarget - Adds a target by configuring routing and activating it in nfqlb. Note: configuration fails if no (NSM) inteface is available in the subnet the target IPs belong to.

func (*LoadBalancer) Delete

func (lb *LoadBalancer) Delete() error

func (*LoadBalancer) GetTargets

func (lb *LoadBalancer) GetTargets() []types.Target

func (*LoadBalancer) InterfaceCreated

func (lb *LoadBalancer) InterfaceCreated(intf networking.Iface)

InterfaceCreated - When a new NSM interface of interest appears trigger processPendingTargets() to attempt configuring pending Targets (missing route could have become available)

func (*LoadBalancer) InterfaceDeleted

func (lb *LoadBalancer) InterfaceDeleted(intf networking.Iface)

InterfaceDeleted - When a NSM interface of interest disappears trigger processPendingTargets() to verify if configured Targets still have working routes

func (*LoadBalancer) RemoveTarget

func (lb *LoadBalancer) RemoveTarget(identifier int) error

RemoveTarget -

func (*LoadBalancer) Start

func (lb *LoadBalancer) Start(ctx context.Context) error

func (*LoadBalancer) TargetExists

func (lb *LoadBalancer) TargetExists(identifier int) bool

TargetExists -