lambdaroyal.memory.eviction.core — org.clojars.gixxi/lambdaroyal-memory 1.2.2

an eviction channel listenes for successful database inserts/updates and deletes and performs some kind of I/O to them. For instance a concrete implementation could write all successful changes to the in-memory database to a external database to create a persistent version that can be imported during application ramp-up. Eviction channels can be configured to follow certain timing constraints like immediate post transaction eviction or cron like eviction, that is forwarding all the changes every x seconds. Invariants are: (1) Eviction is asynchronous to to the actual transaction, (2) Eviction might fail but to not cause the transaction to fail.

create-proxy clj

(create-proxy eviction-channel delay)

create-SysoutEvictionChannel clj

(create-SysoutEvictionChannel)

EvictionChannel clj protocol

delete clj

(delete this coll-name unique-key old-user-value)

called when a delete took place

delete-coll clj

(delete-coll this coll-name)

call this to delete the respective collection/db at all

insert clj

(insert this coll-name unique-key user-value)

called when a new value gets inserted into the database.

start clj

(start this ctx colls)

starts the eviction channel by reading in the persistent data into the in-memory db denoted by [ctx]. This function assumes that is eviction channel instance is handling all the collection [colls]. returns a future that can be joined to wait for the database to got warmed up.

started? clj

(started? this)

stop clj

(stop this)

closes the channel. Further evictions must throw an exception.

stopped? clj

(stopped? this)

returns true iff the channel was closed.

update clj

(update this coll-name unique-key old-user-value new-user-value)

called when an update took place

EvictionChannelHeartbeat clj protocol

alive? clj

(alive? this)

returns true iff the eviction channel is up'n running

EvictionChannelProxy clj

SysoutEvictionChannel clj

verbose' clj