querier

type ExternalFlowCollectorAddr struct {
	Address  string
	Protocol string
}

type FlowAggregatorQuerier interface {
	GetFlowRecords(flowKey *ipfixintermediate.FlowKey) []map[string]interface{}
	GetRecordMetrics() Metrics
}

type Metrics struct {
	NumRecordsExported     int64
	NumRecordsReceived     int64
	NumFlows               int64
	NumConnToCollector     int64
	WithClickHouseExporter bool
	WithS3Exporter         bool
	WithLogExporter        bool
	WithIPFIXExporter      bool
}