asami.durable.store — org.clojars.quoll/asami 2.0.0-alpha9

The implements the Block storage version of a Graph/Database/Connection

as-of* clj/s

(as-of* {{:keys [tx-manager] :as connection} :connection
         bgraph :bgraph
         timestamp :timestamp
         t :t
         :as database}
        t-val)

Inputs: [{{:keys [tx-manager], :as connection} :connection, bgraph :bgraph, timestamp :timestamp, t :t, :as database} :- DatabaseType t-val] Returns: DatabaseType

Returns a database value for a provided t-value. If t-val is the transaction number for an older database, then returns that database. Otherwise, will return this database If t-val is a timestamp then returns the most recent database that was valid at that time.

create-database clj/s

(create-database name)

Inputs: [name :- s/Str] Returns: ConnectionType

This opens a connection to an existing database by the name of the location for resources. If the database does not exist then it is created.

db* clj/s

(db* {:keys [name tx-manager grapha] :as connection})

Inputs: [{:keys [name tx-manager grapha], :as connection} :- ConnectionType] Returns: DatabaseType

Returns the most recent database value from the connection.

db-exists? clj/s

(db-exists? store-name)

Inputs: [store-name :- s/Str] Returns: s/Bool

Tests if this database exists by looking for the transaction file

DBsBeforeAfter clj/s

delete-database* clj/s

(delete-database* {:keys [name grapha tx-manager] :as connection})

Inputs: [{:keys [name grapha tx-manager], :as connection} :- ConnectionType]

Delete the graph, which will recursively delete all resources

DurableConnection clj/s

DurableDatabase clj/s

entity* clj/s

(entity* {bgraph :bgraph :as database} id nested?)

Inputs: [{bgraph :bgraph, :as database} id nested? :- s/Bool] Returns: (s/maybe #:s{Keyword s/Any})

new-db clj/s

(new-db)

Inputs: [] Returns: TxRecordPacked

pack-tx clj/s

(pack-tx {:keys [r-spot r-post r-ospt r-pool nodes timestamp]})

Inputs: [{:keys [r-spot r-post r-ospt r-pool nodes timestamp]} :- TxRecord] Returns: TxRecordPacked

Packs a transaction into a vector for serialization

release* clj/s

(release* {:keys [name grapha tx-manager] :as connection})

Inputs: [{:keys [name grapha tx-manager], :as connection} :- ConnectionType]

Closes the transaction manager, and the graph, which will recursively close all resources

since* clj/s

(since* {{tx-manager :tx-manager :as connection} :connection
         timestamp :timestamp
         bgraph :bgraph
         t :t
         :as database}
        t-val)

Inputs: [{{tx-manager :tx-manager, :as connection} :connection, timestamp :timestamp, bgraph :bgraph, t :t, :as database} :- DatabaseType t-val] Returns: (s/maybe DatabaseType)

Returns the next database value after the provided t-value. If t-val is a transaction number for an older databse, then it returns the next database. If it refers to the current database or later, then returns nil (even if more recent databases exist, since this database is stateless. If t-val is a timestamp, then it returns the next database after that time, unless the timestamp is at or after the timestamp on the current database.

transact-data* clj/s≠

clj

(transact-data* conn generator-fn)

(transact-data* conn asserts retracts)

cljs

(transact-data* G__64877 G__64878)

(transact-data* G__64871 G__64872 G__64873)

Inputs: ([conn :- ConnectionType asserts :- [Triple] retracts :- [Triple]] [conn :- ConnectionType generator-fn]) Returns: DBsBeforeAfter

Removes a series of tuples from the latest graph, and asserts new tuples into the graph. Updates the connection to the new graph.

transact-update* clj/s

(transact-update* {:keys [tx-manager grapha nodea] :as connection} update-fn)

Inputs: [{:keys [tx-manager grapha nodea], :as connection} :- ConnectionType update-fn :- UpdateFunction] Returns: DBsBeforeAfter

Updates a graph according to a provided function. This will be done in a new, single transaction.

tx-name clj/s

tx-record-size clj/s

TxRecord clj/s

TxRecordPacked clj/s

unpack-tx clj/s

(unpack-tx {[r-spot r-post r-ospt r-pool nodes] :tx-data timestamp :timestamp})

Inputs: [{[r-spot r-post r-ospt r-pool nodes] :tx-data, timestamp :timestamp} :- TxRecordPacked] Returns: TxRecord

Unpacks a transaction vector into a structure when deserializing

UpdateFunction clj/s