gaoyixia/vendor/alibabacloud/opensearch-sdk-php/service/client.php

<?php

namespace tutorial\php;

error_reporting(E_ALL);

require_once("Config.inc.php");
use Thrift\ClassLoader\ThriftClassLoader;

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements. See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership. The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License. You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

use Thrift\Protocol\TBinaryProtocol;
use Thrift\Transport\TSocket;
use Thrift\Transport\THttpClient;
use Thrift\Transport\TBufferedTransport;
use Thrift\Exception\TException;
use Thrift\Protocol\TMultiplexedProtocol;
use OpenSearch\Generated\Common\Pageable;


try {
  if (array_search('--http', $argv)) {
    $socket = new THttpClient('localhost', 8080, '/php/server.php');
  } else {
    $socket = new TSocket('localhost', 9090);
  }
  $transport = new TBufferedTransport($socket, 1024, 1024);
  $protocol = new TBinaryProtocol($transport);
  $transport->open();

  $clientProtocol = new TMultiplexedProtocol($protocol, 'openSearchServiceProcessor');
  $client = new \OpenSearch\Generated\OpenSearch\OpenSearchServiceClient($clientProtocol);

  $appProtocol = new TMultiplexedProtocol($protocol, 'appServiceProcessor');
  $appClient = new \OpenSearch\Generated\App\AppServiceClient($appProtocol);

  /*$pageable = new Pageable(array('page' => 1, 'size' => 1));
  $ret = $appClient->listAll($pageable);*/
  $ret = $appClient->save('test');
  print_r($ret);
  $transport->close();
} catch (TException $tx) {
  print 'TException: '.$tx->getMessage()."\n";
}

?>