dsl

package

v0.22.18 Latest Latest Go to latest Published: Jul 11, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

View Source

const (
	ID = "_id"
)

This section is empty.

func ViewKey(field, view string) string

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

func (o *Ops) Close() error

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

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[T proto.Message] struct {
	// contains filtered or unexported fields
}

Schema maps proto fields to rbf types.

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

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

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

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

type Shard struct {
	Shard uint64
	Views []string
}

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

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() *db.Shards

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

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.