x/solar
Code Issues Proposed changes

riak join fixes

Browse Source
This commit is contained in:
Jedrzej Nowak 2015-08-21 14:26:03 +02:00
parent 7dd79ac771
commit c8d75e128f
2 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
example-riaks.py
View File

@ -86,6 +86,18 @@ def setup_riak():
# Dep('riak_service1', 'run', 'success', 'riak_service2', 'join'),
# Dep('riak_service1', 'run', 'success', 'riak_service3', 'join'),
# React('riak_service2', 'join', 'error', 'riak_service2', 'leave'),
# React('riak_service3', 'join', 'error', 'riak_service3', 'leave'),
React('riak_service2', 'leave', 'success', 'riak_service2', 'join'),
React('riak_service3', 'leave', 'success', 'riak_service3', 'join'),
# React('riak_service2', 'leave', 'success', 'riak_service1', 'commit_leave'),
# React('riak_service3', 'leave', 'success', 'riak_service1', 'commit_leave'),
# Dep('riak_service1', 'commit_leave', 'success', 'riak_service2', 'join'),
# Dep('riak_service1', 'commit_leave', 'success', 'riak_service3', 'join'),
React('riak_service3', 'join', 'success', 'riak_service1', 'commit'),
React('riak_service2', 'join', 'success', 'riak_service1', 'commit')
]

11
resources/riak_node/actions/join.yml
View File

@ -2,3 +2,14 @@
sudo: yes
tasks:
- shell: riak-admin cluster join {{join_to}}
ignore_errors: true
register: join_output
# those below are hacky solution for "this node is already member of a cluster
# solar for now lacks logic that would allow to avoid it
- shell: /bin/true
when: join_output|failed and join_output.stdout.find("This node is already a member of a cluster") != -1
- shell: /bin/false
when: join_output|failed and join_output.stdout.find("This node is already a member of a cluster") == -1
- shell: /bin/true
when: join_output|success