notify

Documentation

Index

• Constants
• func PostFlows(url string, timeout int, flows Flows) (err error)
• func PrintNotifier(ctx context.Context, duration int64)
• func WebhookNotifier(ctx context.Context, duration int64, nodeId string, nodeOamAddr string, ...)
• type Flow
• type Flows

Constants

const Layer3String = "l3"

const Layer4String = "l4"

Functions

func PostFlows

func PostFlows(url string, timeout int, flows Flows) (err error)

func PrintNotifier

func PrintNotifier(ctx context.Context, duration int64)

func WebhookNotifier

func WebhookNotifier(ctx context.Context, duration int64, nodeId string, nodeOamAddr string, url string, timeout int)

Types

type Flow

type Flow struct {
	Layer            string
	SrcAddr          string
	DstAddr          string
	SrcPort          uint16
	DstPort          uint16
	Protocol         string
	InboundBytes     int64
	InboundPackets   int64
	InboundDuration  int64
	OutboundBytes    int64
	OutboundPackets  int64
	OutboundDuration int64
}

type Flows

type Flows struct {
	RouterId string
	OamAddr  string
	Start    int64
	End      int64
	FLowsMap map[string][]*Flow
}