(Detailed Design) Distributed artefacts - IKANOW/Aleph2 GitHub Wiki

Zookeeper locks

  • /app/aleph2/locks/v1/sources - (actually a latch) ensures only one process is monitoring the v1 source database at a time

  • /app/aleph2/locks/v1/library_jars - (actually a latch) ensures only one process is monitoring the v1 shared file database at a time

  • /app/aleph2/locks/<hostname:application_name> - ensures only one application of each type is running per node (and also handles some ZK race conditions). "<application_name>" comes from the configuration

  • /akka/cluster/seed - used by a 3rd party lib to co-ordinate joining the management cluster via Zookeeper

Actor messages buses subscription indicators

  • /app/aleph2/bucket_actions - the message bus to which distributed bucket actions are broadcast
  • /app/aleph2/streaming_enrichment - the message bus to which distributed bucket actions are broadcast