Cloud PubSub V1 Client - Class SubscriberClient (1.48.0)

$subscriberClient = new SubscriberClient();
try {
    $formattedSubscription = $subscriberClient->subscriptionName('[PROJECT]', '[SUBSCRIPTION]');
    $ackIds = [];
    $subscriberClient->acknowledge($formattedSubscription, $ackIds);
} finally {
    $subscriberClient->close();
}

Namespace

Methods

__construct

acknowledge

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSubscription The subscription whose message is being acknowledged.
 *                                      Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 * @param string $ackIdsElement         The acknowledgment ID for the messages being acknowledged that
 *                                      was returned by the Pub/Sub system in the `Pull` response. Must not be
 *                                      empty.
 */
function acknowledge_sample(string $formattedSubscription, string $ackIdsElement): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $ackIds = [$ackIdsElement,];

    // Call the API and handle any network failures.
    try {
        $subscriberClient->acknowledge($formattedSubscription, $ackIds);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');
    $ackIdsElement = '[ACK_IDS]';

    acknowledge_sample($formattedSubscription, $ackIdsElement);
}

createSnapshot

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\Snapshot;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedName         User-provided name for this snapshot. If the name is not provided
 *                                      in the request, the server will assign a random name for this snapshot on
 *                                      the same project as the subscription. Note that for REST API requests, you
 *                                      must specify a name.  See the [resource name
 *                                      rules](https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
 *                                      Format is `projects/{project}/snapshots/{snap}`. Please see
 *                                      {@see SubscriberClient::snapshotName()} for help formatting this field.
 * @param string $formattedSubscription The subscription whose backlog the snapshot retains.
 *                                      Specifically, the created snapshot is guaranteed to retain:
 *                                      (a) The existing backlog on the subscription. More precisely, this is
 *                                      defined as the messages in the subscription's backlog that are
 *                                      unacknowledged upon the successful completion of the
 *                                      `CreateSnapshot` request; as well as:
 *                                      (b) Any messages published to the subscription's topic following the
 *                                      successful completion of the CreateSnapshot request.
 *                                      Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 */
function create_snapshot_sample(string $formattedName, string $formattedSubscription): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var Snapshot $response */
        $response = $subscriberClient->createSnapshot($formattedName, $formattedSubscription);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = SubscriberClient::snapshotName('[PROJECT]', '[SNAPSHOT]');
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');

    create_snapshot_sample($formattedName, $formattedSubscription);
}

createSubscription

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SubscriberClient;
use Google\Cloud\PubSub\V1\Subscription;

/**
 * @param string $name           The name of the subscription. It must have the format
 *                               `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must
 *                               start with a letter, and contain only letters (`[A-Za-z]`), numbers
 *                               (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`),
 *                               plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters
 *                               in length, and it must not start with `"goog"`.
 * @param string $formattedTopic The name of the topic from which this subscription is receiving
 *                               messages. Format is `projects/{project}/topics/{topic}`. The value of this
 *                               field will be `_deleted-topic_` if the topic has been deleted. Please see
 *                               {@see SubscriberClient::topicName()} for help formatting this field.
 */
function create_subscription_sample(string $name, string $formattedTopic): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var Subscription $response */
        $response = $subscriberClient->createSubscription($name, $formattedTopic);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $name = '[NAME]';
    $formattedTopic = SubscriberClient::topicName('[PROJECT]', '[TOPIC]');

    create_subscription_sample($name, $formattedTopic);
}

deleteSnapshot

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSnapshot The name of the snapshot to delete.
 *                                  Format is `projects/{project}/snapshots/{snap}`. Please see
 *                                  {@see SubscriberClient::snapshotName()} for help formatting this field.
 */
function delete_snapshot_sample(string $formattedSnapshot): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        $subscriberClient->deleteSnapshot($formattedSnapshot);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSnapshot = SubscriberClient::snapshotName('[PROJECT]', '[SNAPSHOT]');

    delete_snapshot_sample($formattedSnapshot);
}

deleteSubscription

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSubscription The subscription to delete.
 *                                      Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 */
function delete_subscription_sample(string $formattedSubscription): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        $subscriberClient->deleteSubscription($formattedSubscription);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');

    delete_subscription_sample($formattedSubscription);
}

getSnapshot

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\Snapshot;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSnapshot The name of the snapshot to get.
 *                                  Format is `projects/{project}/snapshots/{snap}`. Please see
 *                                  {@see SubscriberClient::snapshotName()} for help formatting this field.
 */
function get_snapshot_sample(string $formattedSnapshot): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var Snapshot $response */
        $response = $subscriberClient->getSnapshot($formattedSnapshot);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSnapshot = SubscriberClient::snapshotName('[PROJECT]', '[SNAPSHOT]');

    get_snapshot_sample($formattedSnapshot);
}

getSubscription

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SubscriberClient;
use Google\Cloud\PubSub\V1\Subscription;

/**
 * @param string $formattedSubscription The name of the subscription to get.
 *                                      Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 */
