Versions in this module Expand all Collapse all v1 v1.3.1 Sep 14, 2016 Changes in this version + var ErrStreamTooLarge = errors.New("Stream data too large") + type Message struct + CmdlineTuple *common.CmdlineTuple + Direction NetDirection + IsRequest bool + Notes []string + Size uint64 + Transport Transport + Ts time.Time + Tuple common.IpPortTuple + func (m *Message) AddNotes(n ...string) + type NetDirection uint8 + const NetOriginalDirection + const NetReverseDirection + type Stream struct + Buf streambuf.Buffer + MaxDataInStream int + func (stream *Stream) Append(data []byte) error + func (stream *Stream) Init(maxDataInStream int) + func (stream *Stream) Reset() + func (stream *Stream) Write(data []byte) (int, error) + type Transaction struct + BytesIn uint64 + BytesOut uint64 + Dst common.Endpoint + Notes []string + ResponseTime int32 + Src common.Endpoint + Status string + Transport Transport + Ts TransactionTimestamp + Tuple common.IpPortTuple + Type string + func (t *Transaction) Event(event common.MapStr) error + func (t *Transaction) Init(typ string, tuple common.IpPortTuple, transport Transport, ...) + func (t *Transaction) InitWithMsg(typ string, msg *Message) + type TransactionTimestamp struct + Millis int64 + Ts time.Time + type Transport uint8 + const TransportTcp + const TransportUdp + func (t Transport) String() string Other modules containing this package github.com/snappyflow/beats/v7