meta

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

type Collection[R any] struct {
	// contains filtered or unexported fields
}

type CommitMode uint8

type Log[R any] struct {
	// contains filtered or unexported fields
}

type NamedTx[R any] struct {
	*RecordTx[R]
	// contains filtered or unexported fields
}

type Reader interface {
	GetRaw(ctx context.Context, ns, table, id string) (json.RawMessage, bool, error)
	// ScanRaw yields records in the engine's stable order (json: insertion).
	ScanRaw(ctx context.Context, ns, table string, fn func(id string, raw json.RawMessage) error) error
}

type RecordTx[R any] struct {
	// contains filtered or unexported fields
}

type Scope struct {
	Write string
	Read  []string
}

type Seq uint64

type Store interface {
	// View runs fn over a consistent snapshot of the given namespaces.
	View(ctx context.Context, nss []string, fn func(Reader) error) error
	// Update runs fn in a serializable transaction writing sc.Write; commit follows mode.
	Update(ctx context.Context, sc Scope, mode CommitMode, fn func(Writer) error) error
	// Events returns a coalesced change signal; release unsubscribes.
	Events(ctx context.Context) (<-chan struct{}, func(), error)
	Close() error
}

type WriteOpt uint8

type Writer interface {
	Reader
	PutRaw(ctx context.Context, ns, table, id string, raw json.RawMessage, relaxedOK bool) error
	DeleteRaw(ctx context.Context, ns, table, id string, relaxedOK bool) error
}