dynamo

package module

v0.1.0 Latest Latest Go to latest Published: Apr 30, 2023 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func Add(ctx context.Context, store *Store, graph curie.IRI, bag spock.Bag) (spock.Bag, error)

func Match(ctx context.Context, store *Store, graph curie.IRI, q spock.Pattern) (spock.Stream, error)

func Put(ctx context.Context, store *Store, graph curie.IRI, spock spock.SPOCK) error

type Iterator[T dynamo.Thing] struct {
	// contains filtered or unexported fields
}

func (iter *Iterator[T]) Head() T

func (iter *Iterator[T]) Next() bool

type Seq[T dynamo.Thing] interface {
	Head() T
	Next() bool
}

func NewIterator[T dynamo.Thing](store *ddb.Storage[T], query T) Seq[T]

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

func New(connector string, opts ...dynamo.Option) (*Store, error)

type Unfold[T dynamo.Thing] struct {
	// contains filtered or unexported fields
}

func (unfold *Unfold[T]) FMap(f func(spock.SPOCK) error) error

func (unfold *Unfold[T]) Head() spock.SPOCK

func (unfold *Unfold[T]) Next() bool

type Writer interface {
	Put(ctx context.Context, store *Store) error
	Cut(ctx context.Context, store *Store) error
}