probes

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 6, 2016 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
const DockerClientApiVersion = "1.18"

Variables

This section is empty.

Functions

This section is empty.

Types

type Attributes added in v0.2.0 

type Attributes struct {
	PortID      string
	NetworkID   string
	NetworkName string
	TenantID    string
	VNI         string
}

type ContainerInfo added in v0.4.0 

type ContainerInfo struct {
	Pid  int
	Node *graph.Node
}

type DockerProbe added in v0.2.0 

type DockerProbe struct {
	sync.RWMutex
	NetNSProbe
	// contains filtered or unexported fields
}

func NewDockerProbe added in v0.2.0 

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

func NewDockerProbeFromConfig added in v0.2.0 

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

func (*DockerProbe) Start added in v0.2.0 

func (probe *DockerProbe) Start()

func (*DockerProbe) Stop added in v0.2.0 

func (probe *DockerProbe) Stop()

type FabricProbe added in v0.6.0 

type FabricProbe struct {
	graph.DefaultGraphListener
	Graph *graph.Graph
	// contains filtered or unexported fields
}

func NewFabricProbe added in v0.6.0 

func NewFabricProbe(g *graph.Graph) *FabricProbe

func (*FabricProbe) OnEdgeAdded added in v0.6.0 

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

func (*FabricProbe) Start added in v0.6.0 

func (fb *FabricProbe) Start()

func (*FabricProbe) Stop added in v0.6.0 

func (fb *FabricProbe) Stop()

type NetLinkProbe 

type NetLinkProbe struct {
	Graph *graph.Graph
	Root  *graph.Node
	// contains filtered or unexported fields
}

func NewNetLinkProbe 

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

func (*NetLinkProbe) Run 

func (u *NetLinkProbe) Run()

func (*NetLinkProbe) Start 

func (u *NetLinkProbe) Start()

func (*NetLinkProbe) Stop 

func (u *NetLinkProbe) Stop()

type NetNSProbe 

type NetNSProbe struct {
	sync.RWMutex

	Graph *graph.Graph
	Root  *graph.Node
	// contains filtered or unexported fields
}

func NewNetNSProbe 

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

func NewNetNSProbeFromConfig added in v0.4.0 

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

func (*NetNSProbe) Register added in v0.2.0 

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

func (*NetNSProbe) Start 

func (u *NetNSProbe) Start()

func (*NetNSProbe) Stop 

func (u *NetNSProbe) Stop()

func (*NetNSProbe) Unregister added in v0.2.0 

func (u *NetNSProbe) Unregister(path string)

type NetNs added in v0.4.0 

type NetNs struct {
	// contains filtered or unexported fields
}

func (*NetNs) String added in v0.4.0 

func (ns *NetNs) String() string

type NetNsNetLinkTopoUpdater 

type NetNsNetLinkTopoUpdater struct {
	sync.RWMutex
	Graph *graph.Graph
	Root  *graph.Node
	// contains filtered or unexported fields
}

func NewNetNsNetLinkTopoUpdater 

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

func (*NetNsNetLinkTopoUpdater) Start 

func (nu *NetNsNetLinkTopoUpdater) Start(ns *NetNs)

func (*NetNsNetLinkTopoUpdater) Stop 

func (nu *NetNsNetLinkTopoUpdater) Stop()

type NeutronMapper added in v0.2.0 

type NeutronMapper struct {
	graph.DefaultGraphListener
	// contains filtered or unexported fields
}

func NewNeutronMapper added in v0.2.0 

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

func NewNeutronMapperFromConfig added in v0.2.0 

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

func (*NeutronMapper) EnhanceNode added in v0.2.0 

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

func (*NeutronMapper) OnNodeAdded added in v0.2.0 

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

func (*NeutronMapper) OnNodeUpdated added in v0.2.0 

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

func (*NeutronMapper) Start added in v0.2.0 

func (mapper *NeutronMapper) Start()

func (*NeutronMapper) Stop added in v0.2.0 

func (mapper *NeutronMapper) Stop()

type NeutronPortNotFound added in v0.6.0 

type NeutronPortNotFound struct {
	MAC string
}

func (NeutronPortNotFound) Error added in v0.6.0 

func (e NeutronPortNotFound) Error() string

type OvsdbProbe 

type OvsdbProbe struct {
	sync.Mutex
	Graph  *graph.Graph
	Root   *graph.Node
	OvsMon *ovsdb.OvsMonitor
	// contains filtered or unexported fields
}

func NewOvsdbProbe 

func NewOvsdbProbe(g *graph.Graph, n *graph.Node, p string, t string) *OvsdbProbe

func NewOvsdbProbeFromConfig added in v0.2.0 

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

func (*OvsdbProbe) OnOvsBridgeAdd 

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

func (*OvsdbProbe) OnOvsBridgeDel 

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

func (*OvsdbProbe) OnOvsBridgeUpdate 

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

func (*OvsdbProbe) OnOvsInterfaceAdd 

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

func (*OvsdbProbe) OnOvsInterfaceDel 

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

func (*OvsdbProbe) OnOvsInterfaceUpdate 

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

func (*OvsdbProbe) OnOvsPortAdd 

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

func (*OvsdbProbe) OnOvsPortDel 

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

func (*OvsdbProbe) OnOvsPortUpdate 

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

func (*OvsdbProbe) Start 

func (o *OvsdbProbe) Start()

func (*OvsdbProbe) Stop added in v0.2.0 

func (o *OvsdbProbe) Stop()

type TopologyProbeBundle added in v0.2.0 

type TopologyProbeBundle struct {
	probe.ProbeBundle
}

func NewTopologyProbeBundleFromConfig added in v0.2.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.