src/Connection.php
function connection($name)
    {

        // Check if connection is already loaded.

        if ($this->isLoaded($name)) {

            $this->connection = $this->connections[$name];

            return $this->newQuery($name);

        }

        // Create a new connection.

        if (array_key_exists($name, $this->config["connections"])) {

            $config = $this->config["connections"][$name];

            // Instantiate a new ClientBuilder
            $clientBuilder = ClientBuilder::create();

            $clientBuilder->setHosts($config["servers"]);

            $clientBuilder = self::configureLogging($clientBuilder,$config);

            if (!empty($config['handler'])) {
                $clientBuilder->setHandler($config['handler']);
            }

            // Build the client object
            $connection = $clientBuilder->build();

            $this->connection = $connection;

            $this->connections[$name] = $connection;

            return $this->newQuery($name);
        }

        $this->app->abort(500, "Invalid elasticsearch connection driver `" . $name . "`");
    }
function connection($name)
    {

        // Check if connection is already loaded.

        if ($this->isLoaded($name)) {

            $this->connection = $this->connections[$name];

            return $this->newQuery($name);

        }

        // Create a new connection.

        if (array_key_exists($name, $this->config["connections"])) {

            $config = $this->config["connections"][$name];

            // Instantiate a new ClientBuilder
            $clientBuilder = ClientBuilder::create();

            $clientBuilder->setHosts($config["servers"]);

            $clientBuilder = self::configureLogging($clientBuilder,$config);

            if (!empty($config['handler'])) {
                $clientBuilder->setHandler($config['handler']);
            }

            // Build the client object
            $connection = $clientBuilder->build();

            $this->connection = $connection;

            $this->connections[$name] = $connection;

            return $this->newQuery($name);
        }

        $this->app->abort(500, "Invalid elasticsearch connection driver `" . $name . "`");
    }
function connection ( $ name ) { // Check if connection is already loaded. if ( $ this -> isLoaded ( $ name ) ) { $ this -> connection = $ this -> connections [ $ name ] ; return $ this -> newQuery ( $ name ) ; } // Create a new connection. if ( array_key_exists ( $ name , $ this -> config [ "connections" ] ) ) { $ config = $ this -> config [ "connections" ] [ $ name ] ; // Instantiate a new ClientBuilder $ clientBuilder = ClientBuilder :: create ( ) ; $ clientBuilder -> setHosts ( $ config [ "servers" ] ) ; $ clientBuilder = self :: configureLogging ( $ clientBuilder , $ config ) ; if ( ! empty ( $ config [ 'handler' ] ) ) { $ clientBuilder -> setHandler ( $ config [ 'handler' ] ) ; } // Build the client object $ connection = $ clientBuilder -> build ( ) ; $ this -> connection = $ connection ; $ this -> connections [ $ name ] = $ connection ; return $ this -> newQuery ( $ name ) ; } $ this -> app -> abort ( 500 , "Invalid elasticsearch connection driver `" . $ name . "`" ) ; }
Create a connection for laravel or lumen frameworks
@param $name
@return Query
Create a connection for laravel or lumen frameworks