function get_subscription_sample(string $formattedSubscription): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var Subscription $response */
        $response = $subscriberClient->getSubscription($formattedSubscription);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');

    get_subscription_sample($formattedSubscription);
}

listSnapshots

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\PubSub\V1\Snapshot;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedProject The name of the project in which to list snapshots.
 *                                 Format is `projects/{project-id}`. Please see
 *                                 {@see SubscriberClient::projectName()} for help formatting this field.
 */
function list_snapshots_sample(string $formattedProject): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $subscriberClient->listSnapshots($formattedProject);

        /** @var Snapshot $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedProject = SubscriberClient::projectName('[PROJECT]');

    list_snapshots_sample($formattedProject);
}

listSubscriptions

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\PubSub\V1\SubscriberClient;
use Google\Cloud\PubSub\V1\Subscription;

/**
 * @param string $formattedProject The name of the project in which to list subscriptions.
 *                                 Format is `projects/{project-id}`. Please see
 *                                 {@see SubscriberClient::projectName()} for help formatting this field.
 */
function list_subscriptions_sample(string $formattedProject): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $subscriberClient->listSubscriptions($formattedProject);

        /** @var Subscription $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedProject = SubscriberClient::projectName('[PROJECT]');

    list_subscriptions_sample($formattedProject);
}

modifyAckDeadline

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSubscription The name of the subscription.
 *                                      Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 * @param string $ackIdsElement         List of acknowledgment IDs.
 * @param int    $ackDeadlineSeconds    The new ack deadline with respect to the time this request was
 *                                      sent to the Pub/Sub system. For example, if the value is 10, the new ack
 *                                      deadline will expire 10 seconds after the `ModifyAckDeadline` call was
 *                                      made. Specifying zero might immediately make the message available for
 *                                      delivery to another subscriber client. This typically results in an
 *                                      increase in the rate of message redeliveries (that is, duplicates).
 *                                      The minimum deadline you can specify is 0 seconds.
 *                                      The maximum deadline you can specify is 600 seconds (10 minutes).
 */
function modify_ack_deadline_sample(
    string $formattedSubscription,
    string $ackIdsElement,
    int $ackDeadlineSeconds
): void {
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $ackIds = [$ackIdsElement,];

    // Call the API and handle any network failures.
    try {
        $subscriberClient->modifyAckDeadline($formattedSubscription, $ackIds, $ackDeadlineSeconds);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');
    $ackIdsElement = '[ACK_IDS]';
    $ackDeadlineSeconds = 0;

    modify_ack_deadline_sample($formattedSubscription, $ackIdsElement, $ackDeadlineSeconds);
}

modifyPushConfig

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\PushConfig;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSubscription The name of the subscription.
 *                                      Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 */
function modify_push_config_sample(string $formattedSubscription): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $pushConfig = new PushConfig();

    // Call the API and handle any network failures.
    try {
        $subscriberClient->modifyPushConfig($formattedSubscription, $pushConfig);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');

    modify_push_config_sample($formattedSubscription);
}

pull

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\PullResponse;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSubscription The subscription from which messages should be pulled.
 *                                      Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 * @param int    $maxMessages           The maximum number of messages to return for this request. Must
 *                                      be a positive integer. The Pub/Sub system may return fewer than the number
 *                                      specified.
 */
function pull_sample(string $formattedSubscription, int $maxMessages): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var PullResponse $response */
        $response = $subscriberClient->pull($formattedSubscription, $maxMessages);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');
    $maxMessages = 0;

    pull_sample($formattedSubscription, $maxMessages);
}

seek

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SeekResponse;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSubscription The subscription to affect. Please see
 *                                      {@see SubscriberClient::subscriptionName()} for help formatting this field.
 */
function seek_sample(string $formattedSubscription): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var SeekResponse $response */
        $response = $subscriberClient->seek($formattedSubscription);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');

    seek_sample($formattedSubscription);
}

streamingPull

use Google\ApiCore\ApiException;
use Google\ApiCore\BidiStream;
use Google\Cloud\PubSub\V1\StreamingPullRequest;
use Google\Cloud\PubSub\V1\StreamingPullResponse;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $formattedSubscription    The subscription for which to initialize the new stream. This
 *                                         must be provided in the first request on the stream, and must not be set in
 *                                         subsequent requests from client to server.
 *                                         Format is `projects/{project}/subscriptions/{sub}`. Please see
 *                                         {@see SubscriberClient::subscriptionName()} for help formatting this field.
 * @param int    $streamAckDeadlineSeconds The ack deadline to use for the stream. This must be provided in
 *                                         the first request on the stream, but it can also be updated on subsequent
 *                                         requests from client to server. The minimum deadline you can specify is 10
 *                                         seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
 */
