:". * **Defaults to** 'bigtable.googleapis.com:443'. * @type string|array|FetchAuthTokenInterface|CredentialsWrapper $credentials * The credentials to be used by the client to authorize API calls. * This option accepts either a path to a credentials file, or a * decoded credentials file as a PHP array. * *Advanced usage*: In addition, this option can also accept a * pre-constructed {@see Google\Auth\FetchAuthTokenInterface} object * or {@see Google\ApiCore\CredentialsWrapper} object. Note that when * one of these objects are provided, any settings in * $config['credentialsConfig'] will be ignored. * @type array $credentialsConfig Options used to configure credentials, * including auth token caching, for the client. For a full list of * supporting configuration options, see * {@see Google\ApiCore\CredentialsWrapper}. * @type bool $disableRetries Determines whether or not retries defined by * the client configuration should be disabled. **Defaults to** * `false`. * @type string|array $clientConfig Client method configuration, including * retry settings. This option can be either a path to a JSON file, or * a PHP array containing the decoded JSON data. * @type string|TransportInterface $transport The transport used for * executing network requests. May be either the string `rest` or * `grpc`. **Defaults to** `grpc` if gRPC support is detected on * the system. *Advanced usage*: Additionally, it is possible to * pass in an already instantiated * {@see Google\ApiCore\Transport\TransportInterface} object. Note * that when this object is provided, any settings in * $config['transportConfig'] and the $config['apiEndpoint'] * setting will be ignored. * @type array $transportConfig Configuration options that will be used to * construct the transport. Options for each supported transport type * should be passed in a key for that transport. For example: * $transportConfig = [ * 'grpc' => [...], * 'rest' => [...] * ]; * See the `build` method on {@see Google\ApiCore\Transport\GrpcTransport} * and {@see Google\ApiCore\Transport\RestTransport} for the * supported options. * @type string $quotaProject Specifies a user project to bill for * access charges associated with the request. * } * @throws ValidationException */ public function __construct(array $config = []) { if (!isset($config['transportConfig']['grpc']['stubOpts'])) { $config['transportConfig']['grpc']['stubOpts'] = []; } // Workaround for large messages. $config['transportConfig']['grpc']['stubOpts'] += [ 'grpc.max_send_message_length' => -1, 'grpc.max_receive_message_length' => -1, // Sets 30s as Google Frontends allows keepalive pings at 30s 'grpc.keepalive_time_ms' => 30000, // Conservative timeout at 10s 'grpc.keepalive_timeout_ms' => 10000 ]; $this->projectId = $this->pluck('projectId', $config, false) ?: $this->detectProjectId(); $this->gapicClient = new GapicClient($config); } /** * Returns a table instance which can be used to read rows and to perform * insert, update, and delete operations. * * Example: * ``` * $table = $bigtable->table('my-instance', 'my-table'); * ``` * * @param string $instanceId The instance ID. * @param string $tableId The table ID. * @param array $options [optional] { * Configuration options. * * @type string $appProfileId This value specifies routing for * replication. **Defaults to** the "default" application profile. * @type array $headers Headers to be passed with each request. * } * @return Table */ public function table($instanceId, $tableId, array $options = []) { return new Table( $this->gapicClient, GapicClient::tableName($this->projectId, $instanceId, $tableId), $options ); } /** * Attempts to detect the project ID. * * @todo Add better support for detecting the project ID (check keyFile/GCE metadata server). * @return string * @throws ValidationException If a project ID cannot be detected. */ private function detectProjectId() { if (getenv('GOOGLE_CLOUD_PROJECT')) { return getenv('GOOGLE_CLOUD_PROJECT'); } if (getenv('GCLOUD_PROJECT')) { return getenv('GCLOUD_PROJECT'); } throw new ValidationException( 'No project ID was provided, ' . 'and we were unable to detect a default project ID.' ); } }