Vision AI v1 API - Class StreamsServiceClient (1.0.0-beta01)

public abstract class StreamsServiceClient

Reference documentation and code samples for the Vision AI v1 API class StreamsServiceClient.

StreamsService client wrapper, for convenient use.

Inheritance

object > StreamsServiceClient

Inherited Members

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ToString()

Derived Types

StreamsServiceClientImpl

Namespace

Google.Cloud.VisionAI.V1

Assembly

Google.Cloud.VisionAI.V1.dll

Remarks

Service describing handlers for resources. Vision API and Vision AI API are two independent APIs developed by the same team. Vision API is for people to annotate their image while Vision AI is an e2e solution for customer to build their own computer vision application.

Properties

CreateClusterOperationsClient

public virtual OperationsClient CreateClusterOperationsClient { get; }

The long-running operations client for CreateCluster.

Property Value
Type	Description
OperationsClient

CreateEventOperationsClient

public virtual OperationsClient CreateEventOperationsClient { get; }

The long-running operations client for CreateEvent.

Property Value
Type	Description
OperationsClient

CreateSeriesOperationsClient

public virtual OperationsClient CreateSeriesOperationsClient { get; }

The long-running operations client for CreateSeries.

Property Value
Type	Description
OperationsClient

CreateStreamOperationsClient

public virtual OperationsClient CreateStreamOperationsClient { get; }

The long-running operations client for CreateStream.

Property Value
Type	Description
OperationsClient

DefaultEndpoint

public static string DefaultEndpoint { get; }

The default endpoint for the StreamsService service, which is a host of "visionai.googleapis.com" and a port of 443.

Property Value
Type	Description
string

DefaultScopes

public static IReadOnlyList<string> DefaultScopes { get; }

The default StreamsService scopes.

Property Value
Type	Description
IReadOnlyListstring

Remarks

The default StreamsService scopes are:

• https://www.googleapis.com/auth/cloud-platform

DeleteClusterOperationsClient

public virtual OperationsClient DeleteClusterOperationsClient { get; }

The long-running operations client for DeleteCluster.

Property Value
Type	Description
OperationsClient

DeleteEventOperationsClient

public virtual OperationsClient DeleteEventOperationsClient { get; }

The long-running operations client for DeleteEvent.

Property Value
Type	Description
OperationsClient

DeleteSeriesOperationsClient

public virtual OperationsClient DeleteSeriesOperationsClient { get; }

The long-running operations client for DeleteSeries.

Property Value
Type	Description
OperationsClient

DeleteStreamOperationsClient

public virtual OperationsClient DeleteStreamOperationsClient { get; }

The long-running operations client for DeleteStream.

Property Value
Type	Description
OperationsClient

GetStreamThumbnailOperationsClient

public virtual OperationsClient GetStreamThumbnailOperationsClient { get; }

The long-running operations client for GetStreamThumbnail.

Property Value
Type	Description
OperationsClient

GrpcClient

public virtual StreamsService.StreamsServiceClient GrpcClient { get; }

The underlying gRPC StreamsService client

Property Value
Type	Description
StreamsServiceStreamsServiceClient

IAMPolicyClient

public virtual IAMPolicyClient IAMPolicyClient { get; }

The IAMPolicyClient associated with this client.

Property Value
Type	Description
IAMPolicyClient

LocationsClient

public virtual LocationsClient LocationsClient { get; }

The LocationsClient associated with this client.

Property Value
Type	Description
LocationsClient

MaterializeChannelOperationsClient

public virtual OperationsClient MaterializeChannelOperationsClient { get; }

The long-running operations client for MaterializeChannel.

Property Value
Type	Description
OperationsClient

ServiceMetadata

public static ServiceMetadata ServiceMetadata { get; }

The service metadata associated with this client type.

Property Value
Type	Description
ServiceMetadata

UpdateClusterOperationsClient

public virtual OperationsClient UpdateClusterOperationsClient { get; }

The long-running operations client for UpdateCluster.

Property Value
Type	Description
OperationsClient

UpdateEventOperationsClient

public virtual OperationsClient UpdateEventOperationsClient { get; }

The long-running operations client for UpdateEvent.

Property Value
Type	Description
OperationsClient

UpdateSeriesOperationsClient

public virtual OperationsClient UpdateSeriesOperationsClient { get; }

The long-running operations client for UpdateSeries.

Property Value
Type	Description
OperationsClient

UpdateStreamOperationsClient

public virtual OperationsClient UpdateStreamOperationsClient { get; }

The long-running operations client for UpdateStream.

Property Value
Type	Description
OperationsClient

Methods

Create()

public static StreamsServiceClient Create()

Synchronously creates a StreamsServiceClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use StreamsServiceClientBuilder.

Returns
Type	Description
StreamsServiceClient	The created StreamsServiceClient.

CreateAsync(CancellationToken)

public static Task<StreamsServiceClient> CreateAsync(CancellationToken cancellationToken = default)

Asynchronously creates a StreamsServiceClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use StreamsServiceClientBuilder.

Parameter
Name	Description
cancellationToken	CancellationToken The CancellationToken to use while creating the client.

Returns
Type	Description
TaskStreamsServiceClient	The task representing the created StreamsServiceClient.

CreateCluster(LocationName, Cluster, string, CallSettings)

public virtual Operation<Cluster, OperationMetadata> CreateCluster(LocationName parent, Cluster cluster, string clusterId, CallSettings callSettings = null)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
parent	LocationName Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Cluster cluster = new Cluster();
string clusterId = "";
// Make the request
Operation<Cluster, OperationMetadata> response = streamsServiceClient.CreateCluster(parent, cluster, clusterId);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateCluster(CreateClusterRequest, CallSettings)

public virtual Operation<Cluster, OperationMetadata> CreateCluster(CreateClusterRequest request, CallSettings callSettings = null)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
request	CreateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
CreateClusterRequest request = new CreateClusterRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    ClusterId = "",
    Cluster = new Cluster(),
    RequestId = "",
};
// Make the request
Operation<Cluster, OperationMetadata> response = streamsServiceClient.CreateCluster(request);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateCluster(string, Cluster, string, CallSettings)

public virtual Operation<Cluster, OperationMetadata> CreateCluster(string parent, Cluster cluster, string clusterId, CallSettings callSettings = null)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Cluster cluster = new Cluster();
string clusterId = "";
// Make the request
Operation<Cluster, OperationMetadata> response = streamsServiceClient.CreateCluster(parent, cluster, clusterId);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateClusterAsync(LocationName, Cluster, string, CallSettings)

public virtual Task<Operation<Cluster, OperationMetadata>> CreateClusterAsync(LocationName parent, Cluster cluster, string clusterId, CallSettings callSettings = null)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
parent	LocationName Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Cluster cluster = new Cluster();
string clusterId = "";
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.CreateClusterAsync(parent, cluster, clusterId);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateClusterAsync(LocationName, Cluster, string, CancellationToken)

public virtual Task<Operation<Cluster, OperationMetadata>> CreateClusterAsync(LocationName parent, Cluster cluster, string clusterId, CancellationToken cancellationToken)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
parent	LocationName Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Cluster cluster = new Cluster();
string clusterId = "";
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.CreateClusterAsync(parent, cluster, clusterId);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateClusterAsync(CreateClusterRequest, CallSettings)

public virtual Task<Operation<Cluster, OperationMetadata>> CreateClusterAsync(CreateClusterRequest request, CallSettings callSettings = null)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
request	CreateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateClusterRequest request = new CreateClusterRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    ClusterId = "",
    Cluster = new Cluster(),
    RequestId = "",
};
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.CreateClusterAsync(request);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateClusterAsync(CreateClusterRequest, CancellationToken)

public virtual Task<Operation<Cluster, OperationMetadata>> CreateClusterAsync(CreateClusterRequest request, CancellationToken cancellationToken)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
request	CreateClusterRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateClusterRequest request = new CreateClusterRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    ClusterId = "",
    Cluster = new Cluster(),
    RequestId = "",
};
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.CreateClusterAsync(request);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateClusterAsync(string, Cluster, string, CallSettings)

public virtual Task<Operation<Cluster, OperationMetadata>> CreateClusterAsync(string parent, Cluster cluster, string clusterId, CallSettings callSettings = null)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Cluster cluster = new Cluster();
string clusterId = "";
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.CreateClusterAsync(parent, cluster, clusterId);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateClusterAsync(string, Cluster, string, CancellationToken)

public virtual Task<Operation<Cluster, OperationMetadata>> CreateClusterAsync(string parent, Cluster cluster, string clusterId, CancellationToken cancellationToken)

Creates a new Cluster in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Cluster cluster = new Cluster();
string clusterId = "";
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.CreateClusterAsync(parent, cluster, clusterId);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

CreateEvent(ClusterName, Event, string, CallSettings)

public virtual Operation<Event, OperationMetadata> CreateEvent(ClusterName parent, Event @event, string eventId, CallSettings callSettings = null)

Creates a new Event in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
event	Event Required. The resource being created.
eventId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEventOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Event @event = new Event();
string eventId = "";
// Make the request
Operation<Event, OperationMetadata> response = streamsServiceClient.CreateEvent(parent, @event, eventId);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEvent(CreateEventRequest, CallSettings)

public virtual Operation<Event, OperationMetadata> CreateEvent(CreateEventRequest request, CallSettings callSettings = null)

Creates a new Event in a given project and location.

Parameters
Name	Description
request	CreateEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEventOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
CreateEventRequest request = new CreateEventRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    EventId = "",
    Event = new Event(),
    RequestId = "",
};
// Make the request
Operation<Event, OperationMetadata> response = streamsServiceClient.CreateEvent(request);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEvent(string, Event, string, CallSettings)

public virtual Operation<Event, OperationMetadata> CreateEvent(string parent, Event @event, string eventId, CallSettings callSettings = null)

Creates a new Event in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
event	Event Required. The resource being created.
eventId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEventOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Event @event = new Event();
string eventId = "";
// Make the request
Operation<Event, OperationMetadata> response = streamsServiceClient.CreateEvent(parent, @event, eventId);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEventAsync(ClusterName, Event, string, CallSettings)

public virtual Task<Operation<Event, OperationMetadata>> CreateEventAsync(ClusterName parent, Event @event, string eventId, CallSettings callSettings = null)

Creates a new Event in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
event	Event Required. The resource being created.
eventId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Event @event = new Event();
string eventId = "";
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.CreateEventAsync(parent, @event, eventId);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEventAsync(ClusterName, Event, string, CancellationToken)

public virtual Task<Operation<Event, OperationMetadata>> CreateEventAsync(ClusterName parent, Event @event, string eventId, CancellationToken cancellationToken)

Creates a new Event in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
event	Event Required. The resource being created.
eventId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Event @event = new Event();
string eventId = "";
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.CreateEventAsync(parent, @event, eventId);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEventAsync(CreateEventRequest, CallSettings)

public virtual Task<Operation<Event, OperationMetadata>> CreateEventAsync(CreateEventRequest request, CallSettings callSettings = null)

Creates a new Event in a given project and location.

Parameters
Name	Description
request	CreateEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateEventRequest request = new CreateEventRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    EventId = "",
    Event = new Event(),
    RequestId = "",
};
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.CreateEventAsync(request);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEventAsync(CreateEventRequest, CancellationToken)

public virtual Task<Operation<Event, OperationMetadata>> CreateEventAsync(CreateEventRequest request, CancellationToken cancellationToken)

Creates a new Event in a given project and location.

Parameters
Name	Description
request	CreateEventRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateEventRequest request = new CreateEventRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    EventId = "",
    Event = new Event(),
    RequestId = "",
};
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.CreateEventAsync(request);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEventAsync(string, Event, string, CallSettings)

public virtual Task<Operation<Event, OperationMetadata>> CreateEventAsync(string parent, Event @event, string eventId, CallSettings callSettings = null)

Creates a new Event in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
event	Event Required. The resource being created.
eventId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Event @event = new Event();
string eventId = "";
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.CreateEventAsync(parent, @event, eventId);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateEventAsync(string, Event, string, CancellationToken)

public virtual Task<Operation<Event, OperationMetadata>> CreateEventAsync(string parent, Event @event, string eventId, CancellationToken cancellationToken)

Creates a new Event in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
event	Event Required. The resource being created.
eventId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Event @event = new Event();
string eventId = "";
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.CreateEventAsync(parent, @event, eventId);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

CreateSeries(ClusterName, Series, string, CallSettings)

public virtual Operation<Series, OperationMetadata> CreateSeries(ClusterName parent, Series series, string seriesId, CallSettings callSettings = null)

Creates a new Series in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
series	Series Required. The resource being created.
seriesId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationSeriesOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Series series = new Series();
string seriesId = "";
// Make the request
Operation<Series, OperationMetadata> response = streamsServiceClient.CreateSeries(parent, series, seriesId);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeries(CreateSeriesRequest, CallSettings)

public virtual Operation<Series, OperationMetadata> CreateSeries(CreateSeriesRequest request, CallSettings callSettings = null)

Creates a new Series in a given project and location.

Parameters
Name	Description
request	CreateSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationSeriesOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
CreateSeriesRequest request = new CreateSeriesRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    SeriesId = "",
    Series = new Series(),
    RequestId = "",
};
// Make the request
Operation<Series, OperationMetadata> response = streamsServiceClient.CreateSeries(request);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeries(string, Series, string, CallSettings)

public virtual Operation<Series, OperationMetadata> CreateSeries(string parent, Series series, string seriesId, CallSettings callSettings = null)

Creates a new Series in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
series	Series Required. The resource being created.
seriesId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationSeriesOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Series series = new Series();
string seriesId = "";
// Make the request
Operation<Series, OperationMetadata> response = streamsServiceClient.CreateSeries(parent, series, seriesId);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeriesAsync(ClusterName, Series, string, CallSettings)

public virtual Task<Operation<Series, OperationMetadata>> CreateSeriesAsync(ClusterName parent, Series series, string seriesId, CallSettings callSettings = null)

Creates a new Series in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
series	Series Required. The resource being created.
seriesId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Series series = new Series();
string seriesId = "";
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.CreateSeriesAsync(parent, series, seriesId);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeriesAsync(ClusterName, Series, string, CancellationToken)

public virtual Task<Operation<Series, OperationMetadata>> CreateSeriesAsync(ClusterName parent, Series series, string seriesId, CancellationToken cancellationToken)

Creates a new Series in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
series	Series Required. The resource being created.
seriesId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Series series = new Series();
string seriesId = "";
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.CreateSeriesAsync(parent, series, seriesId);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeriesAsync(CreateSeriesRequest, CallSettings)

public virtual Task<Operation<Series, OperationMetadata>> CreateSeriesAsync(CreateSeriesRequest request, CallSettings callSettings = null)

Creates a new Series in a given project and location.

Parameters
Name	Description
request	CreateSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateSeriesRequest request = new CreateSeriesRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    SeriesId = "",
    Series = new Series(),
    RequestId = "",
};
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.CreateSeriesAsync(request);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeriesAsync(CreateSeriesRequest, CancellationToken)

public virtual Task<Operation<Series, OperationMetadata>> CreateSeriesAsync(CreateSeriesRequest request, CancellationToken cancellationToken)

Creates a new Series in a given project and location.

Parameters
Name	Description
request	CreateSeriesRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateSeriesRequest request = new CreateSeriesRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    SeriesId = "",
    Series = new Series(),
    RequestId = "",
};
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.CreateSeriesAsync(request);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeriesAsync(string, Series, string, CallSettings)

public virtual Task<Operation<Series, OperationMetadata>> CreateSeriesAsync(string parent, Series series, string seriesId, CallSettings callSettings = null)

Creates a new Series in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
series	Series Required. The resource being created.
seriesId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Series series = new Series();
string seriesId = "";
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.CreateSeriesAsync(parent, series, seriesId);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateSeriesAsync(string, Series, string, CancellationToken)

public virtual Task<Operation<Series, OperationMetadata>> CreateSeriesAsync(string parent, Series series, string seriesId, CancellationToken cancellationToken)

Creates a new Series in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
series	Series Required. The resource being created.
seriesId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Series series = new Series();
string seriesId = "";
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.CreateSeriesAsync(parent, series, seriesId);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

CreateStream(ClusterName, Stream, string, CallSettings)

public virtual Operation<Stream, OperationMetadata> CreateStream(ClusterName parent, Stream stream, string streamId, CallSettings callSettings = null)

Creates a new Stream in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationStreamOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = streamsServiceClient.CreateStream(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStream(CreateStreamRequest, CallSettings)

public virtual Operation<Stream, OperationMetadata> CreateStream(CreateStreamRequest request, CallSettings callSettings = null)

Creates a new Stream in a given project and location.

Parameters
Name	Description
request	CreateStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationStreamOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    StreamId = "",
    Stream = new Stream(),
    RequestId = "",
};
// Make the request
Operation<Stream, OperationMetadata> response = streamsServiceClient.CreateStream(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStream(string, Stream, string, CallSettings)

public virtual Operation<Stream, OperationMetadata> CreateStream(string parent, Stream stream, string streamId, CallSettings callSettings = null)

Creates a new Stream in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationStreamOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = streamsServiceClient.CreateStream(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceCreateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(ClusterName, Stream, string, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(ClusterName parent, Stream stream, string streamId, CallSettings callSettings = null)

Creates a new Stream in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(ClusterName, Stream, string, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(ClusterName parent, Stream stream, string streamId, CancellationToken cancellationToken)

Creates a new Stream in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(CreateStreamRequest, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(CreateStreamRequest request, CallSettings callSettings = null)

Creates a new Stream in a given project and location.

Parameters
Name	Description
request	CreateStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    StreamId = "",
    Stream = new Stream(),
    RequestId = "",
};
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.CreateStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(CreateStreamRequest, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(CreateStreamRequest request, CancellationToken cancellationToken)

Creates a new Stream in a given project and location.

Parameters
Name	Description
request	CreateStreamRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    StreamId = "",
    Stream = new Stream(),
    RequestId = "",
};
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.CreateStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(string, Stream, string, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(string parent, Stream stream, string streamId, CallSettings callSettings = null)

Creates a new Stream in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	string Required. Id of the requesting object.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(string, Stream, string, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(string parent, Stream stream, string streamId, CancellationToken cancellationToken)

Creates a new Stream in a given project and location.

Parameters
Name	Description
parent	string Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	string Required. Id of the requesting object.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

DeleteCluster(ClusterName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteCluster(ClusterName name, CallSettings callSettings = null)

Deletes a single Cluster.

Parameters
Name	Description
name	ClusterName Required. Name of the resource
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName name = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteCluster(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteCluster(DeleteClusterRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteCluster(DeleteClusterRequest request, CallSettings callSettings = null)

Deletes a single Cluster.

Parameters
Name	Description
request	DeleteClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
DeleteClusterRequest request = new DeleteClusterRequest
{
    ClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteCluster(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteCluster(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteCluster(string name, CallSettings callSettings = null)

Deletes a single Cluster.

Parameters
Name	Description
name	string Required. Name of the resource
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteCluster(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteClusterAsync(ClusterName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteClusterAsync(ClusterName name, CallSettings callSettings = null)

Deletes a single Cluster.

Parameters
Name	Description
name	ClusterName Required. Name of the resource
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName name = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteClusterAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteClusterAsync(ClusterName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteClusterAsync(ClusterName name, CancellationToken cancellationToken)

Deletes a single Cluster.

Parameters
Name	Description
name	ClusterName Required. Name of the resource
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName name = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteClusterAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteClusterAsync(DeleteClusterRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteClusterAsync(DeleteClusterRequest request, CallSettings callSettings = null)

Deletes a single Cluster.

Parameters
Name	Description
request	DeleteClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteClusterRequest request = new DeleteClusterRequest
{
    ClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteClusterAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteClusterAsync(DeleteClusterRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteClusterAsync(DeleteClusterRequest request, CancellationToken cancellationToken)

Deletes a single Cluster.

Parameters
Name	Description
request	DeleteClusterRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteClusterRequest request = new DeleteClusterRequest
{
    ClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteClusterAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteClusterAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteClusterAsync(string name, CallSettings callSettings = null)

Deletes a single Cluster.

Parameters
Name	Description
name	string Required. Name of the resource
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteClusterAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteClusterAsync(string, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteClusterAsync(string name, CancellationToken cancellationToken)

Deletes a single Cluster.

Parameters
Name	Description
name	string Required. Name of the resource
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteClusterAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEvent(DeleteEventRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteEvent(DeleteEventRequest request, CallSettings callSettings = null)

Deletes a single Event.

Parameters
Name	Description
request	DeleteEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
DeleteEventRequest request = new DeleteEventRequest
{
    EventName = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteEvent(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEvent(EventName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteEvent(EventName name, CallSettings callSettings = null)

Deletes a single Event.

Parameters
Name	Description
name	EventName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
EventName name = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteEvent(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEvent(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteEvent(string name, CallSettings callSettings = null)

Deletes a single Event.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/events/[EVENT]";
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteEvent(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEventAsync(DeleteEventRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteEventAsync(DeleteEventRequest request, CallSettings callSettings = null)

Deletes a single Event.

Parameters
Name	Description
request	DeleteEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteEventRequest request = new DeleteEventRequest
{
    EventName = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteEventAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEventAsync(DeleteEventRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteEventAsync(DeleteEventRequest request, CancellationToken cancellationToken)

Deletes a single Event.

Parameters
Name	Description
request	DeleteEventRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteEventRequest request = new DeleteEventRequest
{
    EventName = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteEventAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEventAsync(EventName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteEventAsync(EventName name, CallSettings callSettings = null)

Deletes a single Event.

Parameters
Name	Description
name	EventName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
EventName name = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteEventAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEventAsync(EventName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteEventAsync(EventName name, CancellationToken cancellationToken)

Deletes a single Event.

Parameters
Name	Description
name	EventName Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
EventName name = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteEventAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEventAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteEventAsync(string name, CallSettings callSettings = null)

Deletes a single Event.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/events/[EVENT]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteEventAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteEventAsync(string, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteEventAsync(string name, CancellationToken cancellationToken)

Deletes a single Event.

Parameters
Name	Description
name	string Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/events/[EVENT]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteEventAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeries(DeleteSeriesRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteSeries(DeleteSeriesRequest request, CallSettings callSettings = null)

Deletes a single Series.

Parameters
Name	Description
request	DeleteSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
DeleteSeriesRequest request = new DeleteSeriesRequest
{
    SeriesName = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteSeries(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeries(SeriesName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteSeries(SeriesName name, CallSettings callSettings = null)

Deletes a single Series.

Parameters
Name	Description
name	SeriesName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
SeriesName name = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteSeries(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeries(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteSeries(string name, CallSettings callSettings = null)

Deletes a single Series.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/series/[SERIES]";
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteSeries(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeriesAsync(DeleteSeriesRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteSeriesAsync(DeleteSeriesRequest request, CallSettings callSettings = null)

Deletes a single Series.

Parameters
Name	Description
request	DeleteSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteSeriesRequest request = new DeleteSeriesRequest
{
    SeriesName = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteSeriesAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeriesAsync(DeleteSeriesRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteSeriesAsync(DeleteSeriesRequest request, CancellationToken cancellationToken)

Deletes a single Series.

Parameters
Name	Description
request	DeleteSeriesRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteSeriesRequest request = new DeleteSeriesRequest
{
    SeriesName = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteSeriesAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeriesAsync(SeriesName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteSeriesAsync(SeriesName name, CallSettings callSettings = null)

Deletes a single Series.

Parameters
Name	Description
name	SeriesName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
SeriesName name = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteSeriesAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeriesAsync(SeriesName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteSeriesAsync(SeriesName name, CancellationToken cancellationToken)

Deletes a single Series.

Parameters
Name	Description
name	SeriesName Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
SeriesName name = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteSeriesAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeriesAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteSeriesAsync(string name, CallSettings callSettings = null)

Deletes a single Series.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/series/[SERIES]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteSeriesAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteSeriesAsync(string, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteSeriesAsync(string name, CancellationToken cancellationToken)

Deletes a single Series.

Parameters
Name	Description
name	string Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/series/[SERIES]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteSeriesAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStream(DeleteStreamRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteStream(DeleteStreamRequest request, CallSettings callSettings = null)

Deletes a single Stream.

Parameters
Name	Description
request	DeleteStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
    StreamName = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteStream(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStream(StreamName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteStream(StreamName name, CallSettings callSettings = null)

Deletes a single Stream.

Parameters
Name	Description
name	StreamName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteStream(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStream(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteStream(string name, CallSettings callSettings = null)

Deletes a single Stream.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = streamsServiceClient.DeleteStream(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceDeleteStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(DeleteStreamRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(DeleteStreamRequest request, CallSettings callSettings = null)

Deletes a single Stream.

Parameters
Name	Description
request	DeleteStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
    StreamName = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(DeleteStreamRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(DeleteStreamRequest request, CancellationToken cancellationToken)

Deletes a single Stream.

Parameters
Name	Description
request	DeleteStreamRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
    StreamName = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(StreamName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(StreamName name, CallSettings callSettings = null)

Deletes a single Stream.

Parameters
Name	Description
name	StreamName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(StreamName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(StreamName name, CancellationToken cancellationToken)

Deletes a single Stream.

Parameters
Name	Description
name	StreamName Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(string name, CallSettings callSettings = null)

Deletes a single Stream.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(string, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(string name, CancellationToken cancellationToken)

Deletes a single Stream.

Parameters
Name	Description
name	string Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = await streamsServiceClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

GenerateStreamHlsToken(GenerateStreamHlsTokenRequest, CallSettings)

public virtual GenerateStreamHlsTokenResponse GenerateStreamHlsToken(GenerateStreamHlsTokenRequest request, CallSettings callSettings = null)

Generate the JWT auth token required to get the stream HLS contents.

Parameters
Name	Description
request	GenerateStreamHlsTokenRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
GenerateStreamHlsTokenResponse	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
GenerateStreamHlsTokenRequest request = new GenerateStreamHlsTokenRequest { Stream = "", };
// Make the request
GenerateStreamHlsTokenResponse response = streamsServiceClient.GenerateStreamHlsToken(request);

GenerateStreamHlsToken(string, CallSettings)

public virtual GenerateStreamHlsTokenResponse GenerateStreamHlsToken(string stream, CallSettings callSettings = null)

Generate the JWT auth token required to get the stream HLS contents.

Parameters
Name	Description
stream	string Required. The name of the stream.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
GenerateStreamHlsTokenResponse	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string stream = "";
// Make the request
GenerateStreamHlsTokenResponse response = streamsServiceClient.GenerateStreamHlsToken(stream);

GenerateStreamHlsTokenAsync(GenerateStreamHlsTokenRequest, CallSettings)

public virtual Task<GenerateStreamHlsTokenResponse> GenerateStreamHlsTokenAsync(GenerateStreamHlsTokenRequest request, CallSettings callSettings = null)

Generate the JWT auth token required to get the stream HLS contents.

Parameters
Name	Description
request	GenerateStreamHlsTokenRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskGenerateStreamHlsTokenResponse	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GenerateStreamHlsTokenRequest request = new GenerateStreamHlsTokenRequest { Stream = "", };
// Make the request
GenerateStreamHlsTokenResponse response = await streamsServiceClient.GenerateStreamHlsTokenAsync(request);

GenerateStreamHlsTokenAsync(GenerateStreamHlsTokenRequest, CancellationToken)

public virtual Task<GenerateStreamHlsTokenResponse> GenerateStreamHlsTokenAsync(GenerateStreamHlsTokenRequest request, CancellationToken cancellationToken)

Generate the JWT auth token required to get the stream HLS contents.

Parameters
Name	Description
request	GenerateStreamHlsTokenRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskGenerateStreamHlsTokenResponse	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GenerateStreamHlsTokenRequest request = new GenerateStreamHlsTokenRequest { Stream = "", };
// Make the request
GenerateStreamHlsTokenResponse response = await streamsServiceClient.GenerateStreamHlsTokenAsync(request);

GenerateStreamHlsTokenAsync(string, CallSettings)

public virtual Task<GenerateStreamHlsTokenResponse> GenerateStreamHlsTokenAsync(string stream, CallSettings callSettings = null)

Generate the JWT auth token required to get the stream HLS contents.

Parameters
Name	Description
stream	string Required. The name of the stream.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskGenerateStreamHlsTokenResponse	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string stream = "";
// Make the request
GenerateStreamHlsTokenResponse response = await streamsServiceClient.GenerateStreamHlsTokenAsync(stream);

GenerateStreamHlsTokenAsync(string, CancellationToken)

public virtual Task<GenerateStreamHlsTokenResponse> GenerateStreamHlsTokenAsync(string stream, CancellationToken cancellationToken)

Generate the JWT auth token required to get the stream HLS contents.

Parameters
Name	Description
stream	string Required. The name of the stream.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskGenerateStreamHlsTokenResponse	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string stream = "";
// Make the request
GenerateStreamHlsTokenResponse response = await streamsServiceClient.GenerateStreamHlsTokenAsync(stream);

GetCluster(ClusterName, CallSettings)

public virtual Cluster GetCluster(ClusterName name, CallSettings callSettings = null)

Gets details of a single Cluster.

Parameters
Name	Description
name	ClusterName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Cluster	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName name = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
Cluster response = streamsServiceClient.GetCluster(name);

GetCluster(GetClusterRequest, CallSettings)

public virtual Cluster GetCluster(GetClusterRequest request, CallSettings callSettings = null)

Gets details of a single Cluster.

Parameters
Name	Description
request	GetClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Cluster	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
GetClusterRequest request = new GetClusterRequest
{
    ClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
};
// Make the request
Cluster response = streamsServiceClient.GetCluster(request);

GetCluster(string, CallSettings)

public virtual Cluster GetCluster(string name, CallSettings callSettings = null)

Gets details of a single Cluster.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Cluster	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
Cluster response = streamsServiceClient.GetCluster(name);

GetClusterAsync(ClusterName, CallSettings)

public virtual Task<Cluster> GetClusterAsync(ClusterName name, CallSettings callSettings = null)

Gets details of a single Cluster.

Parameters
Name	Description
name	ClusterName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskCluster	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName name = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
Cluster response = await streamsServiceClient.GetClusterAsync(name);

GetClusterAsync(ClusterName, CancellationToken)

public virtual Task<Cluster> GetClusterAsync(ClusterName name, CancellationToken cancellationToken)

Gets details of a single Cluster.

Parameters
Name	Description
name	ClusterName Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskCluster	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName name = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
Cluster response = await streamsServiceClient.GetClusterAsync(name);

GetClusterAsync(GetClusterRequest, CallSettings)

public virtual Task<Cluster> GetClusterAsync(GetClusterRequest request, CallSettings callSettings = null)

Gets details of a single Cluster.

Parameters
Name	Description
request	GetClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskCluster	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetClusterRequest request = new GetClusterRequest
{
    ClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
};
// Make the request
Cluster response = await streamsServiceClient.GetClusterAsync(request);

GetClusterAsync(GetClusterRequest, CancellationToken)

public virtual Task<Cluster> GetClusterAsync(GetClusterRequest request, CancellationToken cancellationToken)

Gets details of a single Cluster.

Parameters
Name	Description
request	GetClusterRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskCluster	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetClusterRequest request = new GetClusterRequest
{
    ClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
};
// Make the request
Cluster response = await streamsServiceClient.GetClusterAsync(request);

GetClusterAsync(string, CallSettings)

public virtual Task<Cluster> GetClusterAsync(string name, CallSettings callSettings = null)

Gets details of a single Cluster.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskCluster	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
Cluster response = await streamsServiceClient.GetClusterAsync(name);

GetClusterAsync(string, CancellationToken)

public virtual Task<Cluster> GetClusterAsync(string name, CancellationToken cancellationToken)

Gets details of a single Cluster.

Parameters
Name	Description
name	string Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskCluster	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
Cluster response = await streamsServiceClient.GetClusterAsync(name);

GetEvent(EventName, CallSettings)

public virtual Event GetEvent(EventName name, CallSettings callSettings = null)

Gets details of a single Event.

Parameters
Name	Description
name	EventName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Event	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
EventName name = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
// Make the request
Event response = streamsServiceClient.GetEvent(name);

GetEvent(GetEventRequest, CallSettings)

public virtual Event GetEvent(GetEventRequest request, CallSettings callSettings = null)

Gets details of a single Event.

Parameters
Name	Description
request	GetEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Event	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
GetEventRequest request = new GetEventRequest
{
    EventName = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]"),
};
// Make the request
Event response = streamsServiceClient.GetEvent(request);

GetEvent(string, CallSettings)

public virtual Event GetEvent(string name, CallSettings callSettings = null)

Gets details of a single Event.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Event	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/events/[EVENT]";
// Make the request
Event response = streamsServiceClient.GetEvent(name);

GetEventAsync(EventName, CallSettings)

public virtual Task<Event> GetEventAsync(EventName name, CallSettings callSettings = null)

Gets details of a single Event.

Parameters
Name	Description
name	EventName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskEvent	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
EventName name = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
// Make the request
Event response = await streamsServiceClient.GetEventAsync(name);

GetEventAsync(EventName, CancellationToken)

public virtual Task<Event> GetEventAsync(EventName name, CancellationToken cancellationToken)

Gets details of a single Event.

Parameters
Name	Description
name	EventName Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskEvent	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
EventName name = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
// Make the request
Event response = await streamsServiceClient.GetEventAsync(name);

GetEventAsync(GetEventRequest, CallSettings)

public virtual Task<Event> GetEventAsync(GetEventRequest request, CallSettings callSettings = null)

Gets details of a single Event.

Parameters
Name	Description
request	GetEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskEvent	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetEventRequest request = new GetEventRequest
{
    EventName = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]"),
};
// Make the request
Event response = await streamsServiceClient.GetEventAsync(request);

GetEventAsync(GetEventRequest, CancellationToken)

public virtual Task<Event> GetEventAsync(GetEventRequest request, CancellationToken cancellationToken)

Gets details of a single Event.

Parameters
Name	Description
request	GetEventRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskEvent	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetEventRequest request = new GetEventRequest
{
    EventName = EventName.FromProjectLocationClusterEvent("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]"),
};
// Make the request
Event response = await streamsServiceClient.GetEventAsync(request);

GetEventAsync(string, CallSettings)

public virtual Task<Event> GetEventAsync(string name, CallSettings callSettings = null)

Gets details of a single Event.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskEvent	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/events/[EVENT]";
// Make the request
Event response = await streamsServiceClient.GetEventAsync(name);

GetEventAsync(string, CancellationToken)

public virtual Task<Event> GetEventAsync(string name, CancellationToken cancellationToken)

Gets details of a single Event.

Parameters
Name	Description
name	string Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskEvent	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/events/[EVENT]";
// Make the request
Event response = await streamsServiceClient.GetEventAsync(name);

GetSeries(GetSeriesRequest, CallSettings)

public virtual Series GetSeries(GetSeriesRequest request, CallSettings callSettings = null)

Gets details of a single Series.

Parameters
Name	Description
request	GetSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Series	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
GetSeriesRequest request = new GetSeriesRequest
{
    SeriesName = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]"),
};
// Make the request
Series response = streamsServiceClient.GetSeries(request);

GetSeries(SeriesName, CallSettings)

public virtual Series GetSeries(SeriesName name, CallSettings callSettings = null)

Gets details of a single Series.

Parameters
Name	Description
name	SeriesName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Series	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
SeriesName name = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
// Make the request
Series response = streamsServiceClient.GetSeries(name);

GetSeries(string, CallSettings)

public virtual Series GetSeries(string name, CallSettings callSettings = null)

Gets details of a single Series.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Series	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/series/[SERIES]";
// Make the request
Series response = streamsServiceClient.GetSeries(name);

GetSeriesAsync(GetSeriesRequest, CallSettings)

public virtual Task<Series> GetSeriesAsync(GetSeriesRequest request, CallSettings callSettings = null)

Gets details of a single Series.

Parameters
Name	Description
request	GetSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskSeries	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetSeriesRequest request = new GetSeriesRequest
{
    SeriesName = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]"),
};
// Make the request
Series response = await streamsServiceClient.GetSeriesAsync(request);

GetSeriesAsync(GetSeriesRequest, CancellationToken)

public virtual Task<Series> GetSeriesAsync(GetSeriesRequest request, CancellationToken cancellationToken)

Gets details of a single Series.

Parameters
Name	Description
request	GetSeriesRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskSeries	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetSeriesRequest request = new GetSeriesRequest
{
    SeriesName = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]"),
};
// Make the request
Series response = await streamsServiceClient.GetSeriesAsync(request);

GetSeriesAsync(SeriesName, CallSettings)

public virtual Task<Series> GetSeriesAsync(SeriesName name, CallSettings callSettings = null)

Gets details of a single Series.

Parameters
Name	Description
name	SeriesName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskSeries	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
SeriesName name = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
// Make the request
Series response = await streamsServiceClient.GetSeriesAsync(name);

GetSeriesAsync(SeriesName, CancellationToken)

public virtual Task<Series> GetSeriesAsync(SeriesName name, CancellationToken cancellationToken)

Gets details of a single Series.

Parameters
Name	Description
name	SeriesName Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskSeries	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
SeriesName name = SeriesName.FromProjectLocationClusterSeries("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
// Make the request
Series response = await streamsServiceClient.GetSeriesAsync(name);

GetSeriesAsync(string, CallSettings)

public virtual Task<Series> GetSeriesAsync(string name, CallSettings callSettings = null)

Gets details of a single Series.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskSeries	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/series/[SERIES]";
// Make the request
Series response = await streamsServiceClient.GetSeriesAsync(name);

GetSeriesAsync(string, CancellationToken)

public virtual Task<Series> GetSeriesAsync(string name, CancellationToken cancellationToken)

Gets details of a single Series.

Parameters
Name	Description
name	string Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskSeries	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/series/[SERIES]";
// Make the request
Series response = await streamsServiceClient.GetSeriesAsync(name);

GetStream(GetStreamRequest, CallSettings)

public virtual Stream GetStream(GetStreamRequest request, CallSettings callSettings = null)

Gets details of a single Stream.

Parameters
Name	Description
request	GetStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Stream	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
    StreamName = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]"),
};
// Make the request
Stream response = streamsServiceClient.GetStream(request);

GetStream(StreamName, CallSettings)

public virtual Stream GetStream(StreamName name, CallSettings callSettings = null)

Gets details of a single Stream.

Parameters
Name	Description
name	StreamName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Stream	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
// Make the request
Stream response = streamsServiceClient.GetStream(name);

GetStream(string, CallSettings)

public virtual Stream GetStream(string name, CallSettings callSettings = null)

Gets details of a single Stream.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Stream	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/streams/[STREAM]";
// Make the request
Stream response = streamsServiceClient.GetStream(name);

GetStreamAsync(GetStreamRequest, CallSettings)

public virtual Task<Stream> GetStreamAsync(GetStreamRequest request, CallSettings callSettings = null)

Gets details of a single Stream.

Parameters
Name	Description
request	GetStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskStream	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
    StreamName = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]"),
};
// Make the request
Stream response = await streamsServiceClient.GetStreamAsync(request);

GetStreamAsync(GetStreamRequest, CancellationToken)

public virtual Task<Stream> GetStreamAsync(GetStreamRequest request, CancellationToken cancellationToken)

Gets details of a single Stream.

Parameters
Name	Description
request	GetStreamRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskStream	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
    StreamName = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]"),
};
// Make the request
Stream response = await streamsServiceClient.GetStreamAsync(request);

GetStreamAsync(StreamName, CallSettings)

public virtual Task<Stream> GetStreamAsync(StreamName name, CallSettings callSettings = null)

Gets details of a single Stream.

Parameters
Name	Description
name	StreamName Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskStream	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
// Make the request
Stream response = await streamsServiceClient.GetStreamAsync(name);

GetStreamAsync(StreamName, CancellationToken)

public virtual Task<Stream> GetStreamAsync(StreamName name, CancellationToken cancellationToken)

Gets details of a single Stream.

Parameters
Name	Description
name	StreamName Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskStream	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationClusterStream("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
// Make the request
Stream response = await streamsServiceClient.GetStreamAsync(name);

GetStreamAsync(string, CallSettings)

public virtual Task<Stream> GetStreamAsync(string name, CallSettings callSettings = null)

Gets details of a single Stream.

Parameters
Name	Description
name	string Required. Name of the resource.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskStream	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/streams/[STREAM]";
// Make the request
Stream response = await streamsServiceClient.GetStreamAsync(name);

GetStreamAsync(string, CancellationToken)

public virtual Task<Stream> GetStreamAsync(string name, CancellationToken cancellationToken)

Gets details of a single Stream.

Parameters
Name	Description
name	string Required. Name of the resource.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskStream	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]/streams/[STREAM]";
// Make the request
Stream response = await streamsServiceClient.GetStreamAsync(name);

GetStreamThumbnail(GetStreamThumbnailRequest, CallSettings)

public virtual Operation<GetStreamThumbnailResponse, OperationMetadata> GetStreamThumbnail(GetStreamThumbnailRequest request, CallSettings callSettings = null)

Gets the thumbnail (image snapshot) of a single Stream.

Parameters
Name	Description
request	GetStreamThumbnailRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationGetStreamThumbnailResponseOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
GetStreamThumbnailRequest request = new GetStreamThumbnailRequest
{
    Stream = "",
    GcsObjectName = "",
    Event = "",
    RequestId = "",
};
// Make the request
Operation<GetStreamThumbnailResponse, OperationMetadata> response = streamsServiceClient.GetStreamThumbnail(request);

// Poll until the returned long-running operation is complete
Operation<GetStreamThumbnailResponse, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
GetStreamThumbnailResponse result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<GetStreamThumbnailResponse, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceGetStreamThumbnail(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    GetStreamThumbnailResponse retrievedResult = retrievedResponse.Result;
}

GetStreamThumbnail(string, string, CallSettings)

public virtual Operation<GetStreamThumbnailResponse, OperationMetadata> GetStreamThumbnail(string stream, string gcsObjectName, CallSettings callSettings = null)

Gets the thumbnail (image snapshot) of a single Stream.

Parameters
Name	Description
stream	string Required. The name of the stream for to get the thumbnail from.
gcsObjectName	string Required. The name of the GCS object to store the thumbnail image.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationGetStreamThumbnailResponseOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string stream = "";
string gcsObjectName = "";
// Make the request
Operation<GetStreamThumbnailResponse, OperationMetadata> response = streamsServiceClient.GetStreamThumbnail(stream, gcsObjectName);

// Poll until the returned long-running operation is complete
Operation<GetStreamThumbnailResponse, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
GetStreamThumbnailResponse result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<GetStreamThumbnailResponse, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceGetStreamThumbnail(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    GetStreamThumbnailResponse retrievedResult = retrievedResponse.Result;
}

GetStreamThumbnailAsync(GetStreamThumbnailRequest, CallSettings)

public virtual Task<Operation<GetStreamThumbnailResponse, OperationMetadata>> GetStreamThumbnailAsync(GetStreamThumbnailRequest request, CallSettings callSettings = null)

Gets the thumbnail (image snapshot) of a single Stream.

Parameters
Name	Description
request	GetStreamThumbnailRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationGetStreamThumbnailResponseOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetStreamThumbnailRequest request = new GetStreamThumbnailRequest
{
    Stream = "",
    GcsObjectName = "",
    Event = "",
    RequestId = "",
};
// Make the request
Operation<GetStreamThumbnailResponse, OperationMetadata> response = await streamsServiceClient.GetStreamThumbnailAsync(request);

// Poll until the returned long-running operation is complete
Operation<GetStreamThumbnailResponse, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
GetStreamThumbnailResponse result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<GetStreamThumbnailResponse, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceGetStreamThumbnailAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    GetStreamThumbnailResponse retrievedResult = retrievedResponse.Result;
}

GetStreamThumbnailAsync(GetStreamThumbnailRequest, CancellationToken)

public virtual Task<Operation<GetStreamThumbnailResponse, OperationMetadata>> GetStreamThumbnailAsync(GetStreamThumbnailRequest request, CancellationToken cancellationToken)

Gets the thumbnail (image snapshot) of a single Stream.

Parameters
Name	Description
request	GetStreamThumbnailRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationGetStreamThumbnailResponseOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
GetStreamThumbnailRequest request = new GetStreamThumbnailRequest
{
    Stream = "",
    GcsObjectName = "",
    Event = "",
    RequestId = "",
};
// Make the request
Operation<GetStreamThumbnailResponse, OperationMetadata> response = await streamsServiceClient.GetStreamThumbnailAsync(request);

// Poll until the returned long-running operation is complete
Operation<GetStreamThumbnailResponse, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
GetStreamThumbnailResponse result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<GetStreamThumbnailResponse, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceGetStreamThumbnailAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    GetStreamThumbnailResponse retrievedResult = retrievedResponse.Result;
}

GetStreamThumbnailAsync(string, string, CallSettings)

public virtual Task<Operation<GetStreamThumbnailResponse, OperationMetadata>> GetStreamThumbnailAsync(string stream, string gcsObjectName, CallSettings callSettings = null)

Gets the thumbnail (image snapshot) of a single Stream.

Parameters
Name	Description
stream	string Required. The name of the stream for to get the thumbnail from.
gcsObjectName	string Required. The name of the GCS object to store the thumbnail image.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationGetStreamThumbnailResponseOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string stream = "";
string gcsObjectName = "";
// Make the request
Operation<GetStreamThumbnailResponse, OperationMetadata> response = await streamsServiceClient.GetStreamThumbnailAsync(stream, gcsObjectName);

// Poll until the returned long-running operation is complete
Operation<GetStreamThumbnailResponse, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
GetStreamThumbnailResponse result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<GetStreamThumbnailResponse, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceGetStreamThumbnailAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    GetStreamThumbnailResponse retrievedResult = retrievedResponse.Result;
}

GetStreamThumbnailAsync(string, string, CancellationToken)

public virtual Task<Operation<GetStreamThumbnailResponse, OperationMetadata>> GetStreamThumbnailAsync(string stream, string gcsObjectName, CancellationToken cancellationToken)

Gets the thumbnail (image snapshot) of a single Stream.

Parameters
Name	Description
stream	string Required. The name of the stream for to get the thumbnail from.
gcsObjectName	string Required. The name of the GCS object to store the thumbnail image.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationGetStreamThumbnailResponseOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string stream = "";
string gcsObjectName = "";
// Make the request
Operation<GetStreamThumbnailResponse, OperationMetadata> response = await streamsServiceClient.GetStreamThumbnailAsync(stream, gcsObjectName);

// Poll until the returned long-running operation is complete
Operation<GetStreamThumbnailResponse, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
GetStreamThumbnailResponse result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<GetStreamThumbnailResponse, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceGetStreamThumbnailAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    GetStreamThumbnailResponse retrievedResult = retrievedResponse.Result;
}

ListClusters(LocationName, string, int?, CallSettings)

public virtual PagedEnumerable<ListClustersResponse, Cluster> ListClusters(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Clusters in a given project and location.

Parameters
Name	Description
parent	LocationName Required. Parent value for ListClustersRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListClustersResponseCluster	A pageable sequence of Cluster resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedEnumerable<ListClustersResponse, Cluster> response = streamsServiceClient.ListClusters(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Cluster item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListClustersResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Cluster item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Cluster> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Cluster item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListClusters(ListClustersRequest, CallSettings)

public virtual PagedEnumerable<ListClustersResponse, Cluster> ListClusters(ListClustersRequest request, CallSettings callSettings = null)

Lists Clusters in a given project and location.

Parameters
Name	Description
request	ListClustersRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListClustersResponseCluster	A pageable sequence of Cluster resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ListClustersRequest request = new ListClustersRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedEnumerable<ListClustersResponse, Cluster> response = streamsServiceClient.ListClusters(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (Cluster item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListClustersResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Cluster item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Cluster> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Cluster item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListClusters(string, string, int?, CallSettings)

public virtual PagedEnumerable<ListClustersResponse, Cluster> ListClusters(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Clusters in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListClustersRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListClustersResponseCluster	A pageable sequence of Cluster resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedEnumerable<ListClustersResponse, Cluster> response = streamsServiceClient.ListClusters(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Cluster item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListClustersResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Cluster item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Cluster> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Cluster item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListClustersAsync(LocationName, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListClustersResponse, Cluster> ListClustersAsync(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Clusters in a given project and location.

Parameters
Name	Description
parent	LocationName Required. Parent value for ListClustersRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListClustersResponseCluster	A pageable asynchronous sequence of Cluster resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedAsyncEnumerable<ListClustersResponse, Cluster> response = streamsServiceClient.ListClustersAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Cluster item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListClustersResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Cluster item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Cluster> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Cluster item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListClustersAsync(ListClustersRequest, CallSettings)

public virtual PagedAsyncEnumerable<ListClustersResponse, Cluster> ListClustersAsync(ListClustersRequest request, CallSettings callSettings = null)

Lists Clusters in a given project and location.

Parameters
Name	Description
request	ListClustersRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListClustersResponseCluster	A pageable asynchronous sequence of Cluster resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ListClustersRequest request = new ListClustersRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListClustersResponse, Cluster> response = streamsServiceClient.ListClustersAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Cluster item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListClustersResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Cluster item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Cluster> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Cluster item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListClustersAsync(string, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListClustersResponse, Cluster> ListClustersAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Clusters in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListClustersRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListClustersResponseCluster	A pageable asynchronous sequence of Cluster resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedAsyncEnumerable<ListClustersResponse, Cluster> response = streamsServiceClient.ListClustersAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Cluster item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListClustersResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Cluster item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Cluster> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Cluster item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListEvents(ClusterName, string, int?, CallSettings)

public virtual PagedEnumerable<ListEventsResponse, Event> ListEvents(ClusterName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Events in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Parent value for ListEventsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListEventsResponseEvent	A pageable sequence of Event resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
PagedEnumerable<ListEventsResponse, Event> response = streamsServiceClient.ListEvents(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Event item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Event item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Event> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Event item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListEvents(ListEventsRequest, CallSettings)

public virtual PagedEnumerable<ListEventsResponse, Event> ListEvents(ListEventsRequest request, CallSettings callSettings = null)

Lists Events in a given project and location.

Parameters
Name	Description
request	ListEventsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListEventsResponseEvent	A pageable sequence of Event resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ListEventsRequest request = new ListEventsRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedEnumerable<ListEventsResponse, Event> response = streamsServiceClient.ListEvents(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (Event item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Event item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Event> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Event item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListEvents(string, string, int?, CallSettings)

public virtual PagedEnumerable<ListEventsResponse, Event> ListEvents(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Events in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListEventsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListEventsResponseEvent	A pageable sequence of Event resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
PagedEnumerable<ListEventsResponse, Event> response = streamsServiceClient.ListEvents(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Event item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Event item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Event> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Event item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListEventsAsync(ClusterName, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListEventsResponse, Event> ListEventsAsync(ClusterName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Events in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Parent value for ListEventsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListEventsResponseEvent	A pageable asynchronous sequence of Event resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
PagedAsyncEnumerable<ListEventsResponse, Event> response = streamsServiceClient.ListEventsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Event item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Event item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Event> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Event item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListEventsAsync(ListEventsRequest, CallSettings)

public virtual PagedAsyncEnumerable<ListEventsResponse, Event> ListEventsAsync(ListEventsRequest request, CallSettings callSettings = null)

Lists Events in a given project and location.

Parameters
Name	Description
request	ListEventsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListEventsResponseEvent	A pageable asynchronous sequence of Event resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ListEventsRequest request = new ListEventsRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListEventsResponse, Event> response = streamsServiceClient.ListEventsAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Event item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Event item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Event> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Event item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListEventsAsync(string, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListEventsResponse, Event> ListEventsAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Events in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListEventsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListEventsResponseEvent	A pageable asynchronous sequence of Event resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
PagedAsyncEnumerable<ListEventsResponse, Event> response = streamsServiceClient.ListEventsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Event item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Event item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Event> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Event item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListSeries(ClusterName, string, int?, CallSettings)

public virtual PagedEnumerable<ListSeriesResponse, Series> ListSeries(ClusterName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Series in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Parent value for ListSeriesRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListSeriesResponseSeries	A pageable sequence of Series resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
PagedEnumerable<ListSeriesResponse, Series> response = streamsServiceClient.ListSeries(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Series item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListSeriesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Series item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Series> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Series item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListSeries(ListSeriesRequest, CallSettings)

public virtual PagedEnumerable<ListSeriesResponse, Series> ListSeries(ListSeriesRequest request, CallSettings callSettings = null)

Lists Series in a given project and location.

Parameters
Name	Description
request	ListSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListSeriesResponseSeries	A pageable sequence of Series resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ListSeriesRequest request = new ListSeriesRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedEnumerable<ListSeriesResponse, Series> response = streamsServiceClient.ListSeries(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (Series item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListSeriesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Series item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Series> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Series item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListSeries(string, string, int?, CallSettings)

public virtual PagedEnumerable<ListSeriesResponse, Series> ListSeries(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Series in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListSeriesRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListSeriesResponseSeries	A pageable sequence of Series resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
PagedEnumerable<ListSeriesResponse, Series> response = streamsServiceClient.ListSeries(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Series item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListSeriesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Series item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Series> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Series item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListSeriesAsync(ClusterName, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListSeriesResponse, Series> ListSeriesAsync(ClusterName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Series in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Parent value for ListSeriesRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListSeriesResponseSeries	A pageable asynchronous sequence of Series resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
PagedAsyncEnumerable<ListSeriesResponse, Series> response = streamsServiceClient.ListSeriesAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Series item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListSeriesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Series item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Series> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Series item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListSeriesAsync(ListSeriesRequest, CallSettings)

public virtual PagedAsyncEnumerable<ListSeriesResponse, Series> ListSeriesAsync(ListSeriesRequest request, CallSettings callSettings = null)

Lists Series in a given project and location.

Parameters
Name	Description
request	ListSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListSeriesResponseSeries	A pageable asynchronous sequence of Series resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ListSeriesRequest request = new ListSeriesRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListSeriesResponse, Series> response = streamsServiceClient.ListSeriesAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Series item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListSeriesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Series item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Series> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Series item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListSeriesAsync(string, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListSeriesResponse, Series> ListSeriesAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Series in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListSeriesRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListSeriesResponseSeries	A pageable asynchronous sequence of Series resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
PagedAsyncEnumerable<ListSeriesResponse, Series> response = streamsServiceClient.ListSeriesAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Series item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListSeriesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Series item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Series> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Series item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListStreams(ClusterName, string, int?, CallSettings)

public virtual PagedEnumerable<ListStreamsResponse, Stream> ListStreams(ClusterName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Streams in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Parent value for ListStreamsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListStreamsResponseStream	A pageable sequence of Stream resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
PagedEnumerable<ListStreamsResponse, Stream> response = streamsServiceClient.ListStreams(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Stream item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListStreamsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Stream item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Stream> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Stream item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListStreams(ListStreamsRequest, CallSettings)

public virtual PagedEnumerable<ListStreamsResponse, Stream> ListStreams(ListStreamsRequest request, CallSettings callSettings = null)

Lists Streams in a given project and location.

Parameters
Name	Description
request	ListStreamsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListStreamsResponseStream	A pageable sequence of Stream resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ListStreamsRequest request = new ListStreamsRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedEnumerable<ListStreamsResponse, Stream> response = streamsServiceClient.ListStreams(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (Stream item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListStreamsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Stream item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Stream> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Stream item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListStreams(string, string, int?, CallSettings)

public virtual PagedEnumerable<ListStreamsResponse, Stream> ListStreams(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Streams in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListStreamsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListStreamsResponseStream	A pageable sequence of Stream resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
PagedEnumerable<ListStreamsResponse, Stream> response = streamsServiceClient.ListStreams(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Stream item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListStreamsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Stream item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Stream> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Stream item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListStreamsAsync(ClusterName, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListStreamsResponse, Stream> ListStreamsAsync(ClusterName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Streams in a given project and location.

Parameters
Name	Description
parent	ClusterName Required. Parent value for ListStreamsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListStreamsResponseStream	A pageable asynchronous sequence of Stream resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
// Make the request
PagedAsyncEnumerable<ListStreamsResponse, Stream> response = streamsServiceClient.ListStreamsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Stream item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListStreamsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Stream item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Stream> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Stream item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListStreamsAsync(ListStreamsRequest, CallSettings)

public virtual PagedAsyncEnumerable<ListStreamsResponse, Stream> ListStreamsAsync(ListStreamsRequest request, CallSettings callSettings = null)

Lists Streams in a given project and location.

Parameters
Name	Description
request	ListStreamsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListStreamsResponseStream	A pageable asynchronous sequence of Stream resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ListStreamsRequest request = new ListStreamsRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    Filter = "",
    OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListStreamsResponse, Stream> response = streamsServiceClient.ListStreamsAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Stream item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListStreamsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Stream item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Stream> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Stream item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

ListStreamsAsync(string, string, int?, CallSettings)

public virtual PagedAsyncEnumerable<ListStreamsResponse, Stream> ListStreamsAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

Lists Streams in a given project and location.

Parameters
Name	Description
parent	string Required. Parent value for ListStreamsRequest.
pageToken	string The token returned from the previous request. A value of null or an empty string retrieves the first page.
pageSize	int The size of page to request. The response will not be larger than this, but may be smaller. A value of null or 0 uses a server-defined page size.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListStreamsResponseStream	A pageable asynchronous sequence of Stream resources.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
// Make the request
PagedAsyncEnumerable<ListStreamsResponse, Stream> response = streamsServiceClient.ListStreamsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await foreach (Stream item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
await foreach (ListStreamsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Stream item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Stream> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Stream item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

MaterializeChannel(ClusterName, Channel, string, CallSettings)

public virtual Operation<Channel, OperationMetadata> MaterializeChannel(ClusterName parent, Channel channel, string channelId, CallSettings callSettings = null)

Materialize a channel.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	string Required. Id of the channel.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationChannelOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Channel channel = new Channel();
string channelId = "";
// Make the request
Operation<Channel, OperationMetadata> response = streamsServiceClient.MaterializeChannel(parent, channel, channelId);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceMaterializeChannel(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannel(MaterializeChannelRequest, CallSettings)

public virtual Operation<Channel, OperationMetadata> MaterializeChannel(MaterializeChannelRequest request, CallSettings callSettings = null)

Materialize a channel.

Parameters
Name	Description
request	MaterializeChannelRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationChannelOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
MaterializeChannelRequest request = new MaterializeChannelRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    ChannelId = "",
    Channel = new Channel(),
    RequestId = "",
};
// Make the request
Operation<Channel, OperationMetadata> response = streamsServiceClient.MaterializeChannel(request);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceMaterializeChannel(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannel(string, Channel, string, CallSettings)

public virtual Operation<Channel, OperationMetadata> MaterializeChannel(string parent, Channel channel, string channelId, CallSettings callSettings = null)

Materialize a channel.

Parameters
Name	Description
parent	string Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	string Required. Id of the channel.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationChannelOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Channel channel = new Channel();
string channelId = "";
// Make the request
Operation<Channel, OperationMetadata> response = streamsServiceClient.MaterializeChannel(parent, channel, channelId);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceMaterializeChannel(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannelAsync(ClusterName, Channel, string, CallSettings)

public virtual Task<Operation<Channel, OperationMetadata>> MaterializeChannelAsync(ClusterName parent, Channel channel, string channelId, CallSettings callSettings = null)

Materialize a channel.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	string Required. Id of the channel.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationChannelOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Channel channel = new Channel();
string channelId = "";
// Make the request
Operation<Channel, OperationMetadata> response = await streamsServiceClient.MaterializeChannelAsync(parent, channel, channelId);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceMaterializeChannelAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannelAsync(ClusterName, Channel, string, CancellationToken)

public virtual Task<Operation<Channel, OperationMetadata>> MaterializeChannelAsync(ClusterName parent, Channel channel, string channelId, CancellationToken cancellationToken)

Materialize a channel.

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	string Required. Id of the channel.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationChannelOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
ClusterName parent = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]");
Channel channel = new Channel();
string channelId = "";
// Make the request
Operation<Channel, OperationMetadata> response = await streamsServiceClient.MaterializeChannelAsync(parent, channel, channelId);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceMaterializeChannelAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannelAsync(MaterializeChannelRequest, CallSettings)

public virtual Task<Operation<Channel, OperationMetadata>> MaterializeChannelAsync(MaterializeChannelRequest request, CallSettings callSettings = null)

Materialize a channel.

Parameters
Name	Description
request	MaterializeChannelRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationChannelOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
MaterializeChannelRequest request = new MaterializeChannelRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    ChannelId = "",
    Channel = new Channel(),
    RequestId = "",
};
// Make the request
Operation<Channel, OperationMetadata> response = await streamsServiceClient.MaterializeChannelAsync(request);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceMaterializeChannelAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannelAsync(MaterializeChannelRequest, CancellationToken)

public virtual Task<Operation<Channel, OperationMetadata>> MaterializeChannelAsync(MaterializeChannelRequest request, CancellationToken cancellationToken)

Materialize a channel.

Parameters
Name	Description
request	MaterializeChannelRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationChannelOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
MaterializeChannelRequest request = new MaterializeChannelRequest
{
    ParentAsClusterName = ClusterName.FromProjectLocationCluster("[PROJECT]", "[LOCATION]", "[CLUSTER]"),
    ChannelId = "",
    Channel = new Channel(),
    RequestId = "",
};
// Make the request
Operation<Channel, OperationMetadata> response = await streamsServiceClient.MaterializeChannelAsync(request);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceMaterializeChannelAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannelAsync(string, Channel, string, CallSettings)

public virtual Task<Operation<Channel, OperationMetadata>> MaterializeChannelAsync(string parent, Channel channel, string channelId, CallSettings callSettings = null)

Materialize a channel.

Parameters
Name	Description
parent	string Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	string Required. Id of the channel.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationChannelOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Channel channel = new Channel();
string channelId = "";
// Make the request
Operation<Channel, OperationMetadata> response = await streamsServiceClient.MaterializeChannelAsync(parent, channel, channelId);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceMaterializeChannelAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

MaterializeChannelAsync(string, Channel, string, CancellationToken)

public virtual Task<Operation<Channel, OperationMetadata>> MaterializeChannelAsync(string parent, Channel channel, string channelId, CancellationToken cancellationToken)

Materialize a channel.

Parameters
Name	Description
parent	string Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	string Required. Id of the channel.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationChannelOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/clusters/[CLUSTER]";
Channel channel = new Channel();
string channelId = "";
// Make the request
Operation<Channel, OperationMetadata> response = await streamsServiceClient.MaterializeChannelAsync(parent, channel, channelId);

// Poll until the returned long-running operation is complete
Operation<Channel, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Channel result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Channel, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceMaterializeChannelAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Channel retrievedResult = retrievedResponse.Result;
}

PollOnceCreateCluster(string, CallSettings)

public virtual Operation<Cluster, OperationMetadata> PollOnceCreateCluster(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of CreateCluster.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The result of polling the operation.

PollOnceCreateClusterAsync(string, CallSettings)

public virtual Task<Operation<Cluster, OperationMetadata>> PollOnceCreateClusterAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of CreateCluster.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A task representing the result of polling the operation.

PollOnceCreateEvent(string, CallSettings)

public virtual Operation<Event, OperationMetadata> PollOnceCreateEvent(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of CreateEvent.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEventOperationMetadata	The result of polling the operation.

PollOnceCreateEventAsync(string, CallSettings)

public virtual Task<Operation<Event, OperationMetadata>> PollOnceCreateEventAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of CreateEvent.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEventOperationMetadata	A task representing the result of polling the operation.

PollOnceCreateSeries(string, CallSettings)

public virtual Operation<Series, OperationMetadata> PollOnceCreateSeries(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of CreateSeries.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationSeriesOperationMetadata	The result of polling the operation.

PollOnceCreateSeriesAsync(string, CallSettings)

public virtual Task<Operation<Series, OperationMetadata>> PollOnceCreateSeriesAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of CreateSeries.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A task representing the result of polling the operation.

PollOnceCreateStream(string, CallSettings)

public virtual Operation<Stream, OperationMetadata> PollOnceCreateStream(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of CreateStream.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationStreamOperationMetadata	The result of polling the operation.

PollOnceCreateStreamAsync(string, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> PollOnceCreateStreamAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of CreateStream.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A task representing the result of polling the operation.

PollOnceDeleteCluster(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> PollOnceDeleteCluster(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of DeleteCluster.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The result of polling the operation.

PollOnceDeleteClusterAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> PollOnceDeleteClusterAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of DeleteCluster.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A task representing the result of polling the operation.

PollOnceDeleteEvent(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> PollOnceDeleteEvent(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of DeleteEvent.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The result of polling the operation.

PollOnceDeleteEventAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> PollOnceDeleteEventAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of DeleteEvent.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A task representing the result of polling the operation.

PollOnceDeleteSeries(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> PollOnceDeleteSeries(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of DeleteSeries.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The result of polling the operation.

PollOnceDeleteSeriesAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> PollOnceDeleteSeriesAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of DeleteSeries.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A task representing the result of polling the operation.

PollOnceDeleteStream(string, CallSettings)

public virtual Operation<Empty, OperationMetadata> PollOnceDeleteStream(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of DeleteStream.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The result of polling the operation.

PollOnceDeleteStreamAsync(string, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> PollOnceDeleteStreamAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of DeleteStream.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A task representing the result of polling the operation.

PollOnceGetStreamThumbnail(string, CallSettings)

public virtual Operation<GetStreamThumbnailResponse, OperationMetadata> PollOnceGetStreamThumbnail(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of GetStreamThumbnail .

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationGetStreamThumbnailResponseOperationMetadata	The result of polling the operation.

PollOnceGetStreamThumbnailAsync(string, CallSettings)

public virtual Task<Operation<GetStreamThumbnailResponse, OperationMetadata>> PollOnceGetStreamThumbnailAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of GetStreamThumbnail.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationGetStreamThumbnailResponseOperationMetadata	A task representing the result of polling the operation.

PollOnceMaterializeChannel(string, CallSettings)

public virtual Operation<Channel, OperationMetadata> PollOnceMaterializeChannel(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of MaterializeChannel .

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationChannelOperationMetadata	The result of polling the operation.

PollOnceMaterializeChannelAsync(string, CallSettings)

public virtual Task<Operation<Channel, OperationMetadata>> PollOnceMaterializeChannelAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of MaterializeChannel.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationChannelOperationMetadata	A task representing the result of polling the operation.

PollOnceUpdateCluster(string, CallSettings)

public virtual Operation<Cluster, OperationMetadata> PollOnceUpdateCluster(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of UpdateCluster.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The result of polling the operation.

PollOnceUpdateClusterAsync(string, CallSettings)

public virtual Task<Operation<Cluster, OperationMetadata>> PollOnceUpdateClusterAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of UpdateCluster.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A task representing the result of polling the operation.

PollOnceUpdateEvent(string, CallSettings)

public virtual Operation<Event, OperationMetadata> PollOnceUpdateEvent(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of UpdateEvent.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEventOperationMetadata	The result of polling the operation.

PollOnceUpdateEventAsync(string, CallSettings)

public virtual Task<Operation<Event, OperationMetadata>> PollOnceUpdateEventAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of UpdateEvent.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEventOperationMetadata	A task representing the result of polling the operation.

PollOnceUpdateSeries(string, CallSettings)

public virtual Operation<Series, OperationMetadata> PollOnceUpdateSeries(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of UpdateSeries.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationSeriesOperationMetadata	The result of polling the operation.

PollOnceUpdateSeriesAsync(string, CallSettings)

public virtual Task<Operation<Series, OperationMetadata>> PollOnceUpdateSeriesAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of UpdateSeries.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A task representing the result of polling the operation.

PollOnceUpdateStream(string, CallSettings)

public virtual Operation<Stream, OperationMetadata> PollOnceUpdateStream(string operationName, CallSettings callSettings = null)

Poll an operation once, using an operationName from a previous invocation of UpdateStream.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationStreamOperationMetadata	The result of polling the operation.

PollOnceUpdateStreamAsync(string, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> PollOnceUpdateStreamAsync(string operationName, CallSettings callSettings = null)

Asynchronously poll an operation once, using an operationName from a previous invocation of UpdateStream.

Parameters
Name	Description
operationName	string The name of a previously invoked operation. Must not be null or empty.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A task representing the result of polling the operation.

ShutdownDefaultChannelsAsync()

public static Task ShutdownDefaultChannelsAsync()

Shuts down any channels automatically created by Create() and CreateAsync(CancellationToken). Channels which weren't automatically created are not affected.

Returns
Type	Description
Task	A task representing the asynchronous shutdown operation.

Remarks

After calling this method, further calls to Create() and CreateAsync(CancellationToken) will create new channels, which could in turn be shut down by another call to this method.

UpdateCluster(Cluster, FieldMask, CallSettings)

public virtual Operation<Cluster, OperationMetadata> UpdateCluster(Cluster cluster, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Cluster.

Parameters
Name	Description
cluster	Cluster Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Cluster resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
Cluster cluster = new Cluster();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Cluster, OperationMetadata> response = streamsServiceClient.UpdateCluster(cluster, updateMask);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

UpdateCluster(UpdateClusterRequest, CallSettings)

public virtual Operation<Cluster, OperationMetadata> UpdateCluster(UpdateClusterRequest request, CallSettings callSettings = null)

Updates the parameters of a single Cluster.

Parameters
Name	Description
request	UpdateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
UpdateClusterRequest request = new UpdateClusterRequest
{
    UpdateMask = new FieldMask(),
    Cluster = new Cluster(),
    RequestId = "",
};
// Make the request
Operation<Cluster, OperationMetadata> response = streamsServiceClient.UpdateCluster(request);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateCluster(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

UpdateClusterAsync(Cluster, FieldMask, CallSettings)

public virtual Task<Operation<Cluster, OperationMetadata>> UpdateClusterAsync(Cluster cluster, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Cluster.

Parameters
Name	Description
cluster	Cluster Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Cluster resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Cluster cluster = new Cluster();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.UpdateClusterAsync(cluster, updateMask);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

UpdateClusterAsync(Cluster, FieldMask, CancellationToken)

public virtual Task<Operation<Cluster, OperationMetadata>> UpdateClusterAsync(Cluster cluster, FieldMask updateMask, CancellationToken cancellationToken)

Updates the parameters of a single Cluster.

Parameters
Name	Description
cluster	Cluster Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Cluster resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Cluster cluster = new Cluster();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.UpdateClusterAsync(cluster, updateMask);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

UpdateClusterAsync(UpdateClusterRequest, CallSettings)

public virtual Task<Operation<Cluster, OperationMetadata>> UpdateClusterAsync(UpdateClusterRequest request, CallSettings callSettings = null)

Updates the parameters of a single Cluster.

Parameters
Name	Description
request	UpdateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateClusterRequest request = new UpdateClusterRequest
{
    UpdateMask = new FieldMask(),
    Cluster = new Cluster(),
    RequestId = "",
};
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.UpdateClusterAsync(request);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

UpdateClusterAsync(UpdateClusterRequest, CancellationToken)

public virtual Task<Operation<Cluster, OperationMetadata>> UpdateClusterAsync(UpdateClusterRequest request, CancellationToken cancellationToken)

Updates the parameters of a single Cluster.

Parameters
Name	Description
request	UpdateClusterRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateClusterRequest request = new UpdateClusterRequest
{
    UpdateMask = new FieldMask(),
    Cluster = new Cluster(),
    RequestId = "",
};
// Make the request
Operation<Cluster, OperationMetadata> response = await streamsServiceClient.UpdateClusterAsync(request);

// Poll until the returned long-running operation is complete
Operation<Cluster, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Cluster result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Cluster, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateClusterAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Cluster retrievedResult = retrievedResponse.Result;
}

UpdateEvent(Event, FieldMask, CallSettings)

public virtual Operation<Event, OperationMetadata> UpdateEvent(Event @event, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
event	Event Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Event resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEventOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
Event @event = new Event();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Event, OperationMetadata> response = streamsServiceClient.UpdateEvent(@event, updateMask);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

UpdateEvent(UpdateEventRequest, CallSettings)

public virtual Operation<Event, OperationMetadata> UpdateEvent(UpdateEventRequest request, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
request	UpdateEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEventOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
UpdateEventRequest request = new UpdateEventRequest
{
    UpdateMask = new FieldMask(),
    Event = new Event(),
    RequestId = "",
};
// Make the request
Operation<Event, OperationMetadata> response = streamsServiceClient.UpdateEvent(request);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateEvent(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

UpdateEventAsync(Event, FieldMask, CallSettings)

public virtual Task<Operation<Event, OperationMetadata>> UpdateEventAsync(Event @event, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
event	Event Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Event resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Event @event = new Event();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.UpdateEventAsync(@event, updateMask);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

UpdateEventAsync(Event, FieldMask, CancellationToken)

public virtual Task<Operation<Event, OperationMetadata>> UpdateEventAsync(Event @event, FieldMask updateMask, CancellationToken cancellationToken)

Updates the parameters of a single Event.

Parameters
Name	Description
event	Event Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Event resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Event @event = new Event();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.UpdateEventAsync(@event, updateMask);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

UpdateEventAsync(UpdateEventRequest, CallSettings)

public virtual Task<Operation<Event, OperationMetadata>> UpdateEventAsync(UpdateEventRequest request, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
request	UpdateEventRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateEventRequest request = new UpdateEventRequest
{
    UpdateMask = new FieldMask(),
    Event = new Event(),
    RequestId = "",
};
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.UpdateEventAsync(request);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

UpdateEventAsync(UpdateEventRequest, CancellationToken)

public virtual Task<Operation<Event, OperationMetadata>> UpdateEventAsync(UpdateEventRequest request, CancellationToken cancellationToken)

Updates the parameters of a single Event.

Parameters
Name	Description
request	UpdateEventRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationEventOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateEventRequest request = new UpdateEventRequest
{
    UpdateMask = new FieldMask(),
    Event = new Event(),
    RequestId = "",
};
// Make the request
Operation<Event, OperationMetadata> response = await streamsServiceClient.UpdateEventAsync(request);

// Poll until the returned long-running operation is complete
Operation<Event, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Event result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Event, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateEventAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Event retrievedResult = retrievedResponse.Result;
}

UpdateSeries(Series, FieldMask, CallSettings)

public virtual Operation<Series, OperationMetadata> UpdateSeries(Series series, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
series	Series Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Series resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationSeriesOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
Series series = new Series();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Series, OperationMetadata> response = streamsServiceClient.UpdateSeries(series, updateMask);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

UpdateSeries(UpdateSeriesRequest, CallSettings)

public virtual Operation<Series, OperationMetadata> UpdateSeries(UpdateSeriesRequest request, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
request	UpdateSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationSeriesOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
UpdateSeriesRequest request = new UpdateSeriesRequest
{
    UpdateMask = new FieldMask(),
    Series = new Series(),
    RequestId = "",
};
// Make the request
Operation<Series, OperationMetadata> response = streamsServiceClient.UpdateSeries(request);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateSeries(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

UpdateSeriesAsync(Series, FieldMask, CallSettings)

public virtual Task<Operation<Series, OperationMetadata>> UpdateSeriesAsync(Series series, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
series	Series Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Series resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Series series = new Series();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.UpdateSeriesAsync(series, updateMask);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

UpdateSeriesAsync(Series, FieldMask, CancellationToken)

public virtual Task<Operation<Series, OperationMetadata>> UpdateSeriesAsync(Series series, FieldMask updateMask, CancellationToken cancellationToken)

Updates the parameters of a single Event.

Parameters
Name	Description
series	Series Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Series resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Series series = new Series();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.UpdateSeriesAsync(series, updateMask);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

UpdateSeriesAsync(UpdateSeriesRequest, CallSettings)

public virtual Task<Operation<Series, OperationMetadata>> UpdateSeriesAsync(UpdateSeriesRequest request, CallSettings callSettings = null)

Updates the parameters of a single Event.

Parameters
Name	Description
request	UpdateSeriesRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateSeriesRequest request = new UpdateSeriesRequest
{
    UpdateMask = new FieldMask(),
    Series = new Series(),
    RequestId = "",
};
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.UpdateSeriesAsync(request);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

UpdateSeriesAsync(UpdateSeriesRequest, CancellationToken)

public virtual Task<Operation<Series, OperationMetadata>> UpdateSeriesAsync(UpdateSeriesRequest request, CancellationToken cancellationToken)

Updates the parameters of a single Event.

Parameters
Name	Description
request	UpdateSeriesRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationSeriesOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateSeriesRequest request = new UpdateSeriesRequest
{
    UpdateMask = new FieldMask(),
    Series = new Series(),
    RequestId = "",
};
// Make the request
Operation<Series, OperationMetadata> response = await streamsServiceClient.UpdateSeriesAsync(request);

// Poll until the returned long-running operation is complete
Operation<Series, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Series result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Series, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateSeriesAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Series retrievedResult = retrievedResponse.Result;
}

UpdateStream(Stream, FieldMask, CallSettings)

public virtual Operation<Stream, OperationMetadata> UpdateStream(Stream stream, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Stream.

Parameters
Name	Description
stream	Stream Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Stream resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationStreamOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
Stream stream = new Stream();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Stream, OperationMetadata> response = streamsServiceClient.UpdateStream(stream, updateMask);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

UpdateStream(UpdateStreamRequest, CallSettings)

public virtual Operation<Stream, OperationMetadata> UpdateStream(UpdateStreamRequest request, CallSettings callSettings = null)

Updates the parameters of a single Stream.

Parameters
Name	Description
request	UpdateStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationStreamOperationMetadata	The RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = StreamsServiceClient.Create();
// Initialize request argument(s)
UpdateStreamRequest request = new UpdateStreamRequest
{
    UpdateMask = new FieldMask(),
    Stream = new Stream(),
    RequestId = "",
};
// Make the request
Operation<Stream, OperationMetadata> response = streamsServiceClient.UpdateStream(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = streamsServiceClient.PollOnceUpdateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

UpdateStreamAsync(Stream, FieldMask, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> UpdateStreamAsync(Stream stream, FieldMask updateMask, CallSettings callSettings = null)

Updates the parameters of a single Stream.

Parameters
Name	Description
stream	Stream Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Stream resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Stream stream = new Stream();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.UpdateStreamAsync(stream, updateMask);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

UpdateStreamAsync(Stream, FieldMask, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> UpdateStreamAsync(Stream stream, FieldMask updateMask, CancellationToken cancellationToken)

Updates the parameters of a single Stream.

Parameters
Name	Description
stream	Stream Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Stream resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
Stream stream = new Stream();
FieldMask updateMask = new FieldMask();
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.UpdateStreamAsync(stream, updateMask);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

UpdateStreamAsync(UpdateStreamRequest, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> UpdateStreamAsync(UpdateStreamRequest request, CallSettings callSettings = null)

Updates the parameters of a single Stream.

Parameters
Name	Description
request	UpdateStreamRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateStreamRequest request = new UpdateStreamRequest
{
    UpdateMask = new FieldMask(),
    Stream = new Stream(),
    RequestId = "",
};
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.UpdateStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

UpdateStreamAsync(UpdateStreamRequest, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> UpdateStreamAsync(UpdateStreamRequest request, CancellationToken cancellationToken)

Updates the parameters of a single Stream.

Parameters
Name	Description
request	UpdateStreamRequest The request object containing all of the parameters for the API call.
cancellationToken	CancellationToken A CancellationToken to use for this RPC.

Returns
Type	Description
TaskOperationStreamOperationMetadata	A Task containing the RPC response.

Example

// Create client
StreamsServiceClient streamsServiceClient = await StreamsServiceClient.CreateAsync();
// Initialize request argument(s)
UpdateStreamRequest request = new UpdateStreamRequest
{
    UpdateMask = new FieldMask(),
    Stream = new Stream(),
    RequestId = "",
};
// Make the request
Operation<Stream, OperationMetadata> response = await streamsServiceClient.UpdateStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await streamsServiceClient.PollOnceUpdateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}