Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HttpServer ¶
type HttpServer struct {
// contains filtered or unexported fields
}
func NewHttpServer ¶
func NewHttpServer(serviceName string, conf *HttpServerConf) *HttpServer
func (*HttpServer) Run ¶
func (r *HttpServer) Run(ctx context.Context, phandler handlers.HttpPacketHandler) (err error)
func (*HttpServer) Shutdown ¶
func (r *HttpServer) Shutdown()
type HttpServerConf ¶
type HttpServerConf struct {
Listen string
}
type KafkaReader ¶
type KafkaReader struct {
// contains filtered or unexported fields
}
func NewKafkaReader ¶
func NewKafkaReader(serviceName string, conf *KafkaReaderConf) *KafkaReader
func (*KafkaReader) Run ¶
func (r *KafkaReader) Run(ctx context.Context, phandler handlers.KafkaMessageHandler) (err error)
func (*KafkaReader) Shutdown ¶
func (r *KafkaReader) Shutdown()
type KafkaReaderConf ¶
type PcapSource ¶ added in v1.1.3
type PcapSource struct {
// contains filtered or unexported fields
}
func NewPcapSource ¶ added in v1.1.3
func NewPcapSource(serviceName string, conf *PcapSourceConf) *PcapSource
func (*PcapSource) Run ¶ added in v1.1.3
func (p *PcapSource) Run(ctx context.Context, phandler handlers.PcapPacketHandler) (err error)
func (*PcapSource) Shutdown ¶ added in v1.1.3
func (p *PcapSource) Shutdown()
type PcapSourceConf ¶ added in v1.1.3
type UdpServer ¶
type UdpServer struct {
// contains filtered or unexported fields
}
func NewUdpServer ¶
func NewUdpServer(serviceName string, conf *UdpServerConf) *UdpServer
type UdpServerConf ¶
Click to show internal directories.
Click to hide internal directories.