buffer

Documentation

Index

• type Binary
• type Buffer
  • func New(maxSize int, codec *codec.Codec) *Buffer
  • func (b *Buffer) Add(entry codec.LogEntry, entryTime time.Time) bool
  • func (b *Buffer) Flush() (Flush, error)
  • func (b *Buffer) Query(actorID uint32, dayStart time.Time, from, to time.Time) iter.Seq[codec.LogEntry]
  • func (b *Buffer) QueryActors(dayStart time.Time, from, to time.Time, actors []uint32) iter.Seq[codec.LogEntry]
  • func (b *Buffer) Size() int
• type Flush
• type Index

Types

type Binary

type Binary struct {
	UncompressedSize uint32
	CompressedSize   uint32
	CompressedData   []byte
}

Binary represents compressed data.

type Buffer

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

Buffer represents the in-memory buffer for the current chunk.

func New

func New(maxSize int, codec *codec.Codec) *Buffer

New creates a new buffer with the specified maximum size.

func (*Buffer) Add

func (b *Buffer) Add(entry codec.LogEntry, entryTime time.Time) bool

Add adds a log entry to the buffer and updates actor bitmaps.

func (*Buffer) Flush

func (b *Buffer) Flush() (Flush, error)

Flush atomically extracts the current buffer contents and resets the buffer. It returns a deep-copied snapshot so the caller owns the returned slices/maps without needing additional synchronization.

func (*Buffer) Query

func (b *Buffer) Query(actorID uint32, dayStart time.Time, from, to time.Time) iter.Seq[codec.LogEntry]

Query returns entries for a specific actor within a time range.

func (*Buffer) QueryActors

func (b *Buffer) QueryActors(dayStart time.Time, from, to time.Time, actors []uint32) iter.Seq[codec.LogEntry]

QueryActors returns entries that contain ALL specified actors within a time range.

func (*Buffer) Size

func (b *Buffer) Size() int

Size returns the number of entries in the buffer.

type Flush

type Flush struct {
	Data  Binary
	Index []Index
	Time  [2]uint32 // Time bounds [min, max] (Unix seconds)
}

Flush represents the data returned by Buffer.Flush.

type Index

type Index struct {
	Binary
	ActorID uint32
}

Index represents a compressed actor bitmap.