stream

Documentation

Index

• func New(stream *nspAPI.Stream, targetRegistryClient nspAPI.TargetRegistryClient, ...) (types.Stream, error)
• func NewTarget(nspTarget *nspAPI.Target, netUtils networking.Utils) (types.Target, error)
• type Defrag
  • func NewDefrag(excludedIfPrefix string) (*Defrag, error)
  • func (d *Defrag) Delete() 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) RemoveTarget(identifier int) error
  • func (lb *LoadBalancer) Start(ctx context.Context) error
  • func (lb *LoadBalancer) TargetExists(identifier int) bool
• type Target
  • func (t *Target) Configure() error
  • func (t *Target) Delete() error
  • func (t *Target) GetIdentifier() int
  • func (t *Target) GetIps() []string

Functions

func New

func New(stream *nspAPI.Stream, targetRegistryClient nspAPI.TargetRegistryClient, configurationManagerClient nspAPI.ConfigurationManagerClient, m int, n int, nfqueue int, netUtils networking.Utils) (types.Stream, error)

func NewTarget

func NewTarget(nspTarget *nspAPI.Target, netUtils networking.Utils) (types.Target, error)

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 LoadBalancer

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

LoadBalancer -

func (*LoadBalancer) AddTarget

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

AddTarget -

func (*LoadBalancer) Delete

func (lb *LoadBalancer) Delete() error

func (*LoadBalancer) GetTargets

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

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 -

type Target

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

func (*Target) Configure

func (t *Target) Configure() error

func (*Target) Delete

func (t *Target) Delete() error

func (*Target) GetIdentifier

func (t *Target) GetIdentifier() int

func (*Target) GetIps

func (t *Target) GetIps() []string