topology

Aug 17, 2021

Changes in this version

+ func ContainerMetadataDecoder(raw json.RawMessage) (getter.Getter, error)

+ func RegisterContainer()

+ type ContainerMetadata struct

+ Hosts Hosts

+ ID string

+ Image string

+ ImageID string

+ InitProcessPID int64

+ Labels graph.Metadata

+ Runtime string

+ Status string

+ func (obj *ContainerMetadata) GetField(key string) (interface{}, error)

+ func (obj *ContainerMetadata) GetFieldBool(key string) (bool, error)

+ func (obj *ContainerMetadata) GetFieldInt64(key string) (int64, error)

+ func (obj *ContainerMetadata) GetFieldKeys() []string

+ func (obj *ContainerMetadata) GetFieldString(key string) (string, error)

+ func (obj *ContainerMetadata) MatchBool(key string, predicate getter.BoolPredicate) bool

+ func (obj *ContainerMetadata) MatchInt64(key string, predicate getter.Int64Predicate) bool

+ func (obj *ContainerMetadata) MatchString(key string, predicate getter.StringPredicate) bool

+ func (v *ContainerMetadata) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *ContainerMetadata) UnmarshalJSON(data []byte) error

+ func (v ContainerMetadata) MarshalEasyJSON(w *jwriter.Writer)

+ func (v ContainerMetadata) MarshalJSON() ([]byte, error)

+ type Hosts struct

+ ByIP graph.Metadata

+ Hostname string

+ IP string

+ func ReadHosts(path string) (*Hosts, error)

+ func (obj *Hosts) GetField(key string) (interface{}, error)

+ func (obj *Hosts) GetFieldBool(key string) (bool, error)

+ func (obj *Hosts) GetFieldInt64(key string) (int64, error)

+ func (obj *Hosts) GetFieldKeys() []string

+ func (obj *Hosts) GetFieldString(key string) (string, error)

+ func (obj *Hosts) MatchBool(key string, predicate getter.BoolPredicate) bool

+ func (obj *Hosts) MatchInt64(key string, predicate getter.Int64Predicate) bool

+ func (obj *Hosts) MatchString(key string, predicate getter.StringPredicate) bool

+ func (v *Hosts) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Hosts) UnmarshalJSON(data []byte) error

+ func (v Hosts) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Hosts) MarshalJSON() ([]byte, error)

Dec 7, 2020

Changes in this version

+ var ErrNoNextHop = errors.New("no next hop")

Nov 15, 2019

Changes in this version

type InterfaceMetric

+ func (obj *InterfaceMetric) GetFieldBool(key string) (bool, error)

+ func (obj *InterfaceMetric) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *InterfaceMetric) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *InterfaceMetric) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *InterfaceMetric) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *InterfaceMetric) UnmarshalJSON(data []byte) error

+ func (v InterfaceMetric) MarshalEasyJSON(w *jwriter.Writer)

+ func (v InterfaceMetric) MarshalJSON() ([]byte, error)

type Neighbor

+ func (obj *Neighbor) GetField(key string) (interface{}, error)

+ func (obj *Neighbor) GetFieldBool(key string) (bool, error)

+ func (obj *Neighbor) GetFieldInt64(key string) (int64, error)

+ func (obj *Neighbor) GetFieldKeys() []string

+ func (obj *Neighbor) GetFieldString(key string) (string, error)

+ func (obj *Neighbor) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *Neighbor) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *Neighbor) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *Neighbor) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Neighbor) UnmarshalJSON(data []byte) error

+ func (v Neighbor) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Neighbor) MarshalJSON() ([]byte, error)

type Neighbors

+ func (obj *Neighbors) GetField(key string) (interface{}, error)

+ func (obj *Neighbors) GetFieldBool(key string) (bool, error)

+ func (obj *Neighbors) GetFieldInt64(key string) (int64, error)

+ func (obj *Neighbors) GetFieldKeys() []string

+ func (obj *Neighbors) GetFieldString(key string) (string, error)

+ func (obj *Neighbors) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *Neighbors) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *Neighbors) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *Neighbors) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Neighbors) UnmarshalJSON(data []byte) error

+ func (v Neighbors) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Neighbors) MarshalJSON() ([]byte, error)

type NextHop

+ func (obj *NextHop) GetField(key string) (interface{}, error)

+ func (obj *NextHop) GetFieldBool(key string) (bool, error)

+ func (obj *NextHop) GetFieldInt64(key string) (int64, error)

+ func (obj *NextHop) GetFieldKeys() []string

