probes/

Sep 12, 2019

Changes in this version

+ var ErrNotStopped = errors.New("service is not stopped")

+ type Context struct

+ Config config.Config

+ Graph *graph.Graph

+ Logger logging.Logger

+ RootNode *graph.Node

+ type Handler interface

+ Init func(ctx Context, bundle *probe.Bundle) (Handler, error)

+ type ProbeWrapper struct

+ func NewProbeWrapper(handler handler) *ProbeWrapper

+ func (p *ProbeWrapper) GetStatus() interface{}

+ func (p *ProbeWrapper) Start()

+ func (p *ProbeWrapper) Stop()

Dec 6, 2017

Changes in this version

+ type NextHop struct

+ Ip net.IP

+ Priority int

+ type Route struct

+ Nexthops []NextHop

+ Prefix string

+ type RoutingTable struct

+ Id int

+ Routes []Route

+ Src net.IP

Nov 14, 2017

Changes in this version

type NetNSProbe

+ func (u *NetNSProbe) Watch(path string)

type NetNs

+ func (ns *NetNs) Equal(o *NetNs) bool

Oct 12, 2017

Changes in this version

+ type BridgeOfProbe struct

+ Address string

+ Bridge string

+ BridgeNode *graph.Node

+ Host string

+ OvsOfProbe *OvsOfProbe

+ Rules map[string][]*Rule

+ UUID string

+ type Event struct

+ Action string

+ Bridge string

+ Date int64

+ RawRule *Rule

+ Rules []*Rule

+ type Execute interface

+ ExecCommand func(string, ...string) ([]byte, error)

+ ExecCommandPipe func(context.Context, string, ...string) (io.Reader, error)

type NeutronProbe

+ func (mapper *NeutronProbe) OnNodeDeleted(n *graph.Node)

+ type OvsOfProbe struct

+ BridgeProbes map[string]*BridgeOfProbe

+ CA string

+ Certificate string

+ Graph *graph.Graph

+ Host string

+ PrivateKey string

+ Root *graph.Node

+ Translation map[string]string

+ func NewOvsOfProbe(g *graph.Graph, root *graph.Node, host string) *OvsOfProbe

+ func (o *OvsOfProbe) NewBridgeProbe(host string, bridge string, uuid string, bridgeNode *graph.Node) (*BridgeOfProbe, error)

+ func (o *OvsOfProbe) OnOvsBridgeAdd(bridgeNode *graph.Node)

+ func (o *OvsOfProbe) OnOvsBridgeDel(uuid string, bridgeNode *graph.Node)

type OvsdbProbe

+ OvsOfProbe *OvsOfProbe

+ type RealExecute struct

+ func (r RealExecute) ExecCommand(com string, args ...string) ([]byte, error)

+ func (r RealExecute) ExecCommandPipe(ctx context.Context, com string, args ...string) (io.Reader, error)

+ type Rule struct

+ Actions string

+ Cookie uint64

+ Filter string

+ InPort int

+ Priority int

+ Table int

+ UUID string

Aug 1, 2017

Changes in this version

+ type NeutronProbe struct

+ func NewNeutronProbe(g *graph.Graph, wspool *shttp.WSAsyncClientPool, ...) (*NeutronProbe, error)

+ func NewNeutronProbeFromConfig(g *graph.Graph, wspool *shttp.WSAsyncClientPool) (*NeutronProbe, error)

+ func (mapper *NeutronProbe) EnhanceNode(node *graph.Node)

+ func (mapper *NeutronProbe) OnNodeAdded(n *graph.Node)

+ func (mapper *NeutronProbe) OnNodeUpdated(n *graph.Node)

+ func (mapper *NeutronProbe) Start()

+ func (mapper *NeutronProbe) Stop()

+ type OpenContrailProbe struct

+ func NewOpenContrailProbeFromConfig(g *graph.Graph, r *graph.Node) *OpenContrailProbe

