jepsen.mongodb.core — jepsen.mongodb 0.2.3

await-conn clj

(await-conn node)

(await-conn node port)

Block until we can connect to the given node and port. Returns a connection to the process.

await-join clj

(await-join test conn port)

Block until all nodes in the test are known to this connection's replset status

await-primary clj

(await-primary conn)

Block until a primary is known to the current node.

clock-skew-nem clj

(clock-skew-nem clock dt)

Skews clocks on a random subset of nodes by dt seconds.

composite-nemesis clj

(composite-nemesis)

Combined nemesis for process kills, pauses, partitions, and clock skew.

db clj

(db clock url)

MongoDB for a particular HTTP URL

join! clj

(join! test node & opts)

Join nodes into a replica set. Blocks until any primary is visible to all nodes which isn't really what we want but oh well.

kill-nem clj

(kill-nem clock)

A nemesis that kills/restarts Mongo on randomly selected nodes.

mongo! clj

(mongo! cmd)

Run a Mongo shell command. Spits back an unparsable kinda-json string, because what else would 'printjson' do?

mongodb-test clj

(mongodb-test name opts)

Constructs a test with the given name prefixed by 'mongodb_', merging any given options. Special options for Mongo:

:tarball HTTP URL of a tarball to install :time-limit How long do we run the test for? :storage-engine Storage engine to use :protocol-version Replication protocol version

At the end of every test, we use the 'dbHash' command to verify data consistency across each member of the replica set. We extend the nemesis to handle the :compare-dbhashes operations because it is a client that is straightforward to compose via the jepsen.nemesis/compose function. We also extend the generator and checker accordingly.

nemesis-gen clj

(nemesis-gen nem)

Given a nemesis name, builds a generator that emits [:name-start, :name-stop] cycles.

pause-nem clj

(pause-nem)

A nemesis that pauses Mongo on randomly selected nodes.

primaries clj

(primaries conn)

What nodes does this conn think are primaries?

primary clj

(primary conn)

Which single node does this conn think the primary is? Throws for multiple primaries, cuz that sounds like a fun and interesting bug, haha.

primary-divergence-gen clj

(primary-divergence-gen)

primary-divergence-nemesis clj

(primary-divergence-nemesis clock)

(primary-divergence-nemesis clock conns)

A nemesis specifically designed to break Mongo's v0 replication protocol. There are three phases:

1. Isolate a primary p1 and advance its clock. Writes to this primary will not be successfully replicated, but will advance its oplog.

2. Allow a new primary p2 to become elected. Let it do some work, then kill it.

3. Heal the network and restart all nodes. p2 may have committed writes, but p1's higher optime will allow it to win the election.

replica-set-config clj

(replica-set-config conn)

Returns the current replset config.

replica-set-initiate! clj

(replica-set-initiate! conn config)

Initialize a replica set on a node.

replica-set-master? clj

(replica-set-master? conn)

What's this node's replset role?

replica-set-reconfigure! clj

(replica-set-reconfigure! conn conf)

Apply new configuration for a replica set.

replica-set-status clj

(replica-set-status conn)

Returns the current replica set status.

sharded-test? clj

(sharded-test? name)

std-gen clj

(std-gen)

A composite failure schedule, emitting partitions and clock skew ops.

target-replica-set-config clj

(target-replica-set-config test port repl-set-name)

Generates the config for a replset in a given test.

with-errors clj/s macro

(with-errors op idempotent-ops & body)

Takes an invocation operation, a set of idempotent operation functions which can be safely assumed to fail without altering the model state, and a body to evaluate. Catches MongoDB errors and maps them to failure ops matching the invocation.