+ func (obj *NextHop) GetFieldString(key string) (string, error)

+ func (obj *NextHop) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *NextHop) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *NextHop) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *NextHop) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *NextHop) UnmarshalJSON(data []byte) error

+ func (v NextHop) MarshalEasyJSON(w *jwriter.Writer)

+ func (v NextHop) MarshalJSON() ([]byte, error)

type Route

+ func (obj *Route) GetField(key string) (interface{}, error)

+ func (obj *Route) GetFieldBool(key string) (bool, error)

+ func (obj *Route) GetFieldInt64(key string) (int64, error)

+ func (obj *Route) GetFieldKeys() []string

+ func (obj *Route) GetFieldString(key string) (string, error)

+ func (obj *Route) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *Route) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *Route) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *Route) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Route) UnmarshalJSON(data []byte) error

+ func (v Route) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Route) MarshalJSON() ([]byte, error)

type RoutingTable

+ func (obj *RoutingTable) GetField(key string) (interface{}, error)

+ func (obj *RoutingTable) GetFieldBool(key string) (bool, error)

+ func (obj *RoutingTable) GetFieldInt64(key string) (int64, error)

+ func (obj *RoutingTable) GetFieldKeys() []string

+ func (obj *RoutingTable) GetFieldString(key string) (string, error)

+ func (obj *RoutingTable) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *RoutingTable) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *RoutingTable) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *RoutingTable) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *RoutingTable) UnmarshalJSON(data []byte) error

+ func (v RoutingTable) MarshalEasyJSON(w *jwriter.Writer)

+ func (v RoutingTable) MarshalJSON() ([]byte, error)

type RoutingTables

+ func (obj *RoutingTables) GetField(key string) (interface{}, error)

+ func (obj *RoutingTables) GetFieldBool(key string) (bool, error)

+ func (obj *RoutingTables) GetFieldInt64(key string) (int64, error)

+ func (obj *RoutingTables) GetFieldKeys() []string

+ func (obj *RoutingTables) GetFieldString(key string) (string, error)

+ func (obj *RoutingTables) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *RoutingTables) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *RoutingTables) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *RoutingTables) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *RoutingTables) UnmarshalJSON(data []byte) error

+ func (v RoutingTables) MarshalEasyJSON(w *jwriter.Writer)

+ func (v RoutingTables) MarshalJSON() ([]byte, error)

Jul 16, 2019

Changes in this version

+ var IPv4DefaultRoute = net.IPNet

+ var IPv6DefaultRoute = net.IPNet

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

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

+ type Neighbor struct

+ Flags []string

+ IP net.IP

+ IfIndex int64

+ MAC string

+ State []string

+ VNI int64

+ Vlan int64

+ type Neighbors []*Neighbor

+ type NextHop struct

+ IP net.IP

+ IfIndex int64

+ MAC string

+ Priority int64

+ func GetNextHop(node *graph.Node, ip net.IP) (*NextHop, error)

+ type Prefix net.IPNet

+ func (p *Prefix) IsDefaultRoute() bool

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

+ func (p *Prefix) String() string

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

+ type Route struct

+ NextHops []*NextHop

+ Prefix Prefix

+ Protocol int64

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

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

+ type RoutingTable struct

+ ID int64

+ Routes []*Route

+ Src net.IP

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

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

+ type RoutingTables []*RoutingTable

May 17, 2019

Changes in this version

+ func NewLink(g *graph.Graph, node1 *graph.Node, node2 *graph.Node, relationType string, ...) (*graph.Edge, error)

Mar 21, 2019

Changes in this version

+ func AddLink(g *graph.Graph, node1 *graph.Node, node2 *graph.Node, relationType string, ...) (*graph.Edge, error)

+ func HaveLink(g *graph.Graph, node1 *graph.Node, node2 *graph.Node, relationType string) bool

Dec 3, 2018

Changes in this version

+ var ErrInvalidSchema = errors.New("Invalid schema")

+ var ErrNoPathToHost = func(name string) error

+ func InterfaceMetricMetadataDecoder(raw json.RawMessage) (common.Getter, error)

+ func IsInterfaceUp(node *graph.Node) bool

type InterfaceMetric

+ func (im *InterfaceMetric) GetField(key string) (interface{}, error)

+ func (im *InterfaceMetric) GetFieldKeys() []string

+ func (im *InterfaceMetric) GetFieldString(key string) (string, error)

+ type SubscriberEndpoint struct

+ Graph *graph.Graph

