riak_functions.sh

# -*- shell-script -*-

function riak_dev_cleanup_stage() {
  for d in ~/Projects/riak/dev/dev{2,3,4,5}; do
    $d/bin/riak-admin cluster leave;
  done

  ~/Projects/riak/dev/dev1/bin/riak-admin cluster plan
}

function riak_dev_cleanup_commit() {
  ~/Projects/riak/dev/dev1/bin/riak-admin cluster commit

  for d in ~/Projects/riak/dev/*; do
    rm -rf $d/data;
  done
}

function riak_dev_setup() {
  riak_dev_start;

  for d in ~/Projects/riak/dev/dev{2,3,4,5}; do $d/bin/riak-admin cluster join 'dev1@127.0.0.1'; done
  ~/Projects/riak/dev/dev1/bin/riak-admin cluster plan
  ~/Projects/riak/dev/dev1/bin/riak-admin cluster commit
  ~/Projects/riak/dev/dev1/bin/riak-admin ringready
}

function riak_dev_teardown {
  riak_dev_stop;

  for d in ~/Projects/riak/dev/dev{1,2,3,4,5}; do rm -rf $d/data; done
}

function riak_dev_reset {
  riak_dev_teardown;
  riak_dev_setup;
}

### Generic Riak dev version setup
function riak_dev_start() {
  ulimit -n 16384;

  for d in ~/Projects/riak/dev/*; do $d/bin/riak start; done
  for d in ~/Projects/riak/dev/*; do $d/bin/riak ping; done

  ### Use this for configuring a brand new riak-dt cluster
  # for d in ~/Projects/riak/dev/dev{2,3,4,5}; do $d/bin/riak-admin cluster join 'dev1@127.0.0.1'; done
  # ~/Projects/riak/dev/dev1/bin/riak-admin cluster plan
  # ~/Projects/riak/dev/dev1/bin/riak-admin cluster commit
  # ~/Projects/riak/dev/dev1/bin/riak-admin ringready
}

function riak_dev_stop() {
  for d in ~/Projects/riak/dev/*; do $d/bin/riak stop; done
}