flows

type Collector interface {
	Run(ctx context.Context) error
}

type CollectorConfig struct {
	Logger             *zap.Logger
	FlowCache          *cache.FlowCache
	Stats              *stream.Stats
	K8sClient          collector.K8sClientGetter
	CiliumNamespaces   []string
	TlsAuthProps       *tls.AuthProperties
	IPFIXCollectorPort string
	OVNKNamespace      string
}

type CollectorFactory interface {
	NewCollector(ctx context.Context) (Collector, error)
}

type FlowCollectorStreamFactory struct {
	Factory       CollectorFactory
	CollectorName string // e.g., "Cilium", "OVN-K", "Falco"
}

type FlowSinkAdapter struct {
	FlowCache *cache.FlowCache
	Stats     *stream.Stats
}

type KubernetesNetworkFlowsStream interface {
	Send(req *pb.SendKubernetesNetworkFlowsRequest) error
	Recv() (*pb.SendKubernetesNetworkFlowsResponse, error)
}

type NetworkFlowsFactory struct {
	Logger    *zap.Logger
	FlowCache *cache.FlowCache
	Stats     *stream.Stats
}