1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
"""Test the Cluster Routing Action"""
# pylint: disable=C0115, C0116, invalid-name
import os
from . import CuratorTestCase
from . import testvars
HOST = os.environ.get('TEST_ES_SERVER', 'http://127.0.0.1:9200')
class TestCLIClusterRouting(CuratorTestCase):
def test_allocation_all(self):
routing_type = 'allocation'
value = 'all'
self.write_config(self.args['configfile'], testvars.client_config.format(HOST))
self.write_config(
self.args['actionfile'],
testvars.cluster_routing_test.format(routing_type, value),
)
self.create_index('my_index')
self.create_index('not_my_index')
self.invoke_runner()
assert testvars.CRA_all == self.client.cluster.get_settings()
def test_extra_option(self):
self.write_config(self.args['configfile'], testvars.client_config.format(HOST))
self.write_config(
self.args['actionfile'],
testvars.bad_option_proto_test.format('cluster_routing'),
)
self.create_index('my_index')
self.create_index('not_my_index')
self.invoke_runner()
assert 1 == self.result.exit_code
|
