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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
<?php
namespace Elastica\Test\Cluster;
use Elastica\Cluster\Settings;
use Elastica\Document;
use Elastica\Exception\ResponseException;
use Elastica\Test\Base as BaseTest;
class SettingsTest extends BaseTest
{
/**
* @group functional
*/
public function testSetTransient()
{
$index = $this->_createIndex();
if (count($index->getClient()->getCluster()->getNodes()) < 2) {
$this->markTestSkipped('At least two master nodes have to be running for this test');
}
$settings = new Settings($index->getClient());
$settings->setTransient('discovery.zen.minimum_master_nodes', 2);
$data = $settings->get();
$this->assertEquals(2, $data['transient']['discovery']['zen']['minimum_master_nodes']);
$settings->setTransient('discovery.zen.minimum_master_nodes', 1);
$data = $settings->get();
$this->assertEquals(1, $data['transient']['discovery']['zen']['minimum_master_nodes']);
}
/**
* @group functional
*/
public function testSetPersistent()
{
$index = $this->_createIndex();
if (count($index->getClient()->getCluster()->getNodes()) < 2) {
$this->markTestSkipped('At least two master nodes have to be running for this test');
}
$settings = new Settings($index->getClient());
$settings->setPersistent('discovery.zen.minimum_master_nodes', 2);
$data = $settings->get();
$this->assertEquals(2, $data['persistent']['discovery']['zen']['minimum_master_nodes']);
$settings->setPersistent('discovery.zen.minimum_master_nodes', 1);
$data = $settings->get();
$this->assertEquals(1, $data['persistent']['discovery']['zen']['minimum_master_nodes']);
}
/**
* @group functional
*/
public function testSetReadOnly()
{
// Create two indices to check that the complete cluster is read only
$settings = new Settings($this->_getClient());
$settings->setReadOnly(false);
$index1 = $this->_createIndex();
$index2 = $this->_createIndex();
$doc1 = new Document(null, array('hello' => 'world'));
$doc2 = new Document(null, array('hello' => 'world'));
$doc3 = new Document(null, array('hello' => 'world'));
$doc4 = new Document(null, array('hello' => 'world'));
$doc5 = new Document(null, array('hello' => 'world'));
$doc6 = new Document(null, array('hello' => 'world'));
// Check that adding documents work
$index1->getType('test')->addDocument($doc1);
$index2->getType('test')->addDocument($doc2);
$response = $settings->setReadOnly(true);
$this->assertFalse($response->hasError());
$setting = $settings->getTransient('cluster.blocks.read_only');
$this->assertEquals('true', $setting);
// Make sure both index are read only
try {
$index1->getType('test')->addDocument($doc3);
$this->fail('should throw read only exception');
} catch (ResponseException $e) {
$message = $e->getMessage();
$this->assertContains('ClusterBlockException', $message);
$this->assertContains('cluster read-only', $message);
}
try {
$index2->getType('test')->addDocument($doc4);
$this->fail('should throw read only exception');
} catch (ResponseException $e) {
$message = $e->getMessage();
$this->assertContains('ClusterBlockException', $message);
$this->assertContains('cluster read-only', $message);
}
$response = $settings->setReadOnly(false);
$this->assertFalse($response->hasError());
$setting = $settings->getTransient('cluster.blocks.read_only');
$this->assertEquals('false', $setting);
// Check that adding documents works again
$index1->getType('test')->addDocument($doc5);
$index2->getType('test')->addDocument($doc6);
$index1->refresh();
$index2->refresh();
// 2 docs should be in each index
$this->assertEquals(2, $index1->count());
$this->assertEquals(2, $index2->count());
}
}
|
