entry

package

v0.0.0-...-e1bc241 Latest Latest Go to latest Published: Feb 22, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Batch of entries.

func NewBatch(capacity int) Batch

NewBatch with capacity.

func (b *Batch) Append(e Entry)

Append an entry.

func (b *Batch) Len() int

Len is number of entries inside Batch.

func (b *Batch) Marshal(w io.Writer, format common.EntryFormat) (code common.ErrCode, err error)

Marshal into writer.

func (b *Batch) Reset()

Reset batch.

func (b *Batch) ValidateSize(size int) bool

ValidateSize checks size of entries.

type Entry []byte

Entry represents queue entry.

func (e *Entry) CloneFrom(other Entry)

CloneFrom other entry.

func (e Entry) Marshal(w io.Writer, format common.EntryFormat) (code common.ErrCode, err error)

Marshal writes entry to writer.

func (e *Entry) Unmarshal(r io.Reader, format common.EntryFormat) (common.ErrCode, int, error)

Unmarshal from reader.

type Reader interface {
	io.Closer
	io.Seeker
	ReadEntry(*Entry) (common.ErrCode, int, error)
}

Reader interface.

type Writer interface {
	io.Closer
	WriteEntry(Entry) (common.ErrCode, error)
	WriteBatch(Batch) (common.ErrCode, error)
}

Writer interface.