Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
| Total | |
0.00% |
0 / 1 |
|
0.00% |
0 / 2 |
CRAP | |
0.00% |
0 / 19 |
| MaxShardsPerNodeValidator | |
0.00% |
0 / 1 |
|
0.00% |
0 / 2 |
12 | |
0.00% |
0 / 19 |
| __construct | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 4 |
|||
| validate | |
0.00% |
0 / 1 |
6 | |
0.00% |
0 / 15 |
|||
| <?php | |
| namespace CirrusSearch\Maintenance\Validators; | |
| use CirrusSearch\Maintenance\Printer; | |
| use Elastica\Index; | |
| use Status; | |
| class MaxShardsPerNodeValidator extends Validator { | |
| /** | |
| * @var Index | |
| */ | |
| private $index; | |
| /** | |
| * @var int | |
| */ | |
| private $maxShardsPerNode; | |
| /** | |
| * @param Index $index | |
| * @param int $maxShardsPerNode | |
| * @param Printer|null $out | |
| */ | |
| public function __construct( Index $index, $maxShardsPerNode, Printer $out = null ) { | |
| parent::__construct( $out ); | |
| $this->index = $index; | |
| $this->maxShardsPerNode = $maxShardsPerNode; | |
| } | |
| /** | |
| * @return Status | |
| */ | |
| public function validate() { | |
| $this->outputIndented( "\tValidating max shards per node..." ); | |
| $settings = $this->index->getSettings()->get(); | |
| // Elasticsearch uses negative numbers or an unset value to represent unlimited. We accept 'unlimited' | |
| // but it is resolved when reading configuration and not here. | |
| $actualMaxShardsPerNode = $settings['routing']['allocation']['total_shards_per_node'] ?? -1; | |
| $expectedMaxShardsPerNode = $this->maxShardsPerNode; | |
| if ( $actualMaxShardsPerNode == $expectedMaxShardsPerNode ) { | |
| $this->output( "ok\n" ); | |
| } else { | |
| $this->output( "is $actualMaxShardsPerNode but should be $expectedMaxShardsPerNode..." ); | |
| $this->index->getSettings()->set( [ | |
| 'routing.allocation.total_shards_per_node' => $expectedMaxShardsPerNode | |
| ] ); | |
| $this->output( "corrected\n" ); | |
| } | |
| return Status::newGood(); | |
| } | |
| } |