watcher

Documentation

Index

• type MissWatcher
  • func New(logger lager.Logger, subscriber sub, locker sync.Locker, resolver resolver, ...) MissWatcher
• type NamespaceWatcher
  • func (nw *NamespaceWatcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type Neigh
• type Neighbor
• type Resolver
  • func (d *Resolver) ResolveMisses(misses <-chan Neighbor, knownNeighbors chan<- Neighbor)

Types

type MissWatcher

type MissWatcher interface {
	StartMonitor(ns namespace.Namespace, vxlanLinkName string) error
	StopMonitor(ns namespace.Namespace) error
}

func New

func New(logger lager.Logger, subscriber sub, locker sync.Locker, resolver resolver, arpInserter arpInserter) MissWatcher

type NamespaceWatcher

type NamespaceWatcher struct {
	MissWatcher MissWatcher
	Namespace   namespace.Namespace
	DeviceName  string
}

func (*NamespaceWatcher) Run

func (nw *NamespaceWatcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type Neigh

type Neigh struct {
	LinkIndex    int
	Family       int
	State        int
	Type         int
	Flags        int
	IP           net.IP
	HardwareAddr net.HardwareAddr
}

type Neighbor

type Neighbor struct {
	SandboxName string
	VTEP        net.IP
	Neigh       Neigh
}

type Resolver

type Resolver struct {
	Logger lager.Logger
	Store  store.Store
}

func (*Resolver) ResolveMisses

func (d *Resolver) ResolveMisses(misses <-chan Neighbor, knownNeighbors chan<- Neighbor)