runners

Documentation

Index

• func InterceptorLogger(l *zap.Logger) logging.Logger
• 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
• func ProcessLinkAlias(conf *nodenet.PodNetConf, pod *corev1.Pod, ifName string) error
• type GWNets
• type NATSetup
  • func NewNATSetup(port int) NATSetup

Functions

func InterceptorLogger

func InterceptorLogger(l *zap.Logger) logging.Logger

ref: https://github.com/grpc-ecosystem/go-grpc-middleware/blob/71d7422112b1d7fadd4b8bf12a6f33ba6d22e98e/interceptors/logging/examples/zap/example_test.go#L17

func NewCoildServer

func NewCoildServer(l net.Listener, mgr manager.Manager, nodeIPAM ipam.NodeIPAM, podNet nodenet.PodNetwork, setup NATSetup, cfg *config.Config, logger *zap.Logger,
	aliasFunc func(conf *nodenet.PodNetConf, pod *corev1.Pod, ifName string) error) 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.

func ProcessLinkAlias

func ProcessLinkAlias(conf *nodenet.PodNetConf, pod *corev1.Pod, ifName string) error

Types

type GWNets

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

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.