probes

package
v0.0.0-...-3fab846 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 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 

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

type ContainerInfo 

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

type DockerProbe 

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

func NewDockerProbe 

func NewDockerProbe(nsProbe *NetNSProbe, dockerURL string) (probe *DockerProbe, _ error)

func NewDockerProbeFromConfig 

func NewDockerProbeFromConfig(nsProbe *NetNSProbe) (*DockerProbe, error)

func (*DockerProbe) Start 

func (probe *DockerProbe) Start()

func (*DockerProbe) Stop 

func (probe *DockerProbe) Stop()

type FabricProbe 

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

func NewFabricProbe 

func NewFabricProbe(g *graph.Graph) *FabricProbe

func (*FabricProbe) LinkNodes 

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

func (*FabricProbe) OnEdgeAdded 

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

func (*FabricProbe) OnNodeDeleted 

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

func (*FabricProbe) Start 

func (fb *FabricProbe) Start()

func (*FabricProbe) Stop 

func (fb *FabricProbe) Stop()

type FabricRegisterLinkWSMessage 

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

type NetLinkProbe 

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

func NewNetLinkProbe 

func NewNetLinkProbe(g *graph.Graph) (*NetLinkProbe, error)

func (*NetLinkProbe) Register 

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

func (*NetLinkProbe) Start 

func (u *NetLinkProbe) Start()

func (*NetLinkProbe) Stop 

func (u *NetLinkProbe) Stop()

func (*NetLinkProbe) Unregister 

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

type NetNSProbe 

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

func NewNetNSProbe 

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

func NewNetNSProbeFromConfig 

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

func (*NetNSProbe) Register 

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 

func (u *NetNSProbe) Unregister(path string)

type NetNs 

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

func (*NetNs) String 

func (ns *NetNs) String() string

type NetNsNetLinkProbe 

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

type NeutronMapper 

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

func NewNeutronMapper 

func NewNeutronMapper(g *graph.Graph, wspool *shttp.WSAsyncClientPool, authURL, username, password, tenantName, regionName, domainName string, availability gophercloud.Availability) (*NeutronMapper, error)

func NewNeutronMapperFromConfig 

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

func (*NeutronMapper) EnhanceNode 

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

func (*NeutronMapper) OnNodeAdded 

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

func (*NeutronMapper) OnNodeUpdated 

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

func (*NeutronMapper) Start 

func (mapper *NeutronMapper) Start()

func (*NeutronMapper) Stop 

func (mapper *NeutronMapper) Stop()

type NeutronPortNotFound 

type NeutronPortNotFound struct {
	MAC string
}

func (NeutronPortNotFound) Error 

func (e NeutronPortNotFound) Error() string

type OpenContrailMapper 

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

func NewOpenContrailMapper 

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

func (*OpenContrailMapper) OnNodeAdded 

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

func (*OpenContrailMapper) OnNodeDeleted 

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

func (*OpenContrailMapper) OnNodeUpdated 

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

func (*OpenContrailMapper) Start 

func (mapper *OpenContrailMapper) Start()

func (*OpenContrailMapper) Stop 

func (mapper *OpenContrailMapper) Stop()

type OpenContrailMdata 

type OpenContrailMdata struct {
	UUID    string
	Mac     string
	VRF     string
	LocalIP 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 

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 

func (o *OvsdbProbe) Stop()

type PeeringProbe 

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

func NewPeeringProbe 

func NewPeeringProbe(g *graph.Graph) *PeeringProbe

func (*PeeringProbe) OnNodeAdded 

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

func (*PeeringProbe) OnNodeDeleted 

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

func (*PeeringProbe) OnNodeUpdated 

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

func (*PeeringProbe) Start 

func (p *PeeringProbe) Start()

func (*PeeringProbe) Stop 

func (p *PeeringProbe) Stop()

type PortMetadata 

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.