flows

Sep 8, 2026

Changes in this version

type CollectorConfig

+ AutoModeLogPath string

+ AutoModeMaxConcurrentNodePolls int

+ AutoModePollInterval time.Duration

Jul 29, 2026

Changes in this version

type CollectorConfig

+ AWSVPCCNIPollingInterval time.Duration

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)