+ func (mapper *OpenContrailProbe) OnNodeAdded(n *graph.Node)

+ func (mapper *OpenContrailProbe) OnNodeDeleted(n *graph.Node)

+ func (mapper *OpenContrailProbe) OnNodeUpdated(n *graph.Node)

+ func (mapper *OpenContrailProbe) Start()

+ func (mapper *OpenContrailProbe) Stop()

May 5, 2017

Changes in this version

type NetLinkProbe

+ func (u *NetLinkProbe) Register(nsPath string, root *graph.Node) (*NetNsNetLinkProbe, error)

+ func (u *NetLinkProbe) Unregister(nsPath string) error

type NetNSProbe

+ NetLinkProbe *NetLinkProbe

+ type NetNsNetLinkProbe struct

+ Graph *graph.Graph

+ NsPath string

+ Root *graph.Node

+ type OpenContrailMdata struct

+ LocalIP string

+ Mac string

+ UUID string

+ VRF string

Mar 31, 2017

Changes in this version

+ const DockerClientAPIVersion

Jan 27, 2017

Changes in this version

type Attributes

+ IPs string

+ type PeeringProbe struct

+ func NewPeeringProbe(g *graph.Graph) *PeeringProbe

+ func (p *PeeringProbe) OnNodeAdded(n *graph.Node)

+ func (p *PeeringProbe) OnNodeDeleted(n *graph.Node)

+ func (p *PeeringProbe) OnNodeUpdated(n *graph.Node)

+ func (p *PeeringProbe) Start()

+ func (p *PeeringProbe) Stop()

Dec 9, 2016

Changes in this version

+ const FabricNamespace

type FabricProbe

+ func (fb *FabricProbe) LinkNodes(parent *graph.Node, child *graph.Node)

+ func (fb *FabricProbe) OnMessage(c *shttp.WSClient, msg shttp.WSMessage)

+ func (fb *FabricProbe) OnNodeDeleted(n *graph.Node)

+ func (fb *FabricProbe) RegisterLink(parentNode *graph.Node, parentMetadata graph.Metadata, ...)

+ func (fb *FabricProbe) UnregisterLink(parentNode *graph.Node)

+ type FabricRegisterLinkWSMessage struct

+ ChildMetadata graph.Metadata

+ ParentMetadata graph.Metadata

+ ParentNodeID graph.Identifier

type NetNsNetLinkTopoUpdater

+ func (nu *NetNsNetLinkTopoUpdater) Run(ns *NetNs)

Nov 8, 2016

Changes in this version

+ type ExtIDs struct

+ AttachedMac string

+ IfaceID string

+ type OpenContrailMapper struct

+ func NewOpenContrailMapper(g *graph.Graph, r *graph.Node) *OpenContrailMapper

+ func (mapper *OpenContrailMapper) OnNodeAdded(n *graph.Node)

+ func (mapper *OpenContrailMapper) OnNodeDeleted(n *graph.Node)

+ func (mapper *OpenContrailMapper) OnNodeUpdated(n *graph.Node)

+ func (mapper *OpenContrailMapper) Start()

+ func (mapper *OpenContrailMapper) Stop()

+ type PortMetadata struct

Oct 6, 2016

Changes in this version

type Attributes

+ PortID string

+ type FabricProbe struct

+ Graph *graph.Graph

+ func NewFabricProbe(g *graph.Graph) *FabricProbe

+ func (fb *FabricProbe) OnEdgeAdded(e *graph.Edge)

+ func (fb *FabricProbe) Start()

+ func (fb *FabricProbe) Stop()

+ type NeutronPortNotFound struct

+ MAC string

+ func (e NeutronPortNotFound) Error() string

Sep 15, 2016

Changes in this version

+ const DockerClientApiVersion

Aug 4, 2016

Changes in this version

+ type ContainerInfo struct

+ Node *graph.Node

+ Pid int

type NetNSProbe

+ func NewNetNSProbeFromConfig(g *graph.Graph, n *graph.Node) *NetNSProbe

