utils

Documentation

Index

• func HumanReadableJSONMarshal(msg *ExtendedFlowMessage) ([]byte, error)
• func HumanReadableJSONMarshalIndent(msg *ExtendedFlowMessage, prefix, indent string) ([]byte, error)
• type Enricher
• type ExtendedFlowMessage
  • func ConvertMessages(msgs []*flowmessage.FlowMessage) []*ExtendedFlowMessage
• type ExtendedTransport
• type FlowMessageAlias

Functions

func HumanReadableJSONMarshal

func HumanReadableJSONMarshal(msg *ExtendedFlowMessage) ([]byte, error)

func HumanReadableJSONMarshalIndent

func HumanReadableJSONMarshalIndent(msg *ExtendedFlowMessage, prefix, indent string) ([]byte, error)

Types

type Enricher

type Enricher interface {
	Enrich([]*ExtendedFlowMessage)
}

type ExtendedFlowMessage

type ExtendedFlowMessage struct {
	Metadata map[string]interface{} `json:"Metadata,omitempty"`
	*flowmessage.FlowMessage
}

func ConvertMessages

func ConvertMessages(msgs []*flowmessage.FlowMessage) []*ExtendedFlowMessage

type ExtendedTransport

type ExtendedTransport interface {
	Publish([]*ExtendedFlowMessage)
}

type FlowMessageAlias

type FlowMessageAlias struct {
	SrcAddr        string `json:"SrcAddr,omitempty"`
	DstAddr        string `json:"DstAddr,omitempty"`
	NextHop        string `json:"NextHop,omitempty"`
	SamplerAddress string `json:"SamplerAddress,omitempty"`
	*ExtendedFlowMessage
}