kernel

Documentation

Index

• Constants
• Variables
• type Balancer
  • func (b *Balancer) BlockList(list [PREFIXES]bool)
  • func (b *Balancer) Close()
  • func (b *Balancer) Configure(r Healthchecks)
  • func (b *Balancer) FlowQueue() []byte
  • func (b *Balancer) Global() Counter
  • func (b *Balancer) NoBlockList()
  • func (b *Balancer) Stats() map[Target]Counter
  • func (b *Balancer) StoreFlow(fs []byte)
• type Counter
  • func (c *Counter) Add(n Counter)
• type Healthchecks
• type ICMPs
  • func ICMP() *ICMPs
  • func (s *ICMPs) Close()
  • func (s *ICMPs) Ping(target string)
• type IP4
  • func LookupNAT(vip, rip IP4) IP4
• type IP4s
• type L4
• type MAC
• type Maps
  • func Open(native bool, vetha, vethb string, eth ...string) (*Maps, error)
• type NAT
  • func (n *NAT) Close()
  • func (n *NAT) Configure(h *Healthchecks)
  • func (n *NAT) NAT(h *Healthchecks) (*Healthchecks, error)
• type NetNS
  • func (n *NetNS) Close()
  • func (n *NetNS) Init() error
  • func (n *NetNS) Open() error
• type Protocol
• type Real
• type Report
• type Service
• type Target

Constants

const (
	A = false
	B = true
)

const NAMESPACE = "vc5"

const PREFIXES = 1048576

Variables

var BPF_O []byte

Types

type Balancer

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

func (*Balancer) BlockList

func (b *Balancer) BlockList(list [PREFIXES]bool)

func (*Balancer) Close

func (b *Balancer) Close()

func (*Balancer) Configure

func (b *Balancer) Configure(r Healthchecks)

func (*Balancer) FlowQueue

func (b *Balancer) FlowQueue() []byte

func (*Balancer) Global

func (b *Balancer) Global() Counter

func (*Balancer) NoBlockList

func (b *Balancer) NoBlockList()

func (*Balancer) Stats

func (b *Balancer) Stats() map[Target]Counter

func (*Balancer) StoreFlow

func (b *Balancer) StoreFlow(fs []byte)

type Counter

type Counter struct {
	Octets      uint64
	Packets     uint64
	Flows       uint64
	Concurrent  uint64
	Blocked     uint64
	Latency     uint64 // global only
	QueueFailed uint64 // global only
	DEFCON      uint8  // global only
}

func (*Counter) Add

func (c *Counter) Add(n Counter)

type Healthchecks

type Healthchecks = healthchecks.Healthchecks

type ICMPs

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

func ICMP

func ICMP() *ICMPs

func (*ICMPs) Close

func (s *ICMPs) Close()

func (*ICMPs) Ping

func (s *ICMPs) Ping(target string)

type IP4

type IP4 = types.IP4

var IP IP4 = IP4{10, 255, 255, 254}

func LookupNAT

func LookupNAT(vip, rip IP4) IP4

type IP4s

type IP4s = types.IP4s

type L4

type L4 = types.L4

type MAC

type MAC = types.MAC

type Maps

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

func Open

func Open(native bool, vetha, vethb string, eth ...string) (*Maps, error)

type NAT

type NAT struct {
	C      chan *Healthchecks
	Logger types.Logger
	Maps   *maps
	NetNS  *NetNS

	DefaultIP     IP4
	PhysicalMAC   MAC
	PhysicalIndex int
	// contains filtered or unexported fields
}

func (*NAT) Close

func (n *NAT) Close()

func (*NAT) Configure

func (n *NAT) Configure(h *Healthchecks)

func (*NAT) NAT

func (n *NAT) NAT(h *Healthchecks) (*Healthchecks, error)

type NetNS

type NetNS struct {
	IfA, IfB string
	IpA, IpB [4]byte
	HwA, HwB [6]byte
	Index    int
	NS       string
}

func (*NetNS) Close

func (n *NetNS) Close()

func (*NetNS) Init

func (n *NetNS) Init() error

func (*NetNS) Open

func (n *NetNS) Open() error

type Protocol

type Protocol = types.Protocol

type Real

type Real = healthchecks.Real

type Report

type Report = monitor.Report

type Service

type Service = healthchecks.Service

type Target

type Target struct {
	VIP      IP4
	RIP      IP4
	Port     uint16
	Protocol uint8
}