+ func NewSubscriberEndpoint(pool ws.StructSpeakerPool, g *graph.Graph, ...) *SubscriberEndpoint

+ func (t *SubscriberEndpoint) OnConnected(c ws.Speaker)

+ func (t *SubscriberEndpoint) OnDisconnected(c ws.Speaker)

+ func (t *SubscriberEndpoint) OnEdgeAdded(e *graph.Edge)

+ func (t *SubscriberEndpoint) OnEdgeDeleted(e *graph.Edge)

+ func (t *SubscriberEndpoint) OnEdgeUpdated(e *graph.Edge)

+ func (t *SubscriberEndpoint) OnNodeAdded(n *graph.Node)

+ func (t *SubscriberEndpoint) OnNodeDeleted(n *graph.Node)

+ func (t *SubscriberEndpoint) OnNodeUpdated(n *graph.Node)

+ func (t *SubscriberEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

Oct 9, 2018

Changes in this version

+ var InvalidSchema = errors.New("Invalid schema")

+ type SchemaValidator struct

+ func NewSchemaValidator() (*SchemaValidator, error)

+ func (v *SchemaValidator) ValidateEdge(edge *graph.Edge) error

+ func (v *SchemaValidator) ValidateNode(node *graph.Node) error

Sep 14, 2018

Changes in this version

type TopologySubscriberEndpoint

+ func (t *TopologySubscriberEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

Aug 8, 2018

Changes in this version

+ var ErrNetworkPathNotFound = func(name string) error

type InterfaceMetric

+ func (im *InterfaceMetric) GetFields() []string

Apr 12, 2018

Changes in this version

+ func GetOwnershipLink(g *graph.Graph, parent *graph.Node, child *graph.Node, metadata graph.Metadata) *graph.Edge

type InterfaceMetric

+ func (im *InterfaceMetric) Split(cut int64) (common.Metric, common.Metric)

type TopologySubscriberEndpoint

+ func (t *TopologySubscriberEndpoint) OnWSStructMessage(c shttp.WSSpeaker, msg *shttp.WSStructMessage)

Jan 29, 2018

Changes in this version

+ type InterfaceMetric struct

+ Collisions int64

+ Last int64

+ Multicast int64

+ RxBytes int64

+ RxCompressed int64

+ RxCrcErrors int64

+ RxDropped int64

+ RxErrors int64

+ RxFifoErrors int64

+ RxFrameErrors int64

+ RxLengthErrors int64

+ RxMissedErrors int64

+ RxOverErrors int64

+ RxPackets int64

+ Start int64

+ TxAbortedErrors int64

+ TxBytes int64

+ TxCarrierErrors int64

+ TxCompressed int64

+ TxDropped int64

+ TxErrors int64

+ TxFifoErrors int64

+ TxHeartbeatErrors int64

+ TxPackets int64

+ TxWindowErrors int64

+ func (im *InterfaceMetric) Add(m common.Metric) common.Metric

+ func (im *InterfaceMetric) GetFieldInt64(field string) (int64, error)

+ func (im *InterfaceMetric) GetLast() int64

+ func (im *InterfaceMetric) GetStart() int64

+ func (im *InterfaceMetric) IsZero() bool

+ func (im *InterfaceMetric) SetLast(last int64)

+ func (im *InterfaceMetric) SetStart(start int64)

+ func (im *InterfaceMetric) Sub(m common.Metric) common.Metric

Dec 6, 2017

Changes in this version

+ type TopologySubscriberEndpoint struct

+ Graph *graph.Graph

+ func NewTopologySubscriberEndpoint(pool shttp.WSJSONSpeakerPool, auth *shttp.AuthenticationOpts, g *graph.Graph) *TopologySubscriberEndpoint

+ func (t *TopologySubscriberEndpoint) OnConnected(c shttp.WSSpeaker)

+ func (t *TopologySubscriberEndpoint) OnDisconnected(c shttp.WSSpeaker)

+ func (t *TopologySubscriberEndpoint) OnEdgeAdded(e *graph.Edge)

+ func (t *TopologySubscriberEndpoint) OnEdgeDeleted(e *graph.Edge)

+ func (t *TopologySubscriberEndpoint) OnEdgeUpdated(e *graph.Edge)

+ func (t *TopologySubscriberEndpoint) OnNodeAdded(n *graph.Node)

+ func (t *TopologySubscriberEndpoint) OnNodeDeleted(n *graph.Node)

+ func (t *TopologySubscriberEndpoint) OnNodeUpdated(n *graph.Node)

+ func (t *TopologySubscriberEndpoint) OnWSJSONMessage(c shttp.WSSpeaker, msg *shttp.WSJSONMessage)

Oct 12, 2017

Changes in this version

+ func IsOwnershipLinked(g *graph.Graph, node *graph.Node) bool

Aug 1, 2017

Changes in this version

+ func NamespaceFromNode(g *graph.Graph, n *graph.Node) (string, string, error)

May 5, 2017

Changes in this version

+ const Layer2Link

+ const OwnershipLink

+ var Layer2Metadata = graph.Metadata

+ var OwnershipMetadata = graph.Metadata

+ func AddLayer2Link(g *graph.Graph, node1 *graph.Node, node2 *graph.Node, metadata graph.Metadata) *graph.Edge

+ func AddOwnershipLink(g *graph.Graph, parent *graph.Node, child *graph.Node, metadata graph.Metadata) *graph.Edge

+ func HaveLayer2Link(g *graph.Graph, node1 *graph.Node, node2 *graph.Node, metadata graph.Metadata) bool

+ func HaveOwnershipLink(g *graph.Graph, parent *graph.Node, child *graph.Node, metadata graph.Metadata) bool

type TIDMapper

+ func (t *TIDMapper) OnEdgeDeleted(e *graph.Edge)

Mar 31, 2017

Changes in this version

+ func ExecuteGremlinQuery(g *graph.Graph, query string) (traversal.GraphTraversalStep, error)

Jan 27, 2017

Changes in this version

+ type HostNodeTIDMap map[string][]string

+ func BuildHostNodeTIDMap(nodes []*graph.Node) HostNodeTIDMap

Dec 9, 2016

Changes in this version

+ func NewNetNSContextByNode(g *graph.Graph, n *graph.Node) (*common.NetNSContext, error)

Oct 6, 2016

Changes in this version

type GraphPathGremlinTraversalStep

+ func (s *GraphPathGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ type TIDMapper struct

+ Graph *graph.Graph

+ func NewTIDMapper(g *graph.Graph) *TIDMapper

+ func (t *TIDMapper) OnEdgeAdded(e *graph.Edge)

+ func (t *TIDMapper) OnEdgeUpdated(e *graph.Edge)

+ func (t *TIDMapper) OnNodeAdded(n *graph.Node)

+ func (t *TIDMapper) OnNodeUpdated(n *graph.Node)

+ func (t *TIDMapper) Start()

+ func (t *TIDMapper) Stop()

Sep 15, 2016

Changes in this version

type GraphPathGremlinTraversalStep

+ func (s *GraphPathGremlinTraversalStep) Params() (params []interface{})

+ func (s *GraphPathGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

Aug 4, 2016

Changes in this version

+ func GraphPath(g *graph.Graph, n *graph.Node) string

+ type GraphPathGremlinTraversalStep struct

+ func (s *GraphPathGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ type GraphPathTraversalStep struct

+ func (p *GraphPathTraversalStep) Error() error

+ func (p *GraphPathTraversalStep) MarshalJSON() ([]byte, error)

+ func (p *GraphPathTraversalStep) Values() []interface{}

+ type TopologyTraversalExtension struct

+ func NewTopologyTraversalExtension() *TopologyTraversalExtension

+ func (e *TopologyTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalStepParams) (traversal.GremlinTraversalStep, error)

+ func (e *TopologyTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

Apr 26, 2016

Changes in this version

+ func IsLayer2Edge(e *graph.Edge) bool

+ func IsOwnershipEdge(e *graph.Edge) bool

+ func LookupNodeFromNodePathString(g *graph.Graph, s string) *graph.Node

+ type NodePath struct

+ Nodes []*graph.Node

+ func (p NodePath) Marshal() string

Feb 23, 2016

Changes in this version

type Server

+ Service string

+ func (s *Server) RegisterRPCEndpoints()

Feb 10, 2016

Changes in this version

+ type Server struct

+ Addr string

+ Graph *graph.Graph

+ Port int

+ Router *mux.Router

+ func NewServer(g *graph.Graph, a string, p int, router *mux.Router) *Server

+ func NewServerFromConfig(s string, g *graph.Graph, router *mux.Router) (*Server, error)

+ func (s *Server) ListenAndServe()

+ func (s *Server) RegisterRpcEndpoints()

+ func (s *Server) RegisterStaticEndpoints()

+ func (s *Server) Stop()

+ func (s *Server) TopologyIndex(w http.ResponseWriter, r *http.Request)