aarondb/storage

Types

StorageAdapter

pub type StorageAdapter {
  StorageAdapter(
    insert: fn(List(fact.Datom)) -> Result(Nil, StorageError),
    append: fn(List(fact.Datom)) -> Result(Nil, StorageError),
    read: fn(String) -> Result(List(fact.Datom), StorageError),
    read_all: fn() -> Result(List(fact.Datom), StorageError),
    query_datoms: fn(#(ast.Part, String, ast.Part)) -> Result(
      List(fact.Datom),
      StorageError,
    ),
  )
}

Constructors

StorageAdapter(
  insert: fn(List(fact.Datom)) -> Result(Nil, StorageError),
  append: fn(List(fact.Datom)) -> Result(Nil, StorageError),
  read: fn(String) -> Result(List(fact.Datom), StorageError),
  read_all: fn() -> Result(List(fact.Datom), StorageError),
  query_datoms: fn(#(ast.Part, String, ast.Part)) -> Result(
    List(fact.Datom),
    StorageError,
  ),
)

StorageError

pub type StorageError {
  StorageError(message: String)
  TransactionError(reason: String)
  NotFoundError
}

Constructors

```
StorageError(message: String)
```
```
TransactionError(reason: String)
```
```
NotFoundError
```

Values

append

pub fn append(
  adapter: StorageAdapter,
  datoms: List(fact.Datom),
) -> Result(Nil, StorageError)

ephemeral

pub fn ephemeral() -> StorageAdapter

insert

pub fn insert(
  adapter: StorageAdapter,
  datoms: List(fact.Datom),
) -> Result(Nil, StorageError)

query_datoms

pub fn query_datoms(
  adapter: StorageAdapter,
  pattern: #(ast.Part, String, ast.Part),
) -> Result(List(fact.Datom), StorageError)

read_all

pub fn read_all(
  adapter: StorageAdapter,
) -> Result(List(fact.Datom), StorageError)