+ type NetNs struct

+ func (ns *NetNs) String() string

Apr 26, 2016

Changes in this version

+ const RunningState

+ const StoppedState

+ const StoppingState

type Attributes

+ NetworkID string

+ NetworkName string

Feb 23, 2016

Changes in this version

+ type Attributes struct

+ TenantID string

+ VNI string

+ type DockerContainerAttributes struct

+ ContainerID string

+ type DockerProbe struct

+ func NewDockerProbe(g *graph.Graph, n *graph.Node, dockerURL string) *DockerProbe

+ func NewDockerProbeFromConfig(g *graph.Graph, n *graph.Node) *DockerProbe

+ func (probe *DockerProbe) Start()

+ func (probe *DockerProbe) Stop()

type NetNSProbe

+ func (u *NetNSProbe) Register(path string, extraMetadata *graph.Metadata)

+ func (u *NetNSProbe) Unregister(path string)

+ type NeutronMapper struct

+ func NewNeutronMapper(g *graph.Graph, authURL string, username string, password string, ...) (*NeutronMapper, error)

+ func NewNeutronMapperFromConfig(g *graph.Graph) (*NeutronMapper, error)

+ func (mapper *NeutronMapper) EnhanceNode(node *graph.Node)

+ func (mapper *NeutronMapper) OnEdgeAdded(n *graph.Edge)

+ func (mapper *NeutronMapper) OnEdgeDeleted(n *graph.Edge)

+ func (mapper *NeutronMapper) OnEdgeUpdated(n *graph.Edge)

+ func (mapper *NeutronMapper) OnNodeAdded(n *graph.Node)

+ func (mapper *NeutronMapper) OnNodeDeleted(n *graph.Node)

+ func (mapper *NeutronMapper) OnNodeUpdated(n *graph.Node)

+ func (mapper *NeutronMapper) Start()

+ func (mapper *NeutronMapper) Stop()

type OvsdbProbe

+ OvsMon *ovsdb.OvsMonitor

+ func NewOvsdbProbeFromConfig(g *graph.Graph, n *graph.Node) *OvsdbProbe

+ func (o *OvsdbProbe) Stop()

+ type TopologyProbeBundle struct

+ func NewTopologyProbeBundleFromConfig(g *graph.Graph, n *graph.Node) *TopologyProbeBundle

Feb 10, 2016

Changes in this version

+ type NetLinkProbe struct

+ Graph *graph.Graph

+ Root *graph.Node

+ func NewNetLinkProbe(g *graph.Graph, n *graph.Node) *NetLinkProbe

+ func (u *NetLinkProbe) Run()

+ func (u *NetLinkProbe) Start()

+ func (u *NetLinkProbe) Stop()

+ type NetNSProbe struct

+ Graph *graph.Graph

+ Root *graph.Node

+ func NewNetNSProbe(g *graph.Graph, n *graph.Node) *NetNSProbe

+ func (u *NetNSProbe) Start()

+ func (u *NetNSProbe) Stop()

+ type NetNsNetLinkTopoUpdater struct

+ Graph *graph.Graph

+ Root *graph.Node

+ func NewNetNsNetLinkTopoUpdater(g *graph.Graph, n *graph.Node) *NetNsNetLinkTopoUpdater

+ func (nu *NetNsNetLinkTopoUpdater) Start(path string)

+ func (nu *NetNsNetLinkTopoUpdater) Stop()

+ type OvsdbProbe struct

+ Graph *graph.Graph

+ Root *graph.Node

+ func NewOvsdbProbe(g *graph.Graph, n *graph.Node, ovsmon *ovsdb.OvsMonitor) *OvsdbProbe

+ func (o *OvsdbProbe) OnOvsBridgeAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsBridgeDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsBridgeUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsInterfaceAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsInterfaceDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsInterfaceUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsPortAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsPortDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) OnOvsPortUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsdbProbe) Start()