probes

Documentation

Index

• type NetLinkProbe
  • func NewNetLinkProbe(g *graph.Graph, n *graph.Node) *NetLinkProbe
  • func (u *NetLinkProbe) Run()
  • func (u *NetLinkProbe) Start()
  • func (u *NetLinkProbe) Stop()
• type NetNSProbe
  • func NewNetNSProbe(g *graph.Graph, n *graph.Node) *NetNSProbe
  • func (u *NetNSProbe) Start()
  • func (u *NetNSProbe) Stop()
• type NetNsNetLinkTopoUpdater
  • func NewNetNsNetLinkTopoUpdater(g *graph.Graph, n *graph.Node) *NetNsNetLinkTopoUpdater
  • func (nu *NetNsNetLinkTopoUpdater) Start(path string)
  • func (nu *NetNsNetLinkTopoUpdater) Stop()
• type OvsdbProbe
  • 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()

Types

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) *NetNSProbe

func (*NetNSProbe) Start

func (u *NetNSProbe) Start()

func (*NetNSProbe) Stop

func (u *NetNSProbe) Stop()

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

func (*NetNsNetLinkTopoUpdater) Stop

func (nu *NetNsNetLinkTopoUpdater) Stop()

type OvsdbProbe

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

func NewOvsdbProbe

func NewOvsdbProbe(g *graph.Graph, n *graph.Node, ovsmon *ovsdb.OvsMonitor) *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()