Versions in this module Expand all Collapse all v1 v1.3.14 May 13, 2026 v1.3.13 Apr 17, 2026 Changes in this version + type Collector interface + Run func(ctx context.Context) error + type CollectorConfig struct + CiliumNamespaces []string + FlowCache *cache.FlowCache + IPFIXCollectorPort string + K8sClient collector.K8sClientGetter + Logger *zap.Logger + OVNKNamespace string + Stats *stream.Stats + TlsAuthProps *tls.AuthProperties + type CollectorFactory interface + NewCollector func(ctx context.Context) (Collector, error) + func DetectFlowCollector(ctx context.Context, config CollectorConfig) (pb.FlowCollector, string, CollectorFactory) + type FlowCollectorStreamFactory struct + CollectorName string + Factory CollectorFactory + func (f *FlowCollectorStreamFactory) Name() string + func (f *FlowCollectorStreamFactory) NewStreamClient(ctx context.Context, _ grpc.ClientConnInterface) (stream.StreamClient, error) + type FlowSinkAdapter struct + FlowCache *cache.FlowCache + Stats *stream.Stats + func NewFlowSinkAdapter(flowCache *cache.FlowCache, stats *stream.Stats) *FlowSinkAdapter + func (f *FlowSinkAdapter) CacheFlow(ctx context.Context, flow pb.Flow) error + func (f *FlowSinkAdapter) IncrementFlowsReceived() + type KubernetesNetworkFlowsStream interface + Recv func() (*pb.SendKubernetesNetworkFlowsResponse, error) + Send func(req *pb.SendKubernetesNetworkFlowsRequest) error + type NetworkFlowsFactory struct + FlowCache *cache.FlowCache + Logger *zap.Logger + Stats *stream.Stats + func (f *NetworkFlowsFactory) Name() string + func (f *NetworkFlowsFactory) NewStreamClient(ctx context.Context, grpcConn grpc.ClientConnInterface) (stream.StreamClient, error)
Go to main page