Geis

creates a new Geis instance

constructor for a Geis class

Throw:

stores config like table name

stores the state of the locking mechanism

the default namespace for this lock

shorter reference to the raw REQL object

The table where this instance's locks live This should be consistent across application instances

the Thinky instance to use for our Locks

polls until the instance obtains a lock

assigns properties to the Geis instance

returns attributes for a given Geis update

Create a new instance of the object with same properties than original.

fetches the lease for this Geis instance from RethinkDB

generates a unique token on the RethinkDB instance

kills the thinky instance, primarily used for testing cleanup, unlikely to needed in production

gets the next closests expiry timestamp in MS

convenience method for determining if the Table is ready for queries

releases the lock on the current instance

replace Query for replacing a lock instance in REQL

obtains a lock and then runs an unary function that receives a done callback it also transparently handles functions that return a {Promise}

Example:

lock.synchronize( function (done) {
   write_to_shared_file(data, function (err, result){
     if (err) return done(err) // throws unless caught because we should propogate errors
     done(result)
   })
})
.catch( err => {
   // handle err
})
.then( result => {
   // handle success
})

lock.synchronize( function () {
 return promised_write_to_shared_file(data)
})
.catch( err => {
   // handle error
})
.then( result => {
   // handle success
})

resets the expiry to 5 seconds in the future for an acquired lock

Throw:

tries to attain a lease on the current instance

atomic update Query for a lock update REQL operation