http2

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

type Dir uint8

type DirectConn struct {
	SrcAddr psnet.Addr
	DstAddr psnet.Addr
}

type FrameBase struct {
	DirectConn *DirectConn
	StreamID   uint32
	Type       uint8
	Flags      uint8
	Length     uint32
	Payload    []byte
}

type FrameContinuation struct {
	EndHeader           bool
	HeaderBlockFragment []byte
	// contains filtered or unexported fields
}

type FrameData struct {
	EndStream bool
	Padded    bool
	// Frame Payload
	PadLength uint8
	Data      []byte
	// contains filtered or unexported fields
}

type FrameHeader struct {
	EndStream bool
	EndHeader bool
	Padded    bool
	// I don't care
	Priority bool
	// Frame Payload
	PadLength           uint8
	HeaderBlockFragment []byte
	// contains filtered or unexported fields
}

type FrameSetting struct {
	Ack bool
	// contains filtered or unexported fields
}

type GRPCMessage struct {
	// ------ complete gRPC Message------
	// https://github.com/grpc/grpc-go/blob/master/Documentation/encoding.md
	//	gRPC lets you use encoders other than Protobuf.
	//  gRPC is compatible with JSON, Thrift, Avro, Flatbuffers, Cap’n Proto, and even raw bytes!
	/*
				+--------------------+
				|  payloadFormat(8)  |
				+--------------------+------------------------------------------+
				|                          length(32)                           |
				+---------------------------------------------------------------+
				|                        encodedMessage(*)                  ... |
				+---------------------------------------------------------------+
			   payloadFormat: compressed or not?
		       encodedMessage: Protobuf,JSON,Thrift,etc.
	*/
	PayloadFormat  payloadFormat
	Length         uint32
	EncodedMessage []byte
}

type Http2Conn struct {
	DirectConn          DirectConn
	MaxDynamicTableSize uint32
	MaxHeaderStringLen  uint32
	HeaderDecoder       *hpack.Decoder
	Streams             [StreamArraySize]*Stream
}

type NetPkg struct {
	IP        *layers.IPv4
	TCP       *layers.TCP
	Direction Dir
}

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

type Processor struct {
	ConnRepository map[DirectConn]*Http2Conn
	InputChan      chan *NetPkg
	OutputChan     chan *protocol.Message
	Finder         *PBMessageFinder
}

type Stream struct {
	StreamID  uint32
	EndHeader bool
	EndStream bool
	Headers   map[string]string `json:"headers"`
	Method    string            `json:"method"`
	// json序列化后的结果
	Request []byte `json:"request"`
}