Versions in this module Expand all Collapse all v0 v0.5.0 Apr 14, 2023 Changes in this version + const ResponseBodyMaxLength + var Endianness = binary.BigEndian + var HeaderSize = binarySize(BinaryHeader{}) + func WriteHeader(w *bytes.Buffer, header *BinaryHeader) error + func WriteString(w *bytes.Buffer, value string) error + type BinaryHeader struct + BodyLength uint32 + Crc uint32 + Flags Flags + Op OpCode + StreamId StreamId + Version uint8 + type BinaryRequest interface + Marshal func(w *bytes.Buffer, header *BinaryHeader) error + ResponseChannels func() []chan<- BinaryResponse + StreamId func() StreamId + func NewProduceRequest(streamId StreamId, parts []*ProduceRequestPart) BinaryRequest + type BinaryResponse interface + Op func() OpCode + func NewClientErrorResponse(message string) BinaryResponse + func NewEmptyResponse(op OpCode) BinaryResponse + type ErrorCode uint8 + const ClientError + const LeaderNotFoundError + const RoutingError + const ServerError + type ErrorResponse struct + Code ErrorCode + Message string + func (r *ErrorResponse) Op() OpCode + func (r *ErrorResponse) ToError() error + type Flags uint8 + const WithTimestamp + type OpCode uint8 + const ErrorOp + const HeartbeatOp + const ProduceOp + const ProduceResponseOp + const ReadyOp + const StartupOp + type ProduceRequest struct + func (r *ProduceRequest) Marshal(w *bytes.Buffer, header *BinaryHeader) error + func (r *ProduceRequest) ResponseChannels() []chan<- BinaryResponse + func (r *ProduceRequest) StreamId() StreamId + type ProduceRequestPart struct + Message FixedLengthReader + PartitionKey string + Response chan BinaryResponse + Topic string + func NewProduceRequestPart(topic string, message FixedLengthReader, partitionKey string) *ProduceRequestPart + type StreamId uint16