codec

Jul 19, 2026

Changes in this version

+ const MaxMillis

+ func Decode[T any](data []byte) (*T, error)

+ func Encode[T any](value T) ([]byte, error)

+ func ValidateChunk(chunk ChunkEntry) error

+ func ValidateCompact(meta *CompactMetadata, day string) error

+ func ValidateManifest(m *Manifest, day, writer string) error

type ChunkEntry

+ Data Range

+ ETag string

+ Entries uint32

+ Sequence Sequence

+ type CompactMetadata struct

+ Actors map[uint32]Range

+ Day string

+ Index ObjectRange

+ PublishedAt int64

+ Sources []CompactSource

+ type CompactSource struct

+ Base uint64

+ Copied bool

+ Entries uint32

+ Payload ObjectRange

+ Sequence Sequence

+ Source string

+ Time [2]uint32

+ Writer string

+ type Event struct

+ func NewEvent(day time.Time, entry LogEntry) Event

+ func (e Event) Actors() iter.Seq[uint32]

+ func (e Event) Bytes() []byte

+ func (e Event) Clone() Event

+ func (e Event) JSON() json.RawMessage

+ func (e Event) Text() string

+ func (e Event) Time() time.Time

type LogEntry

+ func ValidateEntries(data []byte, expected uint32) ([]LogEntry, error)

+ func ValidateEntry(data []byte) (LogEntry, int, error)

+ func (e LogEntry) Millis() uint32

+ type Manifest struct

+ Chunks []ChunkEntry

+ Day string

+ Writer string

+ func (m *Manifest) NextSequence() uint64

+ type ObjectRange struct

+ ETag string

+ Key string

+ Offset int64

+ Size int64

+ type Range struct

+ Offset int64

+ Size int64

+ type Sequence uint64

+ func (s *Sequence) UnmarshalJSON(data []byte) error

+ func (s Sequence) MarshalJSON() ([]byte, error)

Jun 17, 2025

Changes in this version

+ func EncodeMetadata(meta *Metadata) ([]byte, error)

+ type ChunkEntry struct

+ Actors map[uint32]IndexEntry

+ Location [3]uint

+ Time [2]uint

+ func NewChunkEntry(offset uint64, bitmapSize, logSize uint32, startTime, endTime uint32, ...) ChunkEntry

+ func (e ChunkEntry) Between(start, end uint32) bool

+ func (e ChunkEntry) BitmapAt() uint32

+ func (e ChunkEntry) BitmapSize() uint32

+ func (e ChunkEntry) DataAt() uint32

+ func (e ChunkEntry) DataSize() uint32

+ func (e ChunkEntry) From() uint32

+ func (e ChunkEntry) Offset() uint64

+ func (e ChunkEntry) Size() uint32

+ func (e ChunkEntry) Until() uint32

+ type Codec struct

+ func NewCodec() (*Codec, error)

+ func (c *Codec) Close()

+ func (c *Codec) Compress(data []byte) ([]byte, error)

+ func (c *Codec) Decompress(compressed []byte) ([]byte, error)

+ type CompressionError struct

+ Err error

+ Operation string

+ func (e *CompressionError) Error() string

+ func (e *CompressionError) Unwrap() error

+ type IndexEntry [3]uint

+ func NewIndexEntry(timestamp uint32, offset uint64, size uint32) IndexEntry

+ type LogEntry []byte

+ func NewLogEntry(sequenceID uint32, text string, actors []uint32) (LogEntry, error)

+ func (e LogEntry) Actors() iter.Seq[uint32]

+ func (e LogEntry) ID() uint32

+ func (e LogEntry) Size() uint32

+ func (e LogEntry) Text() string

+ func (e LogEntry) Time(dayStart time.Time) time.Time

+ type Metadata struct

+ Chunks []ChunkEntry

+ Date int64

+ Length uint32

+ func DecodeMetadata(data []byte) (*Metadata, error)

+ func NewMetadata(dayStart time.Time) *Metadata

+ func (m *Metadata) Append(offset uint64, bitmapSize, logSize uint32, startTime, endTime uint32, ...) *Metadata