gleamunison/storage

Types

StorageAdapter

Trusted key/value primitives, including mutable branch pointers. Untrusted immutable content must use insert_content, not insert directly.

pub type StorageAdapter {
  StorageAdapter(
    insert: fn(identity.DefinitionRef, BitArray) -> Result(
      Nil,
      StorageError,
    ),
    lookup: fn(identity.DefinitionRef) -> Result(
      option.Option(BitArray),
      StorageError,
    ),
    list_refs: fn() -> Result(
      List(identity.DefinitionRef),
      StorageError,
    ),
    close: fn() -> Result(Nil, StorageError),
  )
}

Constructors

StorageAdapter(
  insert: fn(identity.DefinitionRef, BitArray) -> Result(
    Nil,
    StorageError,
  ),
  lookup: fn(identity.DefinitionRef) -> Result(
    option.Option(BitArray),
    StorageError,
  ),
  list_refs: fn() -> Result(
    List(identity.DefinitionRef),
    StorageError,
  ),
  close: fn() -> Result(Nil, StorageError),
)

StorageError

</>

pub type StorageError {
  StorageError(message: String)
  NotFound
  IoError(reason: String)
}

Constructors

```
StorageError(message: String)
```
```
NotFound
```
```
IoError(reason: String)
```

Values

check_content

</>

pub fn check_content(
  adapter: StorageAdapter,
  ref: identity.DefinitionRef,
) -> Result(Nil, StorageError)

Check a known immutable ref. Mutable pointer cells are not CAS content.

dets

</>

pub fn dets(path: String) -> Result(StorageAdapter, StorageError)

dets_delete_file

</>

pub fn dets_delete_file(
  path: String,
) -> Result(Nil, StorageError)

inmemory

</>

pub fn inmemory() -> StorageAdapter

insert_content

</>

pub fn insert_content(
  adapter: StorageAdapter,
  ref: identity.DefinitionRef,
  bytes: BitArray,
) -> Result(Nil, StorageError)

Validate before write; preserve the first valid binding and report I/O errors.

mnesia

</>

pub fn mnesia(
  table_name: String,
) -> Result(StorageAdapter, StorageError)

partitioned_dets

</>

pub fn partitioned_dets(
  dir_path: String,
) -> Result(StorageAdapter, StorageError)

partitioned_dets_delete

</>

pub fn partitioned_dets_delete(
  dir_path: String,
) -> Result(Nil, StorageError)

verify_content

</>

pub fn verify_content(
  ref: identity.DefinitionRef,
  bytes: BitArray,
) -> Result(Nil, StorageError)