Elastification\Client\Repository\CatRepository

Complexity

Total Complexity

16

Size/Duplication

Total Lines	192
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	0	Features	1

15 Methods

Rating	Name	Duplication	Size	Complexity
A	aliases()	0	6	1
A	allocation()	0	6	1
A	count()	0	6	1
A	fielddata()	0	6	1
A	health()	0	6	1
A	indices()	0	6	1
A	master()	0	6	1
A	nodes()	0	6	1
A	pendingTasks()	0	6	1
A	plugins()	0	6	1
A	recovery()	0	6	1
A	segments()	0	6	1
A	shards()	0	6	1
A	threadPool()	0	6	1
A	getClass()	0	9	2

<?php
/*
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the MIT license.
 */

namespace Elastification\Client\Repository;

use Elastification\Client\ClientVersionMapInterface;
use Elastification\Client\Exception\RepositoryException;

class CatRepository extends AbstractRepository implements CatRepositoryInterface
{

    /**
     * Gets aliases from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     * @author Daniel Wendlandt
     */
    public function aliases()
    {
        $request = $this->createRequestInstance(self::CAT_ALIASES, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets allocation from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function allocation()
    {
        $request = $this->createRequestInstance(self::CAT_ALLOCATION, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets count from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function count()
    {
        $request = $this->createRequestInstance(self::CAT_COUNT, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets fielddata from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function fielddata()
    {
        $request = $this->createRequestInstance(self::CAT_FIELDDATA, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets health from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function health()
    {
        $request = $this->createRequestInstance(self::CAT_HEALTH, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets indices from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function indices()
    {
        $request = $this->createRequestInstance(self::CAT_INDICES, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets master from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function master()
    {
        $request = $this->createRequestInstance(self::CAT_MASTER, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets nodes from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function nodes()
    {
        $request = $this->createRequestInstance(self::CAT_NODES, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets pending tasks from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function pendingTasks()
    {
        $request = $this->createRequestInstance(self::CAT_PENDING_TASKS, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets plugins from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function plugins()
    {
        $request = $this->createRequestInstance(self::CAT_PLUGINS, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets recovery from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function recovery()
    {
        $request = $this->createRequestInstance(self::CAT_RECOVERY, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets segments from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function segments()
    {
        $request = $this->createRequestInstance(self::CAT_SEGMENTS, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets shards from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function shards()
    {
        $request = $this->createRequestInstance(self::CAT_SHARDS, null, null);

        return $this->client->send($request);
    }

    /**
     * Gets thread pool from cat api
     *
     * @return \Elastification\Client\Response\ResponseInterface
     */
    public function threadPool()
    {
        $request = $this->createRequestInstance(self::CAT_THREAD_POOL, null, null);

        return $this->client->send($request);
    }

    /**
     * gets the right class string of a version
     *
     * @param string $class
     *
     * @return string
     * @throws RepositoryException
     * @author Daniel Wendlandt
     */
    protected function getClass($class)
    {
        if(ClientVersionMapInterface::VERSION_V090X === $this->versionFolder) {
            throw new RepositoryException('Version folder ' .
                ClientVersionMapInterface::VERSION_V090X . ' is not allowed for cat repository');
        }

        return parent::getClass($class);
    }

}