probes

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2017 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

View Source 
const DockerClientApiVersion = "1.18"
View Source 
const (
	FabricNamespace = "Fabric"
)

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
	IPs         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, _ error)

func NewDockerProbeFromConfig added in v0.2.0 

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

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 ExtIDs added in v0.7.0 

type ExtIDs struct {
	IfaceID     string
	AttachedMac string
}

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) LinkNodes added in v0.8.0 

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

func (*FabricProbe) OnEdgeAdded added in v0.6.0 

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

func (*FabricProbe) OnNodeDeleted added in v0.8.0 

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

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 FabricRegisterLinkWSMessage added in v0.8.0 

type FabricRegisterLinkWSMessage struct {
	ParentNodeID   graph.Identifier
	ParentMetadata graph.Metadata
	ChildMetadata  graph.Metadata
}

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(nsPath string)

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, error)

func NewNetNSProbeFromConfig added in v0.4.0 

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

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) Run added in v0.8.0 

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

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, wsClient *shttp.WSAsyncClient, authURL, username, password, tenantName, regionName, domainName string, availability gophercloud.Availability) (*NeutronMapper, error)

func NewNeutronMapperFromConfig added in v0.2.0 

func NewNeutronMapperFromConfig(g *graph.Graph, wsCient *shttp.WSAsyncClient) (*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 OpenContrailMapper added in v0.7.0 

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

func NewOpenContrailMapper added in v0.7.0 

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

func (*OpenContrailMapper) OnNodeAdded added in v0.7.0 

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

func (*OpenContrailMapper) OnNodeDeleted added in v0.7.0 

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

func (*OpenContrailMapper) OnNodeUpdated added in v0.7.0 

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

func (*OpenContrailMapper) Start added in v0.7.0 

func (mapper *OpenContrailMapper) Start()

func (*OpenContrailMapper) Stop added in v0.7.0 

func (mapper *OpenContrailMapper) Stop()

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 PeeringProbe added in v0.9.0 

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

func NewPeeringProbe added in v0.9.0 

func NewPeeringProbe(g *graph.Graph) *PeeringProbe

func (*PeeringProbe) OnNodeAdded added in v0.9.0 

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

func (*PeeringProbe) OnNodeDeleted added in v0.9.0 

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

func (*PeeringProbe) OnNodeUpdated added in v0.9.0 

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

func (*PeeringProbe) Start added in v0.9.0 

func (p *PeeringProbe) Start()

func (*PeeringProbe) Stop added in v0.9.0 

func (p *PeeringProbe) Stop()

type PortMetadata added in v0.7.0 

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

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.