ovsnetflow

Documentation

Index

• func NewProbe(ctx probes.Context, bundle *probe.Bundle) (probes.FlowProbeHandler, error)
• type Probe
• type ProbesHandler
  • func (o *ProbesHandler) CaptureTypes() []string
  • func (o *ProbesHandler) RegisterProbe(n *graph.Node, capture *types.Capture, e probes.ProbeEventHandler) (probes.Probe, error)
  • func (o *ProbesHandler) Start() error
  • func (o *ProbesHandler) Stop()
  • func (o *ProbesHandler) UnregisterNetFlowProbeFromBridge(bridgeUUID string) error
  • func (o *ProbesHandler) UnregisterProbe(n *graph.Node, e probes.ProbeEventHandler, p probes.Probe) error

Functions

func NewProbe

func NewProbe(ctx probes.Context, bundle *probe.Bundle) (probes.FlowProbeHandler, error)

NewProbe returns a new ovsnetflow probe

Types

type Probe

type Probe struct {
	ID       string
	Target   string
	EngineID int
	// contains filtered or unexported fields
}

Probe describes a NetFlow probe from OVS switch

type ProbesHandler

type ProbesHandler struct {
	Ctx probes.Context

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

ProbesHandler describes a flow probe in running in the graph

func (*ProbesHandler) CaptureTypes

func (o *ProbesHandler) CaptureTypes() []string

CaptureTypes supported

func (*ProbesHandler) RegisterProbe

func (o *ProbesHandler) RegisterProbe(n *graph.Node, capture *types.Capture, e probes.ProbeEventHandler) (probes.Probe, error)

RegisterProbe registers a probe on a graph node

func (*ProbesHandler) Start

func (o *ProbesHandler) Start() error

Start the probe

func (*ProbesHandler) Stop

func (o *ProbesHandler) Stop()

Stop the probe

func (*ProbesHandler) UnregisterNetFlowProbeFromBridge

func (o *ProbesHandler) UnregisterNetFlowProbeFromBridge(bridgeUUID string) error

UnregisterNetFlowProbeFromBridge unregisters a flow probe from the bridge selected by UUID

func (*ProbesHandler) UnregisterProbe

func (o *ProbesHandler) UnregisterProbe(n *graph.Node, e probes.ProbeEventHandler, p probes.Probe) error

UnregisterProbe at the graph node