request

Documentation

Index

• type Request
  • func Parse(msg []byte) (Request, error)
  • func (r *Request) Data() protocol.MessageData
  • func (r *Request) HeaderData() *request.Header
  • func (r *Request) Release()
  • func (r *Request) Serialize(apiVersion int16) ([]byte, error)
  • func (r *Request) SizeInBytes(apiVersion int16) (int, error)
  • func (r *Request) String() string

Types

type Request

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

func Parse

func Parse(msg []byte) (Request, error)

Parse deserializes this Kafka request

func (*Request) Data

func (r *Request) Data() protocol.MessageData

func (*Request) HeaderData

func (r *Request) HeaderData() *request.Header

func (*Request) Release

func (r *Request) Release()

Release releases the dynamically allocated fields of this object by returning then to object pools

func (*Request) Serialize

func (r *Request) Serialize(apiVersion int16) ([]byte, error)

Serialize serializes this Kafka request according to the given Kafka protocol version

func (*Request) SizeInBytes

func (r *Request) SizeInBytes(apiVersion int16) (int, error)

SizeInBytes returns the max size of this Kafka request in bytes when it's serialized

func (*Request) String

func (r *Request) String() string