reader

Documentation

Index

• type Message
• type MessageOpt
  • func (m *MessageOpt) ContentTotalSize() int
  • func (m *MessageOpt) Direction() enums.SocketDataDirection
  • func (m *MessageOpt) EndTime() uint64
  • func (m *MessageOpt) StartTime() uint64
  • func (m *MessageOpt) TransformReadableContent(defaultEncoding string, maxSize int) (string, error)
• type MessageType
  • func IdentityMessageType(reader *buffer.Buffer) (MessageType, error)
• type Request
  • func ReadRequest(buf *buffer.Buffer, readBody bool) (*Request, enums.ParseResult, error)
  • func (r *Request) BodyBuffer() *buffer.Buffer
  • func (r *Request) HeaderBuffer() *buffer.Buffer
  • func (r *Request) Headers() http.Header
  • func (r *Request) MinDataID() int
  • func (r *Request) Original() *http.Request
• type Response
  • func ReadResponse(req *Request, buf *buffer.Buffer, readBody bool) (*Response, enums.ParseResult, error)
  • func (r *Response) BodyBuffer() *buffer.Buffer
  • func (r *Response) HeaderBuffer() *buffer.Buffer
  • func (r *Response) Headers() http.Header
  • func (r *Response) Original() *http.Response

Types

type Message

type Message interface {
	Headers() http.Header
	HeaderBuffer() *buffer.Buffer
	BodyBuffer() *buffer.Buffer
}

type MessageOpt

type MessageOpt struct {
	Message
}

func (*MessageOpt) ContentTotalSize

func (m *MessageOpt) ContentTotalSize() int

func (*MessageOpt) Direction

func (m *MessageOpt) Direction() enums.SocketDataDirection

func (*MessageOpt) EndTime

func (m *MessageOpt) EndTime() uint64

func (*MessageOpt) StartTime

func (m *MessageOpt) StartTime() uint64

func (*MessageOpt) TransformReadableContent

func (m *MessageOpt) TransformReadableContent(defaultEncoding string, maxSize int) (string, error)

nolint

type MessageType

type MessageType int

const (
	MessageTypeRequest MessageType = iota
	MessageTypeResponse
	MessageTypeUnknown
)

func IdentityMessageType

func IdentityMessageType(reader *buffer.Buffer) (MessageType, error)

type Request

type Request struct {
	*MessageOpt
	// contains filtered or unexported fields
}

func ReadRequest

func ReadRequest(buf *buffer.Buffer, readBody bool) (*Request, enums.ParseResult, error)

nolint

func (*Request) BodyBuffer

func (r *Request) BodyBuffer() *buffer.Buffer

func (*Request) HeaderBuffer

func (r *Request) HeaderBuffer() *buffer.Buffer

func (*Request) Headers

func (r *Request) Headers() http.Header

func (*Request) MinDataID

func (r *Request) MinDataID() int

func (*Request) Original

func (r *Request) Original() *http.Request

type Response

type Response struct {
	*MessageOpt
	// contains filtered or unexported fields
}

func ReadResponse

func ReadResponse(req *Request, buf *buffer.Buffer, readBody bool) (*Response, enums.ParseResult, error)

func (*Response) BodyBuffer

func (r *Response) BodyBuffer() *buffer.Buffer

func (*Response) HeaderBuffer

func (r *Response) HeaderBuffer() *buffer.Buffer

func (*Response) Headers

func (r *Response) Headers() http.Header

func (*Response) Original

func (r *Response) Original() *http.Response