networkmonitor

Jan 20, 2026

Changes in this version

type Config

+ OperatorCommit string

+ OperatorVersion string

Jan 9, 2026

Changes in this version

+ func CiliumAvailable(mode string) bool

+ type Client interface

+ Close func() error

+ ListEntries func(filter EntriesFilter) ([]*Entry, error)

+ func NewCiliumClient(log logr.Logger, clockSource ClockSource) (Client, error)

+ func NewNetfilterClient(log logr.Logger) (Client, error)

+ type ClockSource string

+ const ClockSourceJiffies

+ const ClockSourceKtime

+ type Config struct

+ CleanupInterval time.Duration

+ FlushInterval time.Duration

+ NodeName string

+ ReadInterval time.Duration

+ type EnrichedDNSLookup struct

+ SrcPodName string

+ SrcPodNamespace string

+ type EntriesFilter func(e *Entry) bool

+ func FilterBySrcIP(ips map[netaddr.IP]struct{}) EntriesFilter

+ type Entry struct

+ Dst netaddr.IPPort

+ Lifetime time.Time

+ Proto uint8

+ RxBytes uint64

+ RxPackets uint64

+ Src netaddr.IPPort

+ TxBytes uint64

+ TxPackets uint64

+ type MetricsResponse struct

+ DNSLookups []EnrichedDNSLookup

+ Ip2Domain map[string]string

+ Items []*NetworkFlow

+ NodeName string

+ type Monitor struct

+ func NewMonitor(cfg Config, log logr.Logger, podCache *PodCache, ct Client, ...) (*Monitor, error)

+ func (m *Monitor) GetMetricsHandler(w http.ResponseWriter, r *http.Request)

+ func (m *Monitor) Start(ctx context.Context)

+ type NetfilterClient struct

+ func (c *NetfilterClient) Close() error

+ func (c *NetfilterClient) ListEntries(filter EntriesFilter) ([]*Entry, error)

+ type NetworkFlow struct

+ DstDomain string

+ DstIP string

+ DstPodName string

+ DstPodNamespace string

+ DstPort uint16

+ Protocol uint8

+ RxBytes uint64

+ RxPackets uint64

+ SrcDomain string

+ SrcIP string

+ SrcPodName string

+ SrcPodNamespace string

+ Timestamp time.Time

+ TxBytes uint64

+ TxPackets uint64

+ type PodCache struct

+ func NewPodCache(informer cache.SharedIndexInformer) *PodCache

+ func (pc *PodCache) GetLocalPodIPs() map[netaddr.IP]struct{}

+ func (pc *PodCache) GetPodByIP(ip netaddr.IP) (*corev1.Pod, bool)