options

type DebugCaptureDecoderFunc func(data []byte, decoded *pb.Flow) (*monitor.DebugCapture, error)

type DebugMsgDecoderFunc func(data []byte) (*monitor.DebugMsg, error)

type DropNotifyDecoderFunc func(data []byte, decoded *pb.Flow) (*monitor.DropNotify, error)

type HttpHeadersList struct {
	Allow map[string]struct{}
	Deny  map[string]struct{}
}

type HubbleRedactSettings struct {
	Enabled            bool
	RedactHTTPQuery    bool
	RedactHTTPUserInfo bool
	RedactKafkaAPIKey  bool
	RedactHttpHeaders  HttpHeadersList
}

type L34PacketDecoder interface {
	DecodePacket(payload []byte, decoded *pb.Flow, isL3Device, isIPv6, isVXLAN, isGeneve bool) (
		sourceIP, destinationIP netip.Addr,
		sourcePort, destinationPort uint16,
		err error,
	)
}

type Option func(*Options)

type Options struct {
	CacheSize                      int
	HubbleRedactSettings           HubbleRedactSettings
	EnableNetworkPolicyCorrelation bool
	SkipUnknownCGroupIDs           bool

	DropNotifyDecoder          DropNotifyDecoderFunc
	DebugMsgDecoder            DebugMsgDecoderFunc
	DebugCaptureDecoder        DebugCaptureDecoderFunc
	TraceNotifyDecoder         TraceNotifyDecoderFunc
	PolicyVerdictNotifyDecoder PolicyVerdictNotifyDecoderFunc
	TraceSockNotifyDecoder     TraceSockNotifyDecoderFunc
	L34PacketDecoder           L34PacketDecoder
}

type PolicyVerdictNotifyDecoderFunc func(data []byte, decoded *pb.Flow) (*monitor.PolicyVerdictNotify, error)

type TraceNotifyDecoderFunc func(data []byte, decoded *pb.Flow) (*monitor.TraceNotify, error)

type TraceSockNotifyDecoderFunc func(data []byte, decoded *pb.Flow) (*monitor.TraceSockNotify, error)