simioj: A Clojure repository from gordyt

Simioj - Distribute Execution Environment

Welcome to the Zimbra Simioj project. Simioj is designed to be an extensible framework that allows for the reliable execution of tasks in a clustered environment.

Examples of the type of tasks that it could support include, but are not limited to:

A distributed, replicated key-value system the supports functional metadata updates via PATCH operations.
Maintenance of per-resource queues of asynchronous operations with guarantees that only a single actor in the system will operate on that resource at one time.

Additional Set-Up for Code Quality Checks

Recommend adding the following to $HOME/.lein/profiles.clj:

{:user {:dependencies [[acyclic/squiggly-clojure "0.1.5"]
                       [org.clojure/tools.nrepl "0.2.7"]]
        :aliases {"bikeshed" ["bikeshed" "--max-line-length" "132"]}
        :plugins [[cider/cider-nrepl "0.12.0-SNAPSHOT"]
                  [jonase/kibit "0.0.8"]
                  [lein-kibit "0.1.2"]
                  [lein-cloverage "1.0.6"]
                  [lein-bikeshed "0.3.0"]
                  [jonase/eastwood "0.2.3" :exclusions [org.clojure/clojure]]
                  [lein-bin "0.3.5"]]}}

Then, before committing any work, run the following and fix any issues that are reported:

lein do kibit, eastwood, bikeshed

Work-in-Progress

This project is a work-in-progress. This README will be updated when it is ready for public consumption.

Organization

Major components in zimbra.simioj

actor
- Convert a type or record such that it can process messages in its own thread using a core.async channel as the mailbox.
config
- Load and merge configuration
- Accessor functions for various configuration items
discovery
- Discover and maintain node topology
- Notify interested parties regarding topology changes
endpoint/http
- HTTP interface for APIs and Cluster
main
- startup code
raft/
- server
  - Raft server protocol and core implementations
- log
  - Raft log protocol and core implementations
- statemachine
  - Raft statemachine protocol and core implementations
util
- Miscellaneous utility functions that don't belong anywhere else.

Raft Consensus Algorithm

Simioj uses an implementation of the Raft Consensus Algorithm to maintain a hierarchy of distributed state machines.

At the top level there will be a cluster-wide state machine that uses the normal Raft election protocol. The default implementation provided will be used to maintain a pool of shards that is distributed across the cluster. The number of shards and the number of replicas will be controlled via configuration.

Each "leader" shard and its associated replicas (followers) will form a separate "micro" Raft cluster. A default logging state machine implementation that allows for resource-level logging operations will be provided.

License