buffer

package

v0.3.1 Latest Latest Go to latest Published: Jul 30, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Batch struct {
	Day     time.Time
	Raw     []byte
	Data    []byte
	Indexes []Index
	Entries uint32
	Time    [2]uint32
}

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

func New(maxEntries int, c *codec.Codec) *Buffer

func (b *Buffer) Add(day time.Time, entry codec.LogEntry) error

func (b *Buffer) Bytes() int

func (b *Buffer) Day() time.Time

func (b *Buffer) Size() int

func (b *Buffer) Snapshot() (time.Time, []byte, uint32)

func (b *Buffer) Take() (*Batch, error)

type Index struct {
	Actor uint32
	Data  []byte
}