amqp

type Amqp struct {
	Ports                     []int
	SendRequest               bool
	SendResponse              bool
	MaxBodyLength             int
	ParseHeaders              bool
	ParseArguments            bool
	HideConnectionInformation bool

	//map containing functions associated with different method numbers
	MethodMap map[codeClass]map[codeMethod]AmqpMethod
	// contains filtered or unexported fields
}

type AmqpFrame struct {
	Type byte
	// contains filtered or unexported fields
}

type AmqpMessage struct {
	Ts             time.Time
	TcpTuple       common.TcpTuple
	CmdlineTuple   *common.CmdlineTuple
	Method         string
	IsRequest      bool
	Request        string
	Direction      uint8
	ParseArguments bool

	//mapstr containing all the options for the methods and header fields
	Fields common.MapStr

	Body      []byte
	Body_size uint64

	Notes []string
}

type AmqpMethod func(*AmqpMessage, []byte) (bool, bool)

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

type AmqpTransaction struct {
	Type string

	Src  common.Endpoint
	Dst  common.Endpoint
	Ts   int64
	JsTs time.Time

	Method       string
	Request      string
	Response     string
	ResponseTime int32
	Body         []byte
	BytesOut     uint64
	BytesIn      uint64
	ToString     bool
	Notes        []string

	Amqp common.MapStr
	// contains filtered or unexported fields
}