netlink

Documentation

Index

• Variables
• func NeighborMetadataDecoder(raw json.RawMessage) (common.Getter, error)
• func RoutingTablesMetadataDecoder(raw json.RawMessage) (common.Getter, error)
• type Neighbor
• type Neighbors
  • func (nbs *Neighbors) GetField(field string) (interface{}, error)
  • func (nbs *Neighbors) GetFieldInt64(key string) (int64, error)
  • func (nbs *Neighbors) GetFieldKeys() []string
  • func (nbs *Neighbors) GetFieldString(key string) (string, error)
• type NetNsProbe
• type NextHop
• type Prefix
  • func (p *Prefix) IsDefaultRoute() bool
  • func (p *Prefix) MarshalJSON() ([]byte, error)
  • func (p *Prefix) UnmarshalJSON(b []byte) error
• type Probe
  • func NewProbe(g *graph.Graph, hostNode *graph.Node) (*Probe, error)
  • func (u *Probe) Register(nsPath string, root *graph.Node) (*NetNsProbe, error)
  • func (u *Probe) Start()
  • func (u *Probe) Stop()
  • func (u *Probe) Unregister(nsPath string) error
• type Route
  • func (r *Route) GetNextHop(ip net.IP, ifIndex int64) *NextHop
  • func (r *Route) GetOrCreateNextHop(ip net.IP, ifIndex int64, priority int64) *NextHop
• type RoutingTable
  • func (rt *RoutingTable) GetOrCreateRoute(protocol int64, prefix net.IPNet) *Route
  • func (rt *RoutingTable) GetRoute(protocol int64, prefix net.IPNet) *Route
• type RoutingTables
  • func (rts *RoutingTables) GetField(field string) (interface{}, error)
  • func (rts *RoutingTables) GetFieldInt64(key string) (int64, error)
  • func (rts *RoutingTables) GetFieldKeys() []string
  • func (rts *RoutingTables) GetFieldString(key string) (string, error)

Variables

var (
	// IPv4DefaultRoute default IPv4 route
	IPv4DefaultRoute = net.IPNet{IP: net.IPv4zero, Mask: net.CIDRMask(0, 8*net.IPv4len)}

	// IPv6DefaultRoute default IPv6 route
	IPv6DefaultRoute = net.IPNet{IP: net.IPv6zero, Mask: net.CIDRMask(0, 8*net.IPv6len)}
)

Functions

func NeighborMetadataDecoder

func NeighborMetadataDecoder(raw json.RawMessage) (common.Getter, error)

NeighborMetadataDecoder implements a json message raw decoder

func RoutingTablesMetadataDecoder

func RoutingTablesMetadataDecoder(raw json.RawMessage) (common.Getter, error)

RoutingTablesMetadataDecoder implements a json message raw decoder

Types

type Neighbor

type Neighbor struct {
	Flags   []string `json:"Flags,omitempty"`
	MAC     string
	IP      net.IP   `json:"IP,omitempty"`
	State   []string `json:"State,omitempty"`
	Vlan    int64    `json:"Vlan,omitempty"`
	VNI     int64    `json:"VNI,omitempty"`
	IfIndex int64
}

Neighbor describes a member of the forwarding database easyjson:json

type Neighbors

type Neighbors []*Neighbor

Neighbors describes a list of neighbors easyjson:json

func (*Neighbors) GetField

func (nbs *Neighbors) GetField(field string) (interface{}, error)

GetField implements Getter interface

func (*Neighbors) GetFieldInt64

func (nbs *Neighbors) GetFieldInt64(key string) (int64, error)

GetFieldInt64 implements Getter interface

func (*Neighbors) GetFieldKeys

func (nbs *Neighbors) GetFieldKeys() []string

GetFieldKeys returns the list of valid field of a Flow

func (*Neighbors) GetFieldString

func (nbs *Neighbors) GetFieldString(key string) (string, error)

GetFieldString implements Getter interface

type NetNsProbe

type NetNsProbe struct {
	common.RWMutex
	Graph  *graph.Graph
	Root   *graph.Node
	NsPath string
	// contains filtered or unexported fields
}

NetNsProbe describes a topology probe based on netlink in a network namespace

type NextHop

type NextHop struct {
	Priority int64  `json:"Priority"`
	IP       net.IP `json:"IP,omitempty"`
	IfIndex  int64  `json:"IfIndex"`
}

NextHop describes a next hop easyjson:json

type Prefix

type Prefix struct {
	net.IPNet
}

Prefix describes prefix

func (*Prefix) IsDefaultRoute

func (p *Prefix) IsDefaultRoute() bool

IsDefaultRoute return whether the given cidr is a default route

func (*Prefix) MarshalJSON

func (p *Prefix) MarshalJSON() ([]byte, error)

MarshalJSON custom marshal function

func (*Prefix) UnmarshalJSON

func (p *Prefix) UnmarshalJSON(b []byte) error

UnmarshalJSON custom unmarshal function

type Probe

type Probe struct {
	common.RWMutex
	Graph *graph.Graph
	// contains filtered or unexported fields
}

Probe describes a list NetLink NameSpace probe to enhance the graph

func NewProbe

func NewProbe(g *graph.Graph, hostNode *graph.Node) (*Probe, error)

NewProbe creates a new netlink probe

func (*Probe) Register

func (u *Probe) Register(nsPath string, root *graph.Node) (*NetNsProbe, error)

Register a new network netlink/namespace probe in the graph

func (*Probe) Start

func (u *Probe) Start()

Start the probe

func (*Probe) Stop

func (u *Probe) Stop()

Stop the probe

func (*Probe) Unregister

func (u *Probe) Unregister(nsPath string) error

Unregister a probe from a network namespace

type Route

type Route struct {
	Protocol int64      `json:"Protocol"`
	Prefix   Prefix     `json:"Prefix"`
	NextHops []*NextHop `json:"NextHops"`
}

Route describes a route easyjson:json

func (*Route) GetNextHop

func (r *Route) GetNextHop(ip net.IP, ifIndex int64) *NextHop

GetNextHop returns the nexthop for the given ip and ifindex

func (*Route) GetOrCreateNextHop

func (r *Route) GetOrCreateNextHop(ip net.IP, ifIndex int64, priority int64) *NextHop

GetOrCreateNextHop creates if not existing a new nexthop and returns it

type RoutingTable

type RoutingTable struct {
	ID     int64    `json:"ID"`
	Src    net.IP   `json:"Src"`
	Routes []*Route `json:"Routes"`
}

RoutingTable describes a list of Routes easyjson:json

func (*RoutingTable) GetOrCreateRoute

func (rt *RoutingTable) GetOrCreateRoute(protocol int64, prefix net.IPNet) *Route

GetOrCreateRoute creates if not existing a new route and returns it

func (*RoutingTable) GetRoute

func (rt *RoutingTable) GetRoute(protocol int64, prefix net.IPNet) *Route

GetRoute returns route for the given protocol and prefix

type RoutingTables

type RoutingTables []*RoutingTable

RoutingTables describes a list of routing table easyjson:json

func (*RoutingTables) GetField

func (rts *RoutingTables) GetField(field string) (interface{}, error)

GetField implements Getter interface

func (*RoutingTables) GetFieldInt64

func (rts *RoutingTables) GetFieldInt64(key string) (int64, error)

GetFieldInt64 implements Getter interface

func (*RoutingTables) GetFieldKeys

func (rts *RoutingTables) GetFieldKeys() []string

GetFieldKeys returns the list of valid field of a Flow

func (*RoutingTables) GetFieldString

func (rts *RoutingTables) GetFieldString(key string) (string, error)

GetFieldString implements Getter interface