routemanager

Jun 4, 2024

Changes in this version

+ const NetbirdVPNTableID — linux/amd64

+ const NetbirdVPNTableName — linux/amd64

+ var ErrRouteNotAllowed = errors.New("route not allowed")

+ var ErrRouteNotFound = errors.New("route not found")

+ var ErrTableIDExists = errors.New("ID exists with different name") — linux/amd64

+ func GetNextHop(ip netip.Addr) (netip.Addr, *net.Interface, error)

+ type AddRouteFunc func(prefix netip.Prefix) (nexthop netip.Addr, intf *net.Interface, err error)

+ type DefaultManager struct

+ func NewManager(ctx context.Context, pubKey string, wgInterface *iface.WGIface, ...) *DefaultManager

+ func (m *DefaultManager) EnableServerRouter(firewall firewall.Manager) error

+ func (m *DefaultManager) GetClientRoutes() map[route.HAUniqueID]*clientNetwork

+ func (m *DefaultManager) GetRouteSelector() *routeselector.RouteSelector

+ func (m *DefaultManager) Init() (peer.BeforeAddPeerHookFunc, peer.AfterRemovePeerHookFunc, error)

+ func (m *DefaultManager) InitialRouteRange() []string

+ func (m *DefaultManager) SetRouteChangeListener(listener listener.NetworkChangeListener)

+ func (m *DefaultManager) Stop()

+ func (m *DefaultManager) TriggerSelection(networks route.HAMap)

+ func (m *DefaultManager) UpdateRoutes(updateSerial uint64, newRoutes []*route.Route) (map[route.ID]*route.Route, route.HAMap, error)

+ type MSFT_NetNeighbor struct — windows/amd64

+ AddressFamily uint16

+ IPAddress string

+ InterfaceAlias string

+ InterfaceIndex uint32

+ LinkLayerAddress string

+ State uint8

+ type MSFT_NetRoute struct — windows/amd64

+ AddressFamily uint16

+ DestinationPrefix string

+ InterfaceAlias string

+ InterfaceIndex int32

+ NextHop string

+ type Manager interface

+ EnableServerRouter func(firewall firewall.Manager) error

+ GetRouteSelector func() *routeselector.RouteSelector

+ Init func() (peer.BeforeAddPeerHookFunc, peer.AfterRemovePeerHookFunc, error)

+ InitialRouteRange func() []string

+ SetRouteChangeListener func(listener listener.NetworkChangeListener)

+ Stop func()

+ TriggerSelection func(route.HAMap)

+ UpdateRoutes func(updateSerial uint64, newRoutes []*route.Route) (map[route.ID]*route.Route, route.HAMap, error)

+ type MockManager struct

+ GetRouteSelectorFunc func() *routeselector.RouteSelector

+ StopFunc func()

+ TriggerSelectionFunc func(haMap route.HAMap)

+ UpdateRoutesFunc func(updateSerial uint64, newRoutes []*route.Route) (map[route.ID]*route.Route, route.HAMap, error)

+ func (m *MockManager) EnableServerRouter(firewall firewall.Manager) error

+ func (m *MockManager) GetRouteSelector() *routeselector.RouteSelector

+ func (m *MockManager) Init() (peer.BeforeAddPeerHookFunc, peer.AfterRemovePeerHookFunc, error)

+ func (m *MockManager) InitialRouteRange() []string

+ func (m *MockManager) SetRouteChangeListener(listener listener.NetworkChangeListener)

+ func (m *MockManager) Start(ctx context.Context, iface *iface.WGIface)

+ func (m *MockManager) Stop()

+ func (m *MockManager) TriggerSelection(networks route.HAMap)

+ func (m *MockManager) UpdateRoutes(updateSerial uint64, newRoutes []*route.Route) (map[route.ID]*route.Route, route.HAMap, error)

+ type Neighbor struct — windows/amd64

+ AddressFamily uint16

+ IPAddress netip.Addr

+ InterfaceAlias string

+ InterfaceIndex uint32

+ LinkLayerAddress string

+ State uint8

+ func GetNeighbors() ([]Neighbor, error)

+ type RemoveRouteFunc func(prefix netip.Prefix, nexthop netip.Addr, intf *net.Interface) error

+ type Route struct — darwin/amd64, windows/amd64

+ Destination netip.Prefix

+ Dst netip.Prefix

+ Gw netip.Addr

+ Interface *net.Interface

+ Nexthop netip.Addr

+ func GetRoutes() ([]Route, error)

+ func MsgToRoute(msg *route.RouteMessage) (*Route, error)

+ type RouteManager struct

+ func NewRouteManager(addRoute AddRouteFunc, removeRoute RemoveRouteFunc) *RouteManager

+ func (rm *RouteManager) AddRouteRef(connID nbnet.ConnectionID, prefix netip.Prefix) error

+ func (rm *RouteManager) Flush() error

+ func (rm *RouteManager) RemoveRouteRef(connID nbnet.ConnectionID) error