dsl

Documentation

Index

• Constants
• type Ops
  • func (o *Ops) Close() error
• type Reader
  • func (r *Reader[T]) Release() error
  • func (r *Reader[T]) Tr() *tr.Read
  • func (r *Reader[T]) View(f func(txn *tx.Tx) error) error
• type Schema
  • func NewSchema[T proto.Message](bsi ...string) (*Schema[T], error)
  • func (s *Schema[T]) Reset()
  • func (s *Schema[T]) Write(msg T)
• type Shard
• type Store
  • func New[T proto.Message](path string, bsi ...string) (*Store[T], error)
  • func (s *Store[T]) Append(data []T)
  • func (s *Store[T]) Close() error
  • func (s *Store[T]) DB() *rbf.DB
  • func (s *Store[T]) Flush() error
  • func (s *Store[T]) Reader() (*Reader[T], error)
  • func (s *Store[T]) Shards() *roaring64.Bitmap

Constants

const (
	ID = "_id"
)

Types

type Ops

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

func (*Ops) Close

func (o *Ops) Close() error

type Reader

type Reader[T proto.Message] struct {
	// contains filtered or unexported fields
}

func (*Reader[T]) Release

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

func (*Reader[T]) Tr

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

func (*Reader[T]) View

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

type Schema

type Schema[T proto.Message] struct {
	// contains filtered or unexported fields
}

Schema maps proto fields to rbf types.

func NewSchema

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

func (*Schema[T]) Reset

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

func (*Schema[T]) Write

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

type Shard

type Shard struct {
	Shard uint64
	Views []string
}

type Store

type Store[T proto.Message] struct {
	// contains filtered or unexported fields
}

func New

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

func (*Store[T]) Append

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

func (*Store[T]) Close

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

func (*Store[T]) DB

func (s *Store[T]) DB() *rbf.DB

func (*Store[T]) Flush

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

func (*Store[T]) Reader

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

Reader creates a new Reader for querying the store T. Make sure the reader is released after use.

func (*Store[T]) Shards

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