fluree.db.storage.core — com.fluree/db 1.0.0-rc5

block clj/s

(block conn network dbid block)

Reads a single block from storage

block-range clj/s

(block-range conn network dbid start)

(block-range conn network dbid start end)

Returns a channel that will contains blocks in specified range.

block-storage-path clj

(block-storage-path network dbid)

For a ledger server, will return the relative storage path it is using for blocks for a given ledger.

child-data clj/s

(child-data child)

Given a child, unresolved node, extracts just the data that will go into storage.

ledger-block-file-path clj/s

(ledger-block-file-path network ledger-id block)

ledger-block-key clj/s

(ledger-block-key network ledger-id block)

ledger-garbage-key clj/s

(ledger-garbage-key network ledger-key block)

ledger-node-key clj/s

(ledger-node-key network ledger-id idx-type base-id node-type)

ledger-root-key clj/s

(ledger-root-key network ledger-id block)

read-block clj/s

(read-block conn network ledger-id block)

Returns a core async channel with the requested block.

read-block-version clj/s

(read-block-version conn network ledger-id block version)

Returns a core async channel with the requested block.

read-branch clj/s

(read-branch conn key)

Reads and deserializes branch node.

read-db-root clj/s

(read-db-root conn network dbid block)

Returns all data for a db index root of a given block.

read-garbage clj/s

(read-garbage conn network dbid block)

Returns a all data for a db index root of a given block.

read-leaf clj/s

(read-leaf conn key)

Reads and deserializes a leaf node

reify-branch clj/s

(reify-branch conn
              config
              network
              dbid
              key
              block
              t
              tt-id
              leftmost?
              tempid
              error-fn)

Should throw if no result... should never be the case.

reify-db clj/s

(reify-db conn network dbid blank-db index)

Reifies db at specified index point. If unable to read db-root at index, throws.

reify-db-root clj/s

(reify-db-root conn blank-db root-data)

Constructs db from blank-db, and ensure index roots have proper config as unresolved nodes.

reify-history clj/s

(reify-history conn key error-fn)

reify-index-root clj/s

(reify-index-root conn index-configs network dbid index index-data block t)

Turns each index root node into an unresolved node.

reify-leaf clj/s

(reify-leaf conn config key block t rhs error-fn)

Should throw if no result... should never be the case.

resolve-history-range clj/s

(resolve-history-range node from-t to-t idx-novelty leftmost?)

Gets a history slice of a node with the oldest 't' from-t, to the most recent 't', to-t.

Returns sorted set in novelty's sort order (spot, psot, post, or opst)

resolve-t clj/s

(resolve-t node t idx-novelty rhs leftmost? remove-preds error-fn)

resolve-to-t clj/s

(resolve-to-t node
              id
              tempid
              rhs
              leftmost?
              t
              tt-id
              idx-novelty
              conn
              fast-foward-db?
              remove-preds)

serde clj/s

(serde conn)

Returns serializer from connection.

source-novelty-t clj/s

(source-novelty-t novelty first-flake rhs leftmost?)

(source-novelty-t novelty first-flake rhs leftmost? through-t)

Given a novelty set, a first-flake and rhs flake boundary, returns novelty subrange as a collection.

If through-t is specified, will return novelty only through the specified t.

storage-exists? clj/s

(storage-exists? conn key)

Returns truthy if the provided key exists in storage.

storage-read clj/s

(storage-read conn key)

Reads raw bytes from storage based on provided key. Returns core async channel with eventual response

storage-write clj/s

(storage-write conn key val)

Writes raw bytes to storage based with provided key.

UnresolvedNode clj/s

write-block clj/s

(write-block conn network dbid block-data)

Block data should look like:

{:block block (long) :flakes flakes :hash hash :sigs sigs :txns {tid (tx-id, string) {:cmd command (JSON string) :sig signature (string}]}

write-block-version clj/s

(write-block-version conn network dbid block-data version)

Block data should look like:

{:block block (long) :flakes flakes :hash hash :sigs sigs :txns {tid (tx-id, string) {:cmd command (JSON string) :sig signature (string}]}

write-branch clj/s

(write-branch conn network dbid idx-type id children)

Returns core async channel with index key

write-branch-data clj/s

(write-branch-data conn key data)

Serializes final data for branch and writes it to provided key

write-db-root clj/s

(write-db-root db)

(write-db-root db custom-ecount)

write-garbage clj/s

(write-garbage db {:keys [garbage] :as progress})

Writes garbage record out for latest index.

write-history clj/s

(write-history conn history his-key next-his-key)

write-leaf clj/s

(write-leaf conn network dbid idx-type id flakes history)

Writes a leaf plus its history.

Writes history first, and only on successful history write then writes leaf.

Returns leaf's key