Documentation ¶
Index ¶
- func NewHttpPacketHandler(handler pHttpPacketHandler) (*httpPacketHandler, error)
- func NewKafkaMessageHandler(handler pKafkaMessageHandler) (*kafkaMessageHandler, error)
- func NewPcapPacketHandler(handler pPcapPacketHandler) (*pcapPacketHandler, error)
- func NewUdpPacketHandler(handler pUdpPacketHandler) (*udpPacketHandler, error)
- type HttpPacketHandler
- type KafkaMessageHandler
- type PcapPacketHandler
- type UdpPacketHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewHttpPacketHandler ¶
func NewHttpPacketHandler(handler pHttpPacketHandler) (*httpPacketHandler, error)
func NewKafkaMessageHandler ¶
func NewKafkaMessageHandler(handler pKafkaMessageHandler) (*kafkaMessageHandler, error)
func NewPcapPacketHandler ¶ added in v1.1.3
func NewPcapPacketHandler(handler pPcapPacketHandler) (*pcapPacketHandler, error)
func NewUdpPacketHandler ¶
func NewUdpPacketHandler(handler pUdpPacketHandler) (*udpPacketHandler, error)
Types ¶
type HttpPacketHandler ¶
type HttpPacketHandler interface {
Handle(w http.ResponseWriter, r *http.Request) error
}
type KafkaMessageHandler ¶
type PcapPacketHandler ¶ added in v1.1.3
Click to show internal directories.
Click to hide internal directories.