producer

Documentation

Index

• func ErrAttr(err error) slog.Attr
• func NewLogger(id string) *slog.Logger
• type Event
• type Producer
  • func New(sensorID string) (*Producer, error)
  • func (p *Producer) LogTCP(handler string, conn net.Conn, md connection.Metadata, payload []byte, ...) error
  • func (p *Producer) LogUDP(handler string, srcAddr *net.UDPAddr, md connection.Metadata, payload []byte, ...) error
• type TeeWriter
  • func (t *TeeWriter) Write(p []byte) (n int, err error)

Functions

func ErrAttr

func ErrAttr(err error) slog.Attr

func NewLogger

func NewLogger(id string) *slog.Logger

NewLogger creates a logger instance

Types

type Event

type Event struct {
	Timestamp time.Time   `json:"timestamp,omitempty"`
	Transport string      `json:"transport,omitempty"`
	SrcHost   string      `json:"srcHost,omitempty"`
	SrcPort   string      `json:"srcPort,omitempty"`
	DstPort   uint16      `json:"dstPort,omitempty"`
	SensorID  string      `json:"sensorID,omitempty"`
	Rule      string      `json:"rule,omitempty"`
	Handler   string      `json:"handler,omitempty"`
	Payload   string      `json:"payload,omitempty"`
	Scanner   string      `json:"scanner,omitempty"`
	Decoded   interface{} `json:"decoded,omitempty"`
}

Event is a struct for glutton events

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

Producer for the producer

func New

func New(sensorID string) (*Producer, error)

New initializes the producers

func (*Producer) LogTCP

func (p *Producer) LogTCP(handler string, conn net.Conn, md connection.Metadata, payload []byte, decoded interface{}) error

LogTCP is a meta caller for all producers

func (*Producer) LogUDP

func (p *Producer) LogUDP(handler string, srcAddr *net.UDPAddr, md connection.Metadata, payload []byte, decoded interface{}) error

LogUDP is a meta caller for all producers

type TeeWriter

type TeeWriter struct {
	// contains filtered or unexported fields
}

func (*TeeWriter) Write

func (t *TeeWriter) Write(p []byte) (n int, err error)