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 + const ICMP + const IPv4 + const IPv6 + const SCTP + const TCP + const UDP + var ErrFalcoEventIsNotFlow = errors.New("ignoring falco event, not a network flow") + var ErrFalcoIncompleteL3Flow = errors.New("ignoring incomplete falco l3 network flow") + var ErrFalcoIncompleteL4Flow = errors.New("ignoring incomplete falco l4 network flow") + var ErrFalcoInvalidPort = errors.New("ignoring incomplete falco flow due to bad ports") + var ErrFalcoTimestamp = errors.New("incomplete or incorrectly formatted timestamp found in Falco flow") + func ConvertCiliumFlow(flowResp *observer.GetFlowsResponse) *pb.CiliumFlow + func CreateLayer3Message(source string, destination string, ipVersion string) (*pb.IP, error) + func CreateLayer4Message(proto string, srcPort, dstPort uint32, ipVersion string) (*pb.Layer4, error) + func FilterIllumioTraffic(body string) bool + func IsCiliumAvailable(ctx context.Context, logger *zap.Logger, clientset kubernetes.Interface, ...) bool + func IsOVNKDeployed(ctx context.Context, logger *zap.Logger, ovnkNamespace string, ...) bool + func NewFalcoEventHandler(eventChan chan<- string) http.HandlerFunc + func NewTemplateSystem(logger *zap.Logger) (*netflows.BasicTemplateSystem, error) + func ParseIPVersion(decodedValue []byte) (string, error) + func ParseIPv4Address(b []byte) (string, error) + func ParseIPv6Address(b []byte) (string, error) + func ParsePodNetworkInfo(input string) (*pb.FiveTupleFlow, error) + func ParsePort(decodedValue []byte) (uint16, error) + func ParseProtocol(decodedValue []byte) (string, error) + type CiliumFlowCollector struct + func NewCiliumFlowCollector(ctx context.Context, logger *zap.Logger, clientset kubernetes.Interface, ...) (*CiliumFlowCollector, error) + func (fm *CiliumFlowCollector) ExportCiliumFlows(ctx context.Context, flowSink FlowSink) error + type FalcoEvent struct + DstIP string + DstPort string + IpVersion string + Proto string + SrcIP string + SrcPort string + Timestamp *timestamppb.Timestamp + type FlowSink interface + CacheFlow func(ctx context.Context, flow pb.Flow) error + IncrementFlowsReceived func() + type K8sClientGetter interface + GetClientset func() kubernetes.Interface + type OVNKCollector struct + func NewOVNKCollector(logger *zap.Logger, ipfixCollectorPort string, flowSink FlowSink) *OVNKCollector + func (c *OVNKCollector) RunIPFIXCollector(ctx context.Context) error + type OVNKFlow struct + DestinationIP string + DestinationPort uint16 + EndTimestamp *timestamppb.Timestamp + IPVersion string + Protocol string + SourceIP string + SourcePort uint16 + StartTimestamp *timestamppb.Timestamp + func ProcessDataRecord(dataRecord netflows.DataRecord, exportTime uint32) (OVNKFlow, error)
Go to main page