function streaming_pull_sample(string $formattedSubscription, int $streamAckDeadlineSeconds): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $request = (new StreamingPullRequest())
        ->setSubscription($formattedSubscription)
        ->setStreamAckDeadlineSeconds($streamAckDeadlineSeconds);

    // Call the API and handle any network failures.
    try {
        /** @var BidiStream $stream */
        $stream = $subscriberClient->streamingPull();
        $stream->writeAll([$request,]);

        /** @var StreamingPullResponse $element */
        foreach ($stream->closeWriteAndReadAll() as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedSubscription = SubscriberClient::subscriptionName('[PROJECT]', '[SUBSCRIPTION]');
    $streamAckDeadlineSeconds = 0;

    streaming_pull_sample($formattedSubscription, $streamAckDeadlineSeconds);
}

updateSnapshot

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\Snapshot;
use Google\Cloud\PubSub\V1\SubscriberClient;
use Google\Protobuf\FieldMask;

/**
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function update_snapshot_sample(): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $snapshot = new Snapshot();
    $updateMask = new FieldMask();

    // Call the API and handle any network failures.
    try {
        /** @var Snapshot $response */
        $response = $subscriberClient->updateSnapshot($snapshot, $updateMask);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

updateSubscription

use Google\ApiCore\ApiException;
use Google\Cloud\PubSub\V1\SubscriberClient;
use Google\Cloud\PubSub\V1\Subscription;
use Google\Protobuf\FieldMask;

/**
 * @param string $subscriptionName           The name of the subscription. It must have the format
 *                                           `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must
 *                                           start with a letter, and contain only letters (`[A-Za-z]`), numbers
 *                                           (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`),
 *                                           plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters
 *                                           in length, and it must not start with `"goog"`.
 * @param string $formattedSubscriptionTopic The name of the topic from which this subscription is receiving
 *                                           messages. Format is `projects/{project}/topics/{topic}`. The value of this
 *                                           field will be `_deleted-topic_` if the topic has been deleted. Please see
 *                                           {@see SubscriberClient::topicName()} for help formatting this field.
 */
function update_subscription_sample(
    string $subscriptionName,
    string $formattedSubscriptionTopic
): void {
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $subscription = (new Subscription())
        ->setName($subscriptionName)
        ->setTopic($formattedSubscriptionTopic);
    $updateMask = new FieldMask();

    // Call the API and handle any network failures.
    try {
        /** @var Subscription $response */
        $response = $subscriberClient->updateSubscription($subscription, $updateMask);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $subscriptionName = '[NAME]';
    $formattedSubscriptionTopic = SubscriberClient::topicName('[PROJECT]', '[TOPIC]');

    update_subscription_sample($subscriptionName, $formattedSubscriptionTopic);
}

getIamPolicy

use Google\ApiCore\ApiException;
use Google\Cloud\Iam\V1\Policy;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $resource REQUIRED: The resource for which the policy is being requested.
 *                         See the operation documentation for the appropriate value for this field.
 */
function get_iam_policy_sample(string $resource): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Call the API and handle any network failures.
    try {
        /** @var Policy $response */
        $response = $subscriberClient->getIamPolicy($resource);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $resource = '[RESOURCE]';

    get_iam_policy_sample($resource);
}

setIamPolicy

use Google\ApiCore\ApiException;
use Google\Cloud\Iam\V1\Policy;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $resource REQUIRED: The resource for which the policy is being specified.
 *                         See the operation documentation for the appropriate value for this field.
 */
function set_iam_policy_sample(string $resource): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $policy = new Policy();

    // Call the API and handle any network failures.
    try {
        /** @var Policy $response */
        $response = $subscriberClient->setIamPolicy($resource, $policy);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $resource = '[RESOURCE]';

    set_iam_policy_sample($resource);
}

testIamPermissions

use Google\ApiCore\ApiException;
use Google\Cloud\Iam\V1\TestIamPermissionsResponse;
use Google\Cloud\PubSub\V1\SubscriberClient;

/**
 * @param string $resource           REQUIRED: The resource for which the policy detail is being requested.
 *                                   See the operation documentation for the appropriate value for this field.
 * @param string $permissionsElement The set of permissions to check for the `resource`. Permissions with
 *                                   wildcards (such as '*' or 'storage.*') are not allowed. For more
 *                                   information see
 *                                   [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
 */
function test_iam_permissions_sample(string $resource, string $permissionsElement): void
{
    // Create a client.
    $subscriberClient = new SubscriberClient();

    // Prepare any non-scalar elements to be passed along with the request.
    $permissions = [$permissionsElement,];

    // Call the API and handle any network failures.
    try {
        /** @var TestIamPermissionsResponse $response */
        $response = $subscriberClient->testIamPermissions($resource, $permissions);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $resource = '[RESOURCE]';
    $permissionsElement = '[PERMISSIONS]';

    test_iam_permissions_sample($resource, $permissionsElement);
}

static::deletedTopicName

static::projectName

static::projectTopicName

static::snapshotName

static::subscriptionName

static::topicName

static::parseName

Constants

SERVICE_NAME

Value: 'google.pubsub.v1.Subscriber'

SERVICE_ADDRESS

Value: 'pubsub.googleapis.com'

DEFAULT_SERVICE_PORT

Value: 443

CODEGEN_NAME

Value: 'gapic'