Google Cloud Vision Ai V1 Client - Class StreamsServiceClient (0.3.0)

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Cluster;
use Google\Cloud\VisionAI\V1\CreateClusterRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedParent Value for parent. Please see
 *                                {@see StreamsServiceClient::locationName()} for help formatting this field.
 * @param string $clusterId       Id of the requesting object.
 */
function create_cluster_sample(string $formattedParent, string $clusterId): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $cluster = new Cluster();
    $request = (new CreateClusterRequest())
        ->setParent($formattedParent)
        ->setClusterId($clusterId)
        ->setCluster($cluster);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->createCluster($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Cluster $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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
{
    $formattedParent = StreamsServiceClient::locationName('[PROJECT]', '[LOCATION]');
    $clusterId = '[CLUSTER_ID]';

    create_cluster_sample($formattedParent, $clusterId);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\CreateEventRequest;
use Google\Cloud\VisionAI\V1\Event;
use Google\Rpc\Status;

/**
 * @param string $formattedParent Value for parent. Please see
 *                                {@see StreamsServiceClient::clusterName()} for help formatting this field.
 * @param string $eventId         Id of the requesting object.
 */
function create_event_sample(string $formattedParent, string $eventId): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $event = new Event();
    $request = (new CreateEventRequest())
        ->setParent($formattedParent)
        ->setEventId($eventId)
        ->setEvent($event);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->createEvent($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Event $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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
{
    $formattedParent = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');
    $eventId = '[EVENT_ID]';

    create_event_sample($formattedParent, $eventId);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\CreateSeriesRequest;
use Google\Cloud\VisionAI\V1\Series;
use Google\Rpc\Status;

/**
 * @param string $formattedParent       Value for parent. Please see
 *                                      {@see StreamsServiceClient::clusterName()} for help formatting this field.
 * @param string $seriesId              Id of the requesting object.
 * @param string $formattedSeriesStream Stream that is associated with this series. Please see
 *                                      {@see StreamsServiceClient::streamName()} for help formatting this field.
 * @param string $formattedSeriesEvent  Event that is associated with this series. Please see
 *                                      {@see StreamsServiceClient::eventName()} for help formatting this field.
 */
function create_series_sample(
    string $formattedParent,
    string $seriesId,
    string $formattedSeriesStream,
    string $formattedSeriesEvent
): void {
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $series = (new Series())
        ->setStream($formattedSeriesStream)
        ->setEvent($formattedSeriesEvent);
    $request = (new CreateSeriesRequest())
        ->setParent($formattedParent)
        ->setSeriesId($seriesId)
        ->setSeries($series);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->createSeries($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Series $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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
{
    $formattedParent = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');
    $seriesId = '[SERIES_ID]';
    $formattedSeriesStream = StreamsServiceClient::streamName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[STREAM]'
    );
    $formattedSeriesEvent = StreamsServiceClient::eventName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[EVENT]'
    );

    create_series_sample($formattedParent, $seriesId, $formattedSeriesStream, $formattedSeriesEvent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\CreateStreamRequest;
use Google\Cloud\VisionAI\V1\Stream;
use Google\Rpc\Status;

/**
 * @param string $formattedParent Value for parent. Please see
 *                                {@see StreamsServiceClient::clusterName()} for help formatting this field.
 * @param string $streamId        Id of the requesting object.
 */
function create_stream_sample(string $formattedParent, string $streamId): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $stream = new Stream();
    $request = (new CreateStreamRequest())
        ->setParent($formattedParent)
        ->setStreamId($streamId)
        ->setStream($stream);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->createStream($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Stream $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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
{
    $formattedParent = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');
    $streamId = '[STREAM_ID]';

    create_stream_sample($formattedParent, $streamId);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\DeleteClusterRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedName Name of the resource
 *                              Please see {@see StreamsServiceClient::clusterName()} for help formatting this field.
 */
function delete_cluster_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new DeleteClusterRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->deleteCluster($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            printf('Operation completed successfully.' . PHP_EOL);
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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 = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');

    delete_cluster_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\DeleteEventRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedName Name of the resource. Please see
 *                              {@see StreamsServiceClient::eventName()} for help formatting this field.
 */
function delete_event_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new DeleteEventRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->deleteEvent($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            printf('Operation completed successfully.' . PHP_EOL);
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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 = StreamsServiceClient::eventName('[PROJECT]', '[LOCATION]', '[CLUSTER]', '[EVENT]');

    delete_event_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\DeleteSeriesRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedName Name of the resource. Please see
 *                              {@see StreamsServiceClient::seriesName()} for help formatting this field.
 */
function delete_series_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new DeleteSeriesRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->deleteSeries($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            printf('Operation completed successfully.' . PHP_EOL);
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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 = StreamsServiceClient::seriesName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[SERIES]'
    );

    delete_series_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\DeleteStreamRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedName Name of the resource. Please see
 *                              {@see StreamsServiceClient::streamName()} for help formatting this field.
 */
function delete_stream_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new DeleteStreamRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->deleteStream($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            printf('Operation completed successfully.' . PHP_EOL);
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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 = StreamsServiceClient::streamName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[STREAM]'
    );

    delete_stream_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\GenerateStreamHlsTokenRequest;
use Google\Cloud\VisionAI\V1\GenerateStreamHlsTokenResponse;

/**
 * @param string $stream The name of the stream.
 */
function generate_stream_hls_token_sample(string $stream): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new GenerateStreamHlsTokenRequest())
        ->setStream($stream);

    // Call the API and handle any network failures.
    try {
        /** @var GenerateStreamHlsTokenResponse $response */
        $response = $streamsServiceClient->generateStreamHlsToken($request);
        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
{
    $stream = '[STREAM]';

    generate_stream_hls_token_sample($stream);
}

use Google\ApiCore\ApiException;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Cluster;
use Google\Cloud\VisionAI\V1\GetClusterRequest;

/**
 * @param string $formattedName Name of the resource. Please see
 *                              {@see StreamsServiceClient::clusterName()} for help formatting this field.
 */
function get_cluster_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new GetClusterRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var Cluster $response */
        $response = $streamsServiceClient->getCluster($request);
        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 = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');

    get_cluster_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Event;
use Google\Cloud\VisionAI\V1\GetEventRequest;

/**
 * @param string $formattedName Name of the resource. Please see
 *                              {@see StreamsServiceClient::eventName()} for help formatting this field.
 */
function get_event_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new GetEventRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var Event $response */
        $response = $streamsServiceClient->getEvent($request);
        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 = StreamsServiceClient::eventName('[PROJECT]', '[LOCATION]', '[CLUSTER]', '[EVENT]');

    get_event_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\GetSeriesRequest;
use Google\Cloud\VisionAI\V1\Series;

/**
 * @param string $formattedName Name of the resource. Please see
 *                              {@see StreamsServiceClient::seriesName()} for help formatting this field.
 */
function get_series_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new GetSeriesRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var Series $response */
        $response = $streamsServiceClient->getSeries($request);
        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 = StreamsServiceClient::seriesName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[SERIES]'
    );

    get_series_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\GetStreamRequest;
use Google\Cloud\VisionAI\V1\Stream;

/**
 * @param string $formattedName Name of the resource. Please see
 *                              {@see StreamsServiceClient::streamName()} for help formatting this field.
 */
function get_stream_sample(string $formattedName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new GetStreamRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var Stream $response */
        $response = $streamsServiceClient->getStream($request);
        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 = StreamsServiceClient::streamName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[STREAM]'
    );

    get_stream_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\GetStreamThumbnailRequest;
use Google\Cloud\VisionAI\V1\GetStreamThumbnailResponse;
use Google\Rpc\Status;

/**
 * @param string $stream        The name of the stream for to get the thumbnail from.
 * @param string $gcsObjectName The name of the GCS object to store the thumbnail image.
 */
function get_stream_thumbnail_sample(string $stream, string $gcsObjectName): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new GetStreamThumbnailRequest())
        ->setStream($stream)
        ->setGcsObjectName($gcsObjectName);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->getStreamThumbnail($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var GetStreamThumbnailResponse $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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
{
    $stream = '[STREAM]';
    $gcsObjectName = '[GCS_OBJECT_NAME]';

    get_stream_thumbnail_sample($stream, $gcsObjectName);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Cluster;
use Google\Cloud\VisionAI\V1\ListClustersRequest;

/**
 * @param string $formattedParent Parent value for ListClustersRequest. Please see
 *                                {@see StreamsServiceClient::locationName()} for help formatting this field.
 */
function list_clusters_sample(string $formattedParent): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new ListClustersRequest())
        ->setParent($formattedParent);

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

        /** @var Cluster $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
{
    $formattedParent = StreamsServiceClient::locationName('[PROJECT]', '[LOCATION]');

    list_clusters_sample($formattedParent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Event;
use Google\Cloud\VisionAI\V1\ListEventsRequest;

/**
 * @param string $formattedParent Parent value for ListEventsRequest. Please see
 *                                {@see StreamsServiceClient::clusterName()} for help formatting this field.
 */
function list_events_sample(string $formattedParent): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new ListEventsRequest())
        ->setParent($formattedParent);

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

        /** @var Event $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
{
    $formattedParent = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');

    list_events_sample($formattedParent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\ListSeriesRequest;
use Google\Cloud\VisionAI\V1\Series;

/**
 * @param string $formattedParent Parent value for ListSeriesRequest. Please see
 *                                {@see StreamsServiceClient::clusterName()} for help formatting this field.
 */
function list_series_sample(string $formattedParent): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new ListSeriesRequest())
        ->setParent($formattedParent);

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

        /** @var Series $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
{
    $formattedParent = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');

    list_series_sample($formattedParent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\ListStreamsRequest;
use Google\Cloud\VisionAI\V1\Stream;

/**
 * @param string $formattedParent Parent value for ListStreamsRequest. Please see
 *                                {@see StreamsServiceClient::clusterName()} for help formatting this field.
 */
function list_streams_sample(string $formattedParent): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = (new ListStreamsRequest())
        ->setParent($formattedParent);

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

        /** @var Stream $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
{
    $formattedParent = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');

    list_streams_sample($formattedParent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Channel;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\MaterializeChannelRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedParent        Value for parent. Please see
 *                                       {@see StreamsServiceClient::clusterName()} for help formatting this field.
 * @param string $channelId              Id of the channel.
 * @param string $formattedChannelStream Stream that is associated with this series. Please see
 *                                       {@see StreamsServiceClient::streamName()} for help formatting this field.
 * @param string $formattedChannelEvent  Event that is associated with this series. Please see
 *                                       {@see StreamsServiceClient::eventName()} for help formatting this field.
 */
function materialize_channel_sample(
    string $formattedParent,
    string $channelId,
    string $formattedChannelStream,
    string $formattedChannelEvent
): void {
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $channel = (new Channel())
        ->setStream($formattedChannelStream)
        ->setEvent($formattedChannelEvent);
    $request = (new MaterializeChannelRequest())
        ->setParent($formattedParent)
        ->setChannelId($channelId)
        ->setChannel($channel);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->materializeChannel($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Channel $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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
{
    $formattedParent = StreamsServiceClient::clusterName('[PROJECT]', '[LOCATION]', '[CLUSTER]');
    $channelId = '[CHANNEL_ID]';
    $formattedChannelStream = StreamsServiceClient::streamName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[STREAM]'
    );
    $formattedChannelEvent = StreamsServiceClient::eventName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[EVENT]'
    );

    materialize_channel_sample(
        $formattedParent,
        $channelId,
        $formattedChannelStream,
        $formattedChannelEvent
    );
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Cluster;
use Google\Cloud\VisionAI\V1\UpdateClusterRequest;
use Google\Protobuf\FieldMask;
use Google\Rpc\Status;

/**
 * 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_cluster_sample(): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $updateMask = new FieldMask();
    $cluster = new Cluster();
    $request = (new UpdateClusterRequest())
        ->setUpdateMask($updateMask)
        ->setCluster($cluster);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->updateCluster($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Cluster $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Event;
use Google\Cloud\VisionAI\V1\UpdateEventRequest;
use Google\Protobuf\FieldMask;
use Google\Rpc\Status;

/**
 * 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_event_sample(): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $updateMask = new FieldMask();
    $event = new Event();
    $request = (new UpdateEventRequest())
        ->setUpdateMask($updateMask)
        ->setEvent($event);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->updateEvent($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Event $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Series;
use Google\Cloud\VisionAI\V1\UpdateSeriesRequest;
use Google\Protobuf\FieldMask;
use Google\Rpc\Status;

/**
 * @param string $formattedSeriesStream Stream that is associated with this series. Please see
 *                                      {@see StreamsServiceClient::streamName()} for help formatting this field.
 * @param string $formattedSeriesEvent  Event that is associated with this series. Please see
 *                                      {@see StreamsServiceClient::eventName()} for help formatting this field.
 */
function update_series_sample(string $formattedSeriesStream, string $formattedSeriesEvent): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $updateMask = new FieldMask();
    $series = (new Series())
        ->setStream($formattedSeriesStream)
        ->setEvent($formattedSeriesEvent);
    $request = (new UpdateSeriesRequest())
        ->setUpdateMask($updateMask)
        ->setSeries($series);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->updateSeries($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Series $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->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
{
    $formattedSeriesStream = StreamsServiceClient::streamName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[STREAM]'
    );
    $formattedSeriesEvent = StreamsServiceClient::eventName(
        '[PROJECT]',
        '[LOCATION]',
        '[CLUSTER]',
        '[EVENT]'
    );

    update_series_sample($formattedSeriesStream, $formattedSeriesEvent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;
use Google\Cloud\VisionAI\V1\Stream;
use Google\Cloud\VisionAI\V1\UpdateStreamRequest;
use Google\Protobuf\FieldMask;
use Google\Rpc\Status;

/**
 * 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_stream_sample(): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $updateMask = new FieldMask();
    $stream = new Stream();
    $request = (new UpdateStreamRequest())
        ->setUpdateMask($updateMask)
        ->setStream($stream);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $streamsServiceClient->updateStream($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var Stream $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\Cloud\Location\GetLocationRequest;
use Google\Cloud\Location\Location;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;

/**
 * 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 get_location_sample(): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = new GetLocationRequest();

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

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\Location\ListLocationsRequest;
use Google\Cloud\Location\Location;
use Google\Cloud\VisionAI\V1\Client\StreamsServiceClient;

/**
 * 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 list_locations_sample(): void
{
    // Create a client.
    $streamsServiceClient = new StreamsServiceClient();

    // Prepare the request message.
    $request = new ListLocationsRequest();

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

        /** @var Location $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());
    }
}