Struct DynamicFlowProcessor

pkg/hubble/metrics/dynamic_flow_processor.go:24–31

DynamicFlowProcessor represents instance of hubble exporter with dynamic configuration reload.

// DynamicFlowProcessor represents instance of hubble exporter with dynamic
// configuration reload.
type DynamicFlowProcessor struct {
	logger  *slog.Logger
	watcher *metricConfigWatcher
	// Protects against deregistering metric handlers while ProcessFlow is executing, or concurrent config reloads.
	mutex    lock.RWMutex
	Metrics  []api.NamedHandler
	registry *prometheus.Registry
}

// ProcessFlow implements FlowProcessor.
func (p *DynamicFlowProcessor) ProcessFlow(ctx context.Context, flow *flowpb.Flow) error {