summaryrefslogtreecommitdiff
path: root/vendor/ruflin/elastica/lib/Elastica/Connection.php
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/ruflin/elastica/lib/Elastica/Connection.php')
-rw-r--r--vendor/ruflin/elastica/lib/Elastica/Connection.php274
1 files changed, 0 insertions, 274 deletions
diff --git a/vendor/ruflin/elastica/lib/Elastica/Connection.php b/vendor/ruflin/elastica/lib/Elastica/Connection.php
deleted file mode 100644
index b9d910c9..00000000
--- a/vendor/ruflin/elastica/lib/Elastica/Connection.php
+++ /dev/null
@@ -1,274 +0,0 @@
-<?php
-
-namespace Elastica;
-use Elastica\Exception\InvalidException;
-use Elastica\Transport\AbstractTransport;
-
-/**
- * Elastica connection instance to an elasticasearch node
- *
- * @category Xodoa
- * @package Elastica
- * @author Nicolas Ruflin <spam@ruflin.com>
- */
-class Connection extends Param
-{
- /**
- * Default elastic search port
- */
- const DEFAULT_PORT = 9200;
-
- /**
- * Default host
- */
- const DEFAULT_HOST = 'localhost';
-
- /**
- * Default transport
- *
- * @var string
- */
- const DEFAULT_TRANSPORT = 'Http';
-
- /**
- * Number of seconds after a timeout occurs for every request
- * If using indexing of file large value necessary.
- */
- const TIMEOUT = 300;
-
- /**
- * Creates a new connection object. A connection is enabled by default
- *
- * @param array $params OPTIONAL Connection params: host, port, transport, timeout. All are optional
- */
- public function __construct(array $params = array())
- {
- $this->setParams($params);
- $this->setEnabled(true);
-
- // Set empty config param if not exists
- if (!$this->hasParam('config')) {
- $this->setParam('config', array());
- }
- }
-
- /**
- * @return int Server port
- */
- public function getPort()
- {
- return $this->hasParam('port')?$this->getParam('port'):self::DEFAULT_PORT;
- }
-
- /**
- * @param int $port
- * @return \Elastica\Connection
- */
- public function setPort($port)
- {
- return $this->setParam('port', (int) $port);
- }
-
- /**
- * @return string Host
- */
- public function getHost()
- {
- return $this->hasParam('host')?$this->getParam('host'):self::DEFAULT_HOST;
- }
-
- /**
- * @param string $host
- * @return \Elastica\Connection
- */
- public function setHost($host)
- {
- return $this->setParam('host', $host);
- }
-
- /**
- * @return string|null Host
- */
- public function getProxy()
- {
- return $this->hasParam('proxy')?$this->getParam('proxy'):null;
- }
-
- /**
- * Set proxy for http connections. Null is for environmental proxy,
- * empty string to disable proxy and proxy string to set actual http proxy.
- *
- * @see http://curl.haxx.se/libcurl/c/curl_easy_setopt.html#CURLOPTPROXY
- * @param string|null $proxy
- * @return \Elastica\Connection
- */
- public function setProxy($proxy)
- {
- return $this->setParam('proxy', $proxy);
- }
-
- /**
- * @return string|array
- */
- public function getTransport()
- {
- return $this->hasParam('transport')?$this->getParam('transport'):self::DEFAULT_TRANSPORT;
- }
-
- /**
- * @param string|array $transport
- * @return \Elastica\Connection
- */
- public function setTransport($transport)
- {
- return $this->setParam('transport', $transport);
- }
-
- /**
- * @return string
- */
- public function getPath()
- {
- return $this->hasParam('path')?$this->getParam('path'):'';
- }
-
- /**
- * @param string $path
- * @return \Elastica\Connection
- */
- public function setPath($path)
- {
- return $this->setParam('path', $path);
- }
-
- /**
- * @param int $timeout Timeout in seconds
- * @return \Elastica\Connection
- */
- public function setTimeout($timeout)
- {
- return $this->setParam('timeout', $timeout);
- }
-
- /**
- * @return int Connection timeout in seconds
- */
- public function getTimeout()
- {
- return (int) $this->hasParam('timeout')?$this->getParam('timeout'):self::TIMEOUT;
- }
-
- /**
- * Enables a connection
- *
- * @param bool $enabled OPTIONAL (default = true)
- * @return \Elastica\Connection
- */
- public function setEnabled($enabled = true)
- {
- return $this->setParam('enabled', $enabled);
- }
-
- /**
- * @return bool True if enabled
- */
- public function isEnabled()
- {
- return (bool) $this->getParam('enabled');
- }
-
- /**
- * Returns an instance of the transport type
- *
- * @return \Elastica\Transport\AbstractTransport Transport object
- * @throws \Elastica\Exception\InvalidException If invalid transport type
- */
- public function getTransportObject()
- {
- $transport = $this->getTransport();
-
- return AbstractTransport::create($transport, $this);
- }
-
- /**
- * @return bool Returns true if connection is persistent. True by default
- */
- public function isPersistent()
- {
- return (bool) $this->hasParam('persistent')?$this->getParam('persistent'):true;
- }
-
- /**
- * @param array $config
- * @return \Elastica\Connection
- */
- public function setConfig(array $config)
- {
- return $this->setParam('config', $config);
- }
-
- /**
- * @param string $key
- * @param mixed $value
- * @return \Elastica\Connection
- */
- public function addConfig($key, $value)
- {
- $this->_params['config'][$key] = $value;
-
- return $this;
- }
-
- /**
- * @param string $key
- * @return bool
- */
- public function hasConfig($key)
- {
- $config = $this->getConfig();
-
- return isset($config[$key]);
- }
-
- /**
- * Returns a specific config key or the whole
- * config array if not set
- *
- * @param string $key Config key
- * @throws \Elastica\Exception\InvalidException
- * @return array|string Config value
- */
- public function getConfig($key = '')
- {
- $config = $this->getParam('config');
- if (empty($key)) {
- return $config;
- }
-
- if (!array_key_exists($key, $config)) {
- throw new InvalidException('Config key is not set: ' . $key);
- }
-
- return $config[$key];
- }
-
- /**
- * @param \Elastica\Connection|array $params Params to create a connection
- * @throws Exception\InvalidException
- * @return \Elastica\Connection
- */
- public static function create($params = array())
- {
- $connection = null;
-
- if ($params instanceof Connection) {
- $connection = $params;
- } elseif (is_array($params)) {
- $connection = new Connection($params);
- } else {
- throw new InvalidException('Invalid data type');
- }
-
- return $connection;
- }
-}