MCPcopy
hub / github.com/cilium/cilium / FlowProcessor

Interface FlowProcessor

pkg/hubble/metrics/metrics.go:139–142  ·  view source on GitHub ↗

FlowProcessor is an abstraction over the static and dynamic flow processors.

Source from the content-addressed store, hash-verified

137
138// FlowProcessor is an abstraction over the static and dynamic flow processors.
139type FlowProcessor interface {
140 // ProcessFlow processes a flow event and perform metrics accounting.
141 ProcessFlow(ctx context.Context, flow *pb.Flow) error
142}

Callers

nothing calls this directly

Implementers 14

DynamicFlowProcessorpkg/hubble/metrics/dynamic_flow_proces
StaticFlowProcessorpkg/hubble/metrics/flow_processor.go
flowHandlerpkg/hubble/metrics/flow/handler.go
policyHandlerpkg/hubble/metrics/policy/handler.go
flowsToWorldHandlerpkg/hubble/metrics/flows-to-world/hand
dropHandlerpkg/hubble/metrics/drop/handler.go
httpHandlerpkg/hubble/metrics/http/handler.go
dnsHandlerpkg/hubble/metrics/dns/handler.go
icmpHandlerpkg/hubble/metrics/icmp/handler.go
kafkaHandlerpkg/hubble/metrics/kafka/handler.go
testHandlerpkg/hubble/metrics/api/registry_test.g
portDistributionHandlerpkg/hubble/metrics/port-distribution/h

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…