summaryrefslogtreecommitdiff
path: root/vendor/ruflin/elastica/test/lib/Elastica/Test/Index/SettingsTest.php
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/ruflin/elastica/test/lib/Elastica/Test/Index/SettingsTest.php')
-rw-r--r--vendor/ruflin/elastica/test/lib/Elastica/Test/Index/SettingsTest.php300
1 files changed, 0 insertions, 300 deletions
diff --git a/vendor/ruflin/elastica/test/lib/Elastica/Test/Index/SettingsTest.php b/vendor/ruflin/elastica/test/lib/Elastica/Test/Index/SettingsTest.php
deleted file mode 100644
index 4f74d22b..00000000
--- a/vendor/ruflin/elastica/test/lib/Elastica/Test/Index/SettingsTest.php
+++ /dev/null
@@ -1,300 +0,0 @@
-<?php
-
-namespace Elastica\Test\Index;
-
-use Elastica\Document;
-use Elastica\Exception\ResponseException;
-use Elastica\Index;
-use Elastica\Index\Settings as IndexSettings;
-use Elastica\Test\Base as BaseTest;
-
-class SettingsTest extends BaseTest
-{
- public function testGet()
- {
- $indexName = 'elasticatest';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
- $index->refresh();
- $settings = $index->getSettings();
-
- $this->assertInternalType('array', $settings->get());
- $this->assertNotNull($settings->get('number_of_replicas'));
- $this->assertNotNull($settings->get('number_of_shards'));
- $this->assertNull($settings->get('kjqwerjlqwer'));
-
- $index->delete();
- }
-
- public function testGetWithAlias()
- {
- $indexName = 'elasticatest';
- $aliasName = 'elasticatest_alias';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
- $index->refresh();
-
- $index->addAlias($aliasName);
- $index = $client->getIndex($aliasName);
- $settings = $index->getSettings();
-
- $this->assertInternalType('array', $settings->get());
- $this->assertNotNull($settings->get('number_of_replicas'));
- $this->assertNotNull($settings->get('number_of_shards'));
- $this->assertNull($settings->get('kjqwerjlqwer'));
-
- $index->delete();
- }
-
- public function testSetNumberOfReplicas()
- {
- $indexName = 'test';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
- $settings = $index->getSettings();
-
- $settings->setNumberOfReplicas(2);
- $index->refresh();
- $this->assertEquals(2, $settings->get('number_of_replicas'));
-
- $settings->setNumberOfReplicas(3);
- $index->refresh();
- $this->assertEquals(3, $settings->get('number_of_replicas'));
-
- $index->delete();
- }
-
- public function testSetRefreshInterval()
- {
- $indexName = 'test';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
-
- $settings = $index->getSettings();
-
- $settings->setRefreshInterval('2s');
- $index->refresh();
- $this->assertEquals('2s', $settings->get('refresh_interval'));
-
- $settings->setRefreshInterval('5s');
- $index->refresh();
- $this->assertEquals('5s', $settings->get('refresh_interval'));
-
- $index->delete();
- }
-
- public function testGetRefreshInterval()
- {
- $indexName = 'test';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
-
- $settings = $index->getSettings();
-
- $this->assertEquals(IndexSettings::DEFAULT_REFRESH_INTERVAL, $settings->getRefreshInterval());
-
- $interval = '2s';
- $settings->setRefreshInterval($interval);
- $index->refresh();
- $this->assertEquals($interval, $settings->getRefreshInterval());
- $this->assertEquals($interval, $settings->get('refresh_interval'));
-
- $index->delete();
- }
-
- public function testSetMergePolicy()
- {
- $indexName = 'test';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
- //wait for the shards to be allocated
- $this->_waitForAllocation($index);
-
- $settings = $index->getSettings();
-
- $settings->setMergePolicy('expunge_deletes_allowed', 15);
- $this->assertEquals(15, $settings->getMergePolicy('expunge_deletes_allowed'));
-
- $settings->setMergePolicy('expunge_deletes_allowed', 10);
- $this->assertEquals(10, $settings->getMergePolicy('expunge_deletes_allowed'));
-
- $index->delete();
- }
-
- public function testSetMergeFactor()
- {
- $indexName = 'test';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
-
- //wait for the shards to be allocated
- $this->_waitForAllocation($index);
-
- $settings = $index->getSettings();
-
- $response = $settings->setMergePolicy('merge_factor', 15);
- $this->assertEquals(15, $settings->getMergePolicy('merge_factor'));
- $this->assertInstanceOf('Elastica\Response', $response);
- $this->assertTrue($response->isOk());
-
- $settings->setMergePolicy('merge_factor', 10);
- $this->assertEquals(10, $settings->getMergePolicy('merge_factor'));
-
- $index->delete();
- }
-
- public function testSetMergePolicyType()
- {
- $indexName = 'test';
-
- $client = $this->_getClient();
- $index = $client->getIndex($indexName);
- $index->create(array(), true);
-
- //wait for the shards to be allocated
- $this->_waitForAllocation($index);
-
- $settings = $index->getSettings();
-
- $settings->setMergePolicyType('log_byte_size');
- $this->assertEquals('log_byte_size', $settings->getMergePolicyType());
-
- $response = $settings->setMergePolicy('merge_factor', 15);
- $this->assertEquals(15, $settings->getMergePolicy('merge_factor'));
- $this->assertInstanceOf('Elastica\Response', $response);
- $this->assertTrue($response->isOk());
-
- $index->delete();
- }
-
- public function testSetReadOnly()
- {
- $index = $this->_createIndex('test');
- //wait for the shards to be allocated
- $this->_waitForAllocation($index);
- $index->getSettings()->setReadOnly(false);
-
-
- // Add document to normal index
- $doc1 = new Document(null, array('hello' => 'world'));
- $doc2 = new Document(null, array('hello' => 'world'));
- $doc3 = new Document(null, array('hello' => 'world'));
-
- $type = $index->getType('test');
- $type->addDocument($doc1);
- $this->assertEquals('false', $index->getSettings()->get('blocks.read_only')); //ES returns a string for this setting
-
- // Try to add doc to read only index
- $index->getSettings()->setReadOnly(true);
- $this->assertEquals('true', $index->getSettings()->get('blocks.read_only'));
-
- try {
- $type->addDocument($doc2);
- $this->fail('Should throw exception because of read only');
- } catch (ResponseException $e) {
- $message = $e->getMessage();
- $this->assertContains('ClusterBlockException', $message);
- $this->assertContains('index read-only', $message);
- }
-
- // Remove read only, add document
- $response = $index->getSettings()->setReadOnly(false);
- $this->assertTrue($response->isOk());
-
- $type->addDocument($doc3);
- $index->refresh();
-
- $this->assertEquals(2, $type->count());
-
- $index->delete();
- }
-
-
- public function testGetSetBlocksRead()
- {
- $index = $this->_createIndex('elastica-test');
- $index->refresh();
- $settings = $index->getSettings();
-
- $this->assertFalse($settings->getBlocksRead());
-
- $settings->setBlocksRead(true);
- $this->assertTrue($settings->getBlocksRead());
-
- $settings->setBlocksRead(false);
- $this->assertFalse($settings->getBlocksRead());
-
- $settings->setBlocksRead();
- $this->assertTrue($settings->getBlocksRead());
-
- $index->delete();
- }
-
- public function testGetSetBlocksWrite()
- {
- $index = $this->_createIndex('elastica-test');
- $index->refresh();
- $settings = $index->getSettings();
-
- $this->assertFalse($settings->getBlocksWrite());
-
- $settings->setBlocksWrite(true);
- $this->assertTrue($settings->getBlocksWrite());
-
- $settings->setBlocksWrite(false);
- $this->assertFalse($settings->getBlocksWrite());
-
- $settings->setBlocksWrite();
- $this->assertTrue($settings->getBlocksWrite());
-
- $index->delete();
- }
-
- public function testGetSetBlocksMetadata()
- {
- $index = $this->_createIndex('elastica-test');
- $index->refresh();
- $settings = $index->getSettings();
-
- $this->assertFalse($settings->getBlocksMetadata());
-
- $settings->setBlocksMetadata(true);
- $this->assertTrue($settings->getBlocksMetadata());
-
- $settings->setBlocksMetadata(false);
- $this->assertFalse($settings->getBlocksMetadata());
-
- $settings->setBlocksMetadata();
- $this->assertTrue($settings->getBlocksMetadata());
-
- $settings->setBlocksMetadata(false); // Cannot delete index otherwise
- $index->delete();
- }
-
- protected function _waitForAllocation(Index $index)
- {
- do {
- $settings = $index->getStatus()->get();
- $allocated = true;
- foreach ($settings['shards'] as $shard) {
- if ($shard[0]['routing']['state'] != 'STARTED') {
- $allocated = false;
- }
- }
- } while (!$allocated);
- }
-}
generated by cgit v1.2.2 (git 2.25.0) at 2024-04-18 23:29:03 +0000