batch

Dec 1, 2020

Changes in this version

+ var UnsupportedMagicError = errors.New("magic value is not 2")

Apr 29, 2020

Changes in this version

+ var ErrNilRecord = errors.New("nil record in batch")

Apr 13, 2020

Changes in this version

type Batch

+ func (batch *Batch) Compress(c Compressor) error

+ func (batch *Batch) Decompress(d Decompressor) error

Apr 9, 2020

Changes in this version

type Batch

+ func (batch *Batch) LastOffset() int64

type RecordSet

+ func (b RecordSet) Batches() [][]byte

Mar 20, 2020

Changes in this version

+ const TimestampCreate

+ const TimestampLogAppend

+ var CorruptedBatchError = errors.New("batch crc does not match bytes")

+ var ErrEmpty = errors.New("empty batch")

+ type Batch struct

+ Attributes int16

+ BaseOffset int64

+ BaseSequence int32

+ BatchLengthBytes int32

+ Crc uint32

+ FirstTimestamp int64

+ LastOffsetDelta int32

+ Magic int8

+ MarshaledRecords []byte

+ MaxTimestamp int64

+ NumRecords int32

+ PartitionLeaderEpoch int32

+ ProducerEpoch int16

+ ProducerId int64

+ func Unmarshal(b []byte) (*Batch, error)

+ func (batch *Batch) CompressionType() int16

+ func (batch *Batch) Marshal() []byte

+ func (batch *Batch) Records(d Decompressor) ([][]byte, error)

+ func (batch *Batch) TimestampType() int16

+ type Builder struct

+ func NewBuilder(now time.Time) *Builder

+ func (b *Builder) Add(records ...*record.Record)

+ func (b *Builder) AddStrings(values ...string) *Builder

+ func (b *Builder) Build(now time.Time, c Compressor) (*Batch, error)

+ func (b *Builder) NumRecords() int

+ type Compressor interface

+ Compress func([]byte) ([]byte, error)

+ Type func() int16

+ type Decompressor interface

+ Decompress func([]byte) ([]byte, error)

+ Type func() int16

+ type RecordSet []byte

+ func (b RecordSet) Unmarshal() [][]byte