JsonUnmarshalStrict is like Unmarshal except that any fields that are found in the data that do not have corresponding struct members, or mapping keys that are duplicates, will result in an error.

NewCollectorPipeline creates a new pipeline from an `IngestCollector` initial stage (listening for NetFlows / IPFIX) nolint:golint,gocritic.

nolint:golint,gocritic.

nolint:golint,gocritic.

nolint:golint,gocritic.

nolint:golint,gocritic.

nolint:golint,gocritic.

nolint:golint,gocritic.

NewGRPCPipeline creates a new pipeline from an `IngestGRPCProto` initial stage (listening for NetObserv's eBPF agent protobuf) nolint:golint,gocritic.

nolint:golint,gocritic.

NewKafkaPipeline creates a new pipeline from an `IngestKafka` initial stage (listening for flow events on Kafka) nolint:golint,gocritic.

NewPipeline creates a new pipeline from an existing ingest.

NewPresetIngesterPipeline creates a new partial pipeline without ingest stage.

nolint:golint,gocritic.

nolint:golint,gocritic.

ParseConfig creates the internal unmarshalled representation from the Pipeline and Parameters json.

(nolint => needs refactoring) nolint:revive.

MetricsSettings is similar to api.PromEncode, but is global to the application, ie.

PerfSettings allows setting some internal configuration parameters.

PipelineBuilderStage holds information about a created pipeline stage.