exporter

Documentation

Index

• type FlowstoreFlow
• type FlowstoreFlowExporter
  • func NewFlowstoreFlowExporter(target string, port int, protocol string, maxFlowsPerUpload int, ...) *FlowstoreFlowExporter
  • func (f *FlowstoreFlowExporter) AddIPv4Flow(ipv4Flow flow.Flow)
  • func (f *FlowstoreFlowExporter) ResetBuffer()
  • func (f *FlowstoreFlowExporter) Start()
  • func (f *FlowstoreFlowExporter) Stop()
  • func (f *FlowstoreFlowExporter) UploadFlows() error
• type FlowstorePostInput
• type FlowstorePostOutput
• type IpfixFlowExporter
  • func NewIpfixFlowExporter(collectorTarget string, collectorPort, maxRecordSize int, ...) *IpfixFlowExporter
  • func (fe *IpfixFlowExporter) AddIPv4Flow(ipv4Flow flow.Flow)
  • func (fe *IpfixFlowExporter) CloseExporter()
  • func (fe *IpfixFlowExporter) GetCurrentBiMessageSize() int
  • func (fe *IpfixFlowExporter) GetCurrentUniMessageSize() int
  • func (fe *IpfixFlowExporter) SendBiDataSet() error
  • func (fe *IpfixFlowExporter) SendUniDataSet() error
  • func (fe *IpfixFlowExporter) Start() error
  • func (fe *IpfixFlowExporter) Stop()

Types

type FlowstoreFlow

type FlowstoreFlow struct {
	SourceIP               string `json:"source_ip"`
	DestinationIP          string `json:"destination_ip"`
	SourcePort             uint16 `json:"source_port"`
	DestinationPort        uint16 `json:"destination_port"`
	Protocol               uint8  `json:"protocol"`
	FlowStartMilliseconds  uint64 `json:"flow_start_milliseconds"`
	FlowEndMilliseconds    uint64 `json:"flow_end_milliseconds"`
	FlowOctetCount         uint64 `json:"flow_octet_count"`
	FlowPacketCount        uint64 `json:"flow_packet_count"`
	ReverseFlowOctetCount  uint64 `json:"reverse_flow_octet_count"`
	ReverseFlowPacketCount uint64 `json:"reverse_flow_packet_count"`
}

type FlowstoreFlowExporter

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

func NewFlowstoreFlowExporter

func NewFlowstoreFlowExporter(target string, port int, protocol string, maxFlowsPerUpload int, flowInputChannel chan flow.Flow, waitGroup *sync.WaitGroup) *FlowstoreFlowExporter

func (*FlowstoreFlowExporter) AddIPv4Flow

func (f *FlowstoreFlowExporter) AddIPv4Flow(ipv4Flow flow.Flow)

func (*FlowstoreFlowExporter) ResetBuffer

func (f *FlowstoreFlowExporter) ResetBuffer()

func (*FlowstoreFlowExporter) Start

func (f *FlowstoreFlowExporter) Start()

func (*FlowstoreFlowExporter) Stop

func (f *FlowstoreFlowExporter) Stop()

func (*FlowstoreFlowExporter) UploadFlows

func (f *FlowstoreFlowExporter) UploadFlows() error

type FlowstorePostInput

type FlowstorePostInput struct {
	Flows []FlowstoreFlow `json:"flows,omitempty"`
}

type FlowstorePostOutput

type FlowstorePostOutput struct {
	Error          string `json:"error"`
	ProcessedFlows int    `json:"processed_flows"`
}

type IpfixFlowExporter

type IpfixFlowExporter struct {
	FlowRecordsSent  uint64
	UniElementBuffer []*entities.InfoElementWithValue
	BiElementBuffer  []*entities.InfoElementWithValue
	StopChannel      chan bool
	InputChannel     chan flow.Flow
	// contains filtered or unexported fields
}

func NewIpfixFlowExporter

func NewIpfixFlowExporter(collectorTarget string, collectorPort, maxRecordSize int, flowInputChannel chan flow.Flow, waitGroup *sync.WaitGroup) *IpfixFlowExporter

func (*IpfixFlowExporter) AddIPv4Flow

func (fe *IpfixFlowExporter) AddIPv4Flow(ipv4Flow flow.Flow)

func (*IpfixFlowExporter) CloseExporter

func (fe *IpfixFlowExporter) CloseExporter()

func (*IpfixFlowExporter) GetCurrentBiMessageSize

func (fe *IpfixFlowExporter) GetCurrentBiMessageSize() int

func (*IpfixFlowExporter) GetCurrentUniMessageSize

func (fe *IpfixFlowExporter) GetCurrentUniMessageSize() int

func (*IpfixFlowExporter) SendBiDataSet

func (fe *IpfixFlowExporter) SendBiDataSet() error

func (*IpfixFlowExporter) SendUniDataSet

func (fe *IpfixFlowExporter) SendUniDataSet() error

func (*IpfixFlowExporter) Start

func (fe *IpfixFlowExporter) Start() error

func (*IpfixFlowExporter) Stop

func (fe *IpfixFlowExporter) Stop()