dsl

Jul 12, 2024

Changes in this version

type Store

+ func (s *Store[T]) Shards() *roaring64.Bitmap

Jul 11, 2024

Changes in this version

type Schema

+ func NewSchema[T proto.Message](bsi ...string) (*Schema[T], error)

+ func (s *Schema[T]) Process(db *Store[T]) error

+ func (s *Schema[T]) Reset()

type Store

+ func (s *Store[T]) Flush() error

Jul 9, 2024

Changes in this version

type Option

+ func WithSkip[T proto.Message](field ...string) Option[T]

Jul 8, 2024

Changes in this version

type Option

+ func WithTimestampField[T proto.Message](name string) Option[T]

Jul 8, 2024

Changes in this version

+ type Option func(store *Store[T])

Jul 6, 2024

Changes in this version

+ const ID

+ const IngestQuantum

+ const Quantum

+ const StandardView

+ const TimestampField

+ func Bool(r *roaring.Bitmap, _ *tr.Write, _ protoreflect.FieldDescriptor, id uint64, ...)

+ func Bytes(r *roaring.Bitmap, tr *tr.Write, field protoreflect.FieldDescriptor, id uint64, ...)

+ func Enum(r *roaring.Bitmap, _ *tr.Write, _ protoreflect.FieldDescriptor, id uint64, ...)

+ func Float64(r *roaring.Bitmap, _ *tr.Write, _ protoreflect.FieldDescriptor, id uint64, ...)

+ func Int64(r *roaring.Bitmap, _ *tr.Write, _ protoreflect.FieldDescriptor, id uint64, ...)

+ func Millisecond(value protoreflect.Value) time.Time

+ func Nanosecond(value protoreflect.Value) time.Time

+ func String(r *roaring.Bitmap, tr *tr.Write, field protoreflect.FieldDescriptor, id uint64, ...)

+ func Uint64(r *roaring.Bitmap, _ *tr.Write, _ protoreflect.FieldDescriptor, id uint64, ...)

+ func ViewKey(field, view string) string

+ type Fields map[string]*roaring.Bitmap

+ type Ops struct

+ func (o *Ops) Close() error

+ type RangeCallback func(shard uint64, views Views) error

+ type Reader struct

+ func (r *Reader[T]) Release() error

+ func (r *Reader[T]) Tr() *tr.Read

+ func (r *Reader[T]) View(shard Shard, f func(txn *tx.Tx) error) error

+ func (r Reader[T]) Range(start, end time.Time) []Shard

+ func (r Reader[T]) RangeUnit(start, end time.Time, unit rune) []Shard

+ func (r Reader[T]) Standard() Shard

+ type Schema struct

+ func (s *Schema[T]) Commit(m map[string]*roaring.Bitmap) error

+ func (s *Schema[T]) Range(f RangeCallback) error

+ func (s *Schema[T]) Release() (err error)

+ func (s *Schema[T]) Save() error

+ func (s *Schema[T]) Write(msg T) error

+ type Shard struct

+ Shard uint64

+ Views []string

+ type Shards map[uint64]Views

+ type Store struct

+ func New[T proto.Message](path string) (*Store[T], error)

+ func (s *Store[T]) Append(data []T) error

+ func (s *Store[T]) Close() error

+ func (s *Store[T]) DB() *db.Shards

+ func (s *Store[T]) Reader() (*Reader[T], error)

+ func (s *Store[T]) Schema() (*Schema[T], error)

+ type Views map[string]Fields

+ type Writers map[string]writeFn

Jun 28, 2024

Changes in this version

+ func AddBSI(m *roaring.Bitmap, id, value uint64)

+ func AddBoolean(m *roaring.Bitmap, id uint64, value bool)

+ func AddMutex(m *roaring.Bitmap, id uint64, value uint64)

+ func CompareValueBSI(tx *rbf.Tx, view string, shard uint64, op Operation, valueOrStart uint64, ...) (*rows.Row, error)

+ func ExtractValuesBSI(tx *rbf.Tx, view string, shard uint64, exists *rows.Row, ...) error

+ func ExtractValuesBSIValidate(tx *rbf.Tx, view string, shard uint64, columns *rows.Row, ...) error

+ func False(tx *rbf.Tx, view string, shard uint64, columns *rows.Row) (*rows.Row, error)

+ func Row(tx *rbf.Tx, view string, shard uint64, rowID uint64) (*rows.Row, error)

+ func Rows(tx *rbf.Tx, view string, start uint64, cb func(row uint64) error, ...) error

+ func True(tx *rbf.Tx, view string, shard uint64, columns *rows.Row) (*rows.Row, error)

+ type Operation int

+ const EQ

+ const GE

+ const GT

+ const LE

+ const LT

+ const NEQ

+ const RANGE