Liking cljdoc? Tell your friends :D

asami.durable.store

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

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

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.

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.
sourceraw docstring

create-databaseclj/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.

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.
sourceraw docstring

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.

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

Returns the most recent database value from the connection.
sourceraw docstring

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

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

Tests if this database exists by looking for the transaction file
sourceraw docstring

DBsBeforeAfterclj/s

source

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

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

Delete the graph, which will recursively delete all resources
sourceraw docstring

DurableConnectionclj/s

source

DurableDatabaseclj/s

source

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})

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

new-dbclj/s

(new-db)

Inputs: [] Returns: TxRecordPacked

Inputs: []
Returns: TxRecordPacked
sourceraw docstring

pack-txclj/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

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

Packs a transaction into a vector for serialization
sourceraw docstring

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

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

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

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.

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.
sourceraw docstring

transact-data*clj/s

(transact-data* connection asserts retracts)

Inputs: [connection :- ConnectionType asserts :- [Triple] retracts :- [Triple]] Returns: DBsBeforeAfter

Takes a seq of statements to be asserted, and a seq of statements to be retracted, and applies them each to the graph. A new database is created in the process.

Inputs: [connection :- ConnectionType asserts :- [Triple] retracts :- [Triple]]
Returns: DBsBeforeAfter

Takes a seq of statements to be asserted, and a seq of statements to be retracted, and applies them each to the graph.
A new database is created in the process.
sourceraw docstring

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.

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.
sourceraw docstring

tx-nameclj/s

source

tx-record-sizeclj/s

source

TxRecordclj/s

source

TxRecordPackedclj/s

source

unpack-txclj/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

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
sourceraw docstring

UpdateFunctionclj/s

source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close