runners

Documentation

Index

• func NewCoildServer(l net.Listener, mgr manager.Manager, nodeIPAM ipam.NodeIPAM, ...) manager.Runnable
• func NewGarbageCollector(mgr manager.Manager, log logr.Logger, interval time.Duration) manager.Runnable
• func NewRouter(mgr manager.Manager, log logr.Logger, nodeName string, ...) manager.Runnable
• type GWNets
• type NATSetup
  • func NewNATSetup(port int) NATSetup

Functions

func NewCoildServer

func NewCoildServer(l net.Listener, mgr manager.Manager, nodeIPAM ipam.NodeIPAM, podNet nodenet.PodNetwork, setup NATSetup, logger *zap.Logger) manager.Runnable

NewCoildServer returns an implementation of cnirpc.CNIServer for coild.

func NewGarbageCollector

func NewGarbageCollector(mgr manager.Manager, log logr.Logger, interval time.Duration) manager.Runnable

NewGarbageCollector creates a manager.Runnable to collect orphaned AddressBlocks of deleted nodes.

func NewRouter

func NewRouter(mgr manager.Manager, log logr.Logger, nodeName string, notifyCh <-chan struct{}, syncer nodenet.RouteSyncer, interval time.Duration) manager.Runnable

NewRouter creates a manager.Runnable for coil-router.

Types

type GWNets

type GWNets struct {
	Gateway  net.IP
	Networks []*net.IPNet
}

GWNets represents networks for a destination.

type NATSetup

type NATSetup interface {
	Hook([]GWNets, *zap.Logger) func(ipv4, ipv6 net.IP) error
}

NATSetup represents a NAT setup function for Pods.

func NewNATSetup

func NewNATSetup(port int) NATSetup

NewNATSetup creates a NATSetup using founat package. `port` is the UDP port number to accept Foo-over-UDP packets.