rawproducer

Documentation

Index

• type RawMessage
  • func (m RawMessage) MarshalJSON() ([]byte, error)
  • func (m RawMessage) MarshalText() ([]byte, error)
• type RawProducer
  • func (p *RawProducer) Close()
  • func (p *RawProducer) Commit(flowMessageSet []producer.ProducerMessage)
  • func (p *RawProducer) Produce(msg interface{}, args *producer.ProduceArgs) ([]producer.ProducerMessage, error)

Types

type RawMessage

type RawMessage struct {
	Message      interface{}    `json:"message"`
	Src          netip.AddrPort `json:"src"`
	TimeReceived time.Time      `json:"time_received"`
}

Raw message

func (RawMessage) MarshalJSON

func (m RawMessage) MarshalJSON() ([]byte, error)

func (RawMessage) MarshalText

func (m RawMessage) MarshalText() ([]byte, error)

type RawProducer

type RawProducer struct {
}

Producer that keeps the same format as the original flow samples. This can be used for debugging (eg: getting NetFlow Option Templates)

func (*RawProducer) Close

func (p *RawProducer) Close()

func (*RawProducer) Commit

func (p *RawProducer) Commit(flowMessageSet []producer.ProducerMessage)

func (*RawProducer) Produce

func (p *RawProducer) Produce(msg interface{}, args *producer.ProduceArgs) ([]producer.ProducerMessage, error)