public abstract class DatastreamClient
Datastream client wrapper, for convenient use.
Derived Types
Namespace
Google.Cloud.Datastream.V1Assembly
Google.Cloud.Datastream.V1.dll
Remarks
Datastream service
Properties
CreateConnectionProfileOperationsClient
public virtual OperationsClient CreateConnectionProfileOperationsClient { get; }
The long-running operations client for CreateConnectionProfile
.
Property Value | |
---|---|
Type | Description |
OperationsClient |
CreatePrivateConnectionOperationsClient
public virtual OperationsClient CreatePrivateConnectionOperationsClient { get; }
The long-running operations client for CreatePrivateConnection
.
Property Value | |
---|---|
Type | Description |
OperationsClient |
CreateRouteOperationsClient
public virtual OperationsClient CreateRouteOperationsClient { get; }
The long-running operations client for CreateRoute
.
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 Datastream service, which is a host of "datastream.googleapis.com" and a port of 443.
Property Value | |
---|---|
Type | Description |
String |
DefaultScopes
public static IReadOnlyList<string> DefaultScopes { get; }
The default Datastream scopes.
Property Value | |
---|---|
Type | Description |
IReadOnlyList<String> |
The default Datastream scopes are:
DeleteConnectionProfileOperationsClient
public virtual OperationsClient DeleteConnectionProfileOperationsClient { get; }
The long-running operations client for DeleteConnectionProfile
.
Property Value | |
---|---|
Type | Description |
OperationsClient |
DeletePrivateConnectionOperationsClient
public virtual OperationsClient DeletePrivateConnectionOperationsClient { get; }
The long-running operations client for DeletePrivateConnection
.
Property Value | |
---|---|
Type | Description |
OperationsClient |
DeleteRouteOperationsClient
public virtual OperationsClient DeleteRouteOperationsClient { get; }
The long-running operations client for DeleteRoute
.
Property Value | |
---|---|
Type | Description |
OperationsClient |
DeleteStreamOperationsClient
public virtual OperationsClient DeleteStreamOperationsClient { get; }
The long-running operations client for DeleteStream
.
Property Value | |
---|---|
Type | Description |
OperationsClient |
GrpcClient
public virtual Datastream.DatastreamClient GrpcClient { get; }
The underlying gRPC Datastream client
Property Value | |
---|---|
Type | Description |
Datastream.DatastreamClient |
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 |
ServiceMetadata
public static ServiceMetadata ServiceMetadata { get; }
The service metadata associated with this client type.
Property Value | |
---|---|
Type | Description |
ServiceMetadata |
UpdateConnectionProfileOperationsClient
public virtual OperationsClient UpdateConnectionProfileOperationsClient { get; }
The long-running operations client for UpdateConnectionProfile
.
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 DatastreamClient Create()
Synchronously creates a DatastreamClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use DatastreamClientBuilder.
Returns | |
---|---|
Type | Description |
DatastreamClient | The created DatastreamClient. |
CreateAsync(CancellationToken)
public static Task<DatastreamClient> CreateAsync(CancellationToken cancellationToken = default(CancellationToken))
Asynchronously creates a DatastreamClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use DatastreamClientBuilder.
Parameter | |
---|---|
Name | Description |
cancellationToken | CancellationToken The CancellationToken to use while creating the client. |
Returns | |
---|---|
Type | Description |
Task<DatastreamClient> | The task representing the created DatastreamClient. |
CreateConnectionProfile(LocationName, ConnectionProfile, String, CallSettings)
public virtual Operation<ConnectionProfile, OperationMetadata> CreateConnectionProfile(LocationName parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of ConnectionProfiles. |
connectionProfile | ConnectionProfile Required. The connection profile resource to create. |
connectionProfileId | String Required. The connection profile identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<ConnectionProfile, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = datastreamClient.CreateConnectionProfile(parent, connectionProfile, connectionProfileId);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfile(CreateConnectionProfileRequest, CallSettings)
public virtual Operation<ConnectionProfile, OperationMetadata> CreateConnectionProfile(CreateConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
request | CreateConnectionProfileRequest 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 |
Operation<ConnectionProfile, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreateConnectionProfileRequest request = new CreateConnectionProfileRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
ConnectionProfileId = "",
ConnectionProfile = new ConnectionProfile(),
RequestId = "",
ValidateOnly = false,
Force = false,
};
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = datastreamClient.CreateConnectionProfile(request);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfile(String, ConnectionProfile, String, CallSettings)
public virtual Operation<ConnectionProfile, OperationMetadata> CreateConnectionProfile(string parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of ConnectionProfiles. |
connectionProfile | ConnectionProfile Required. The connection profile resource to create. |
connectionProfileId | String Required. The connection profile identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<ConnectionProfile, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = datastreamClient.CreateConnectionProfile(parent, connectionProfile, connectionProfileId);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfileAsync(LocationName, ConnectionProfile, String, CallSettings)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(LocationName parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of ConnectionProfiles. |
connectionProfile | ConnectionProfile Required. The connection profile resource to create. |
connectionProfileId | String Required. The connection profile identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<ConnectionProfile, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfileAsync(LocationName, ConnectionProfile, String, CancellationToken)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(LocationName parent, ConnectionProfile connectionProfile, string connectionProfileId, CancellationToken cancellationToken)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of ConnectionProfiles. |
connectionProfile | ConnectionProfile Required. The connection profile resource to create. |
connectionProfileId | String Required. The connection profile identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<ConnectionProfile, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfileAsync(CreateConnectionProfileRequest, CallSettings)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(CreateConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
request | CreateConnectionProfileRequest 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 |
Task<Operation<ConnectionProfile, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateConnectionProfileRequest request = new CreateConnectionProfileRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
ConnectionProfileId = "",
ConnectionProfile = new ConnectionProfile(),
RequestId = "",
ValidateOnly = false,
Force = false,
};
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(request);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfileAsync(CreateConnectionProfileRequest, CancellationToken)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(CreateConnectionProfileRequest request, CancellationToken cancellationToken)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
request | CreateConnectionProfileRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<ConnectionProfile, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateConnectionProfileRequest request = new CreateConnectionProfileRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
ConnectionProfileId = "",
ConnectionProfile = new ConnectionProfile(),
RequestId = "",
ValidateOnly = false,
Force = false,
};
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(request);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfileAsync(String, ConnectionProfile, String, CallSettings)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(string parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of ConnectionProfiles. |
connectionProfile | ConnectionProfile Required. The connection profile resource to create. |
connectionProfileId | String Required. The connection profile identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<ConnectionProfile, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreateConnectionProfileAsync(String, ConnectionProfile, String, CancellationToken)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(string parent, ConnectionProfile connectionProfile, string connectionProfileId, CancellationToken cancellationToken)
Use this method to create a connection profile in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of ConnectionProfiles. |
connectionProfile | ConnectionProfile Required. The connection profile resource to create. |
connectionProfileId | String Required. The connection profile identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<ConnectionProfile, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);
// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile 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<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
ConnectionProfile retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnection(LocationName, PrivateConnection, String, CallSettings)
public virtual Operation<PrivateConnection, OperationMetadata> CreatePrivateConnection(LocationName parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of PrivateConnections. |
privateConnection | PrivateConnection Required. The Private Connectivity resource to create. |
privateConnectionId | String Required. The private connectivity identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<PrivateConnection, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = datastreamClient.CreatePrivateConnection(parent, privateConnection, privateConnectionId);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreatePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnection(CreatePrivateConnectionRequest, CallSettings)
public virtual Operation<PrivateConnection, OperationMetadata> CreatePrivateConnection(CreatePrivateConnectionRequest request, CallSettings callSettings = null)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | CreatePrivateConnectionRequest 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 |
Operation<PrivateConnection, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreatePrivateConnectionRequest request = new CreatePrivateConnectionRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
PrivateConnectionId = "",
PrivateConnection = new PrivateConnection(),
RequestId = "",
};
// Make the request
Operation<PrivateConnection, OperationMetadata> response = datastreamClient.CreatePrivateConnection(request);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreatePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnection(String, PrivateConnection, String, CallSettings)
public virtual Operation<PrivateConnection, OperationMetadata> CreatePrivateConnection(string parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of PrivateConnections. |
privateConnection | PrivateConnection Required. The Private Connectivity resource to create. |
privateConnectionId | String Required. The private connectivity identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<PrivateConnection, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = datastreamClient.CreatePrivateConnection(parent, privateConnection, privateConnectionId);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreatePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnectionAsync(LocationName, PrivateConnection, String, CallSettings)
public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(LocationName parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of PrivateConnections. |
privateConnection | PrivateConnection Required. The Private Connectivity resource to create. |
privateConnectionId | String Required. The private connectivity identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<PrivateConnection, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnectionAsync(LocationName, PrivateConnection, String, CancellationToken)
public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(LocationName parent, PrivateConnection privateConnection, string privateConnectionId, CancellationToken cancellationToken)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of PrivateConnections. |
privateConnection | PrivateConnection Required. The Private Connectivity resource to create. |
privateConnectionId | String Required. The private connectivity identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<PrivateConnection, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnectionAsync(CreatePrivateConnectionRequest, CallSettings)
public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(CreatePrivateConnectionRequest request, CallSettings callSettings = null)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | CreatePrivateConnectionRequest 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 |
Task<Operation<PrivateConnection, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreatePrivateConnectionRequest request = new CreatePrivateConnectionRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
PrivateConnectionId = "",
PrivateConnection = new PrivateConnection(),
RequestId = "",
};
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(request);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnectionAsync(CreatePrivateConnectionRequest, CancellationToken)
public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(CreatePrivateConnectionRequest request, CancellationToken cancellationToken)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | CreatePrivateConnectionRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<PrivateConnection, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreatePrivateConnectionRequest request = new CreatePrivateConnectionRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
PrivateConnectionId = "",
PrivateConnection = new PrivateConnection(),
RequestId = "",
};
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(request);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnectionAsync(String, PrivateConnection, String, CallSettings)
public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(string parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of PrivateConnections. |
privateConnection | PrivateConnection Required. The Private Connectivity resource to create. |
privateConnectionId | String Required. The private connectivity identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<PrivateConnection, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreatePrivateConnectionAsync(String, PrivateConnection, String, CancellationToken)
public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(string parent, PrivateConnection privateConnection, string privateConnectionId, CancellationToken cancellationToken)
Use this method to create a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of PrivateConnections. |
privateConnection | PrivateConnection Required. The Private Connectivity resource to create. |
privateConnectionId | String Required. The private connectivity identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<PrivateConnection, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);
// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection 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<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
PrivateConnection retrievedResult = retrievedResponse.Result;
}
CreateRoute(CreateRouteRequest, CallSettings)
public virtual Operation<Route, OperationMetadata> CreateRoute(CreateRouteRequest request, CallSettings callSettings = null)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
request | CreateRouteRequest 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 |
Operation<Route, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreateRouteRequest request = new CreateRouteRequest
{
ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
RouteId = "",
Route = new Route(),
RequestId = "",
};
// Make the request
Operation<Route, OperationMetadata> response = datastreamClient.CreateRoute(request);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRoute(PrivateConnectionName, Route, String, CallSettings)
public virtual Operation<Route, OperationMetadata> CreateRoute(PrivateConnectionName parent, Route route, string routeId, CallSettings callSettings = null)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | PrivateConnectionName Required. The parent that owns the collection of Routes. |
route | Route Required. The Route resource to create. |
routeId | String Required. The Route identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Route, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = datastreamClient.CreateRoute(parent, route, routeId);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRoute(String, Route, String, CallSettings)
public virtual Operation<Route, OperationMetadata> CreateRoute(string parent, Route route, string routeId, CallSettings callSettings = null)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of Routes. |
route | Route Required. The Route resource to create. |
routeId | String Required. The Route identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Route, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = datastreamClient.CreateRoute(parent, route, routeId);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRouteAsync(CreateRouteRequest, CallSettings)
public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(CreateRouteRequest request, CallSettings callSettings = null)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
request | CreateRouteRequest 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 |
Task<Operation<Route, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateRouteRequest request = new CreateRouteRequest
{
ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
RouteId = "",
Route = new Route(),
RequestId = "",
};
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(request);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRouteAsync(CreateRouteRequest, CancellationToken)
public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(CreateRouteRequest request, CancellationToken cancellationToken)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
request | CreateRouteRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Route, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateRouteRequest request = new CreateRouteRequest
{
ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
RouteId = "",
Route = new Route(),
RequestId = "",
};
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(request);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRouteAsync(PrivateConnectionName, Route, String, CallSettings)
public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(PrivateConnectionName parent, Route route, string routeId, CallSettings callSettings = null)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | PrivateConnectionName Required. The parent that owns the collection of Routes. |
route | Route Required. The Route resource to create. |
routeId | String Required. The Route identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Route, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRouteAsync(PrivateConnectionName, Route, String, CancellationToken)
public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(PrivateConnectionName parent, Route route, string routeId, CancellationToken cancellationToken)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | PrivateConnectionName Required. The parent that owns the collection of Routes. |
route | Route Required. The Route resource to create. |
routeId | String Required. The Route identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Route, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRouteAsync(String, Route, String, CallSettings)
public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(string parent, Route route, string routeId, CallSettings callSettings = null)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of Routes. |
route | Route Required. The Route resource to create. |
routeId | String Required. The Route identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Route, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateRouteAsync(String, Route, String, CancellationToken)
public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(string parent, Route route, string routeId, CancellationToken cancellationToken)
Use this method to create a route for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of Routes. |
route | Route Required. The Route resource to create. |
routeId | String Required. The Route identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Route, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);
// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route 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<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Route retrievedResult = retrievedResponse.Result;
}
CreateStream(LocationName, Stream, String, CallSettings)
public virtual Operation<Stream, OperationMetadata> CreateStream(LocationName parent, Stream stream, string streamId, CallSettings callSettings = null)
Use this method to create a stream.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of streams. |
stream | Stream Required. The stream resource to create. |
streamId | String Required. The stream identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Stream, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = datastreamClient.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 = datastreamClient.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)
Use this method to create a stream.
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 |
Operation<Stream, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
StreamId = "",
Stream = new Stream(),
RequestId = "",
ValidateOnly = false,
Force = false,
};
// Make the request
Operation<Stream, OperationMetadata> response = datastreamClient.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 = datastreamClient.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)
Use this method to create a stream.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of streams. |
stream | Stream Required. The stream resource to create. |
streamId | String Required. The stream identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Stream, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = datastreamClient.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 = datastreamClient.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(LocationName, Stream, String, CallSettings)
public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(LocationName parent, Stream stream, string streamId, CallSettings callSettings = null)
Use this method to create a stream.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of streams. |
stream | Stream Required. The stream resource to create. |
streamId | String Required. The stream identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Stream, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.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 datastreamClient.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(LocationName, Stream, String, CancellationToken)
public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(LocationName parent, Stream stream, string streamId, CancellationToken cancellationToken)
Use this method to create a stream.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of streams. |
stream | Stream Required. The stream resource to create. |
streamId | String Required. The stream identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Stream, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to create a stream.
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 |
Task<Operation<Stream, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
StreamId = "",
Stream = new Stream(),
RequestId = "",
ValidateOnly = false,
Force = false,
};
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to create a stream.
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 |
Task<Operation<Stream, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
StreamId = "",
Stream = new Stream(),
RequestId = "",
ValidateOnly = false,
Force = false,
};
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to create a stream.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of streams. |
stream | Stream Required. The stream resource to create. |
streamId | String Required. The stream identifier. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Stream, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to create a stream.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of streams. |
stream | Stream Required. The stream resource to create. |
streamId | String Required. The stream identifier. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Stream, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.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 datastreamClient.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;
}
DeleteConnectionProfile(ConnectionProfileName, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeleteConnectionProfile(ConnectionProfileName name, CallSettings callSettings = null)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
name | ConnectionProfileName Required. The name of the connection profile resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteConnectionProfile(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 = datastreamClient.PollOnceDeleteConnectionProfile(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;
}
DeleteConnectionProfile(DeleteConnectionProfileRequest, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeleteConnectionProfile(DeleteConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
request | DeleteConnectionProfileRequest 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 |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeleteConnectionProfileRequest request = new DeleteConnectionProfileRequest
{
ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteConnectionProfile(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 = datastreamClient.PollOnceDeleteConnectionProfile(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;
}
DeleteConnectionProfile(String, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeleteConnectionProfile(string name, CallSettings callSettings = null)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the connection profile resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteConnectionProfile(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 = datastreamClient.PollOnceDeleteConnectionProfile(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;
}
DeleteConnectionProfileAsync(ConnectionProfileName, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(ConnectionProfileName name, CallSettings callSettings = null)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
name | ConnectionProfileName Required. The name of the connection profile resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(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 datastreamClient.PollOnceDeleteConnectionProfileAsync(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;
}
DeleteConnectionProfileAsync(ConnectionProfileName, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(ConnectionProfileName name, CancellationToken cancellationToken)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
name | ConnectionProfileName Required. The name of the connection profile resource to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(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 datastreamClient.PollOnceDeleteConnectionProfileAsync(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;
}
DeleteConnectionProfileAsync(DeleteConnectionProfileRequest, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(DeleteConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
request | DeleteConnectionProfileRequest 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 |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteConnectionProfileRequest request = new DeleteConnectionProfileRequest
{
ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(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 datastreamClient.PollOnceDeleteConnectionProfileAsync(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;
}
DeleteConnectionProfileAsync(DeleteConnectionProfileRequest, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(DeleteConnectionProfileRequest request, CancellationToken cancellationToken)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
request | DeleteConnectionProfileRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteConnectionProfileRequest request = new DeleteConnectionProfileRequest
{
ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(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 datastreamClient.PollOnceDeleteConnectionProfileAsync(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;
}
DeleteConnectionProfileAsync(String, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(string name, CallSettings callSettings = null)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the connection profile resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(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 datastreamClient.PollOnceDeleteConnectionProfileAsync(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;
}
DeleteConnectionProfileAsync(String, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(string name, CancellationToken cancellationToken)
Use this method to delete a connection profile.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the connection profile resource to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(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 datastreamClient.PollOnceDeleteConnectionProfileAsync(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;
}
DeletePrivateConnection(DeletePrivateConnectionRequest, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeletePrivateConnection(DeletePrivateConnectionRequest request, CallSettings callSettings = null)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | DeletePrivateConnectionRequest 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 |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeletePrivateConnectionRequest request = new DeletePrivateConnectionRequest
{
PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
RequestId = "",
Force = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeletePrivateConnection(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 = datastreamClient.PollOnceDeletePrivateConnection(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;
}
DeletePrivateConnection(PrivateConnectionName, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeletePrivateConnection(PrivateConnectionName name, CallSettings callSettings = null)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | PrivateConnectionName Required. The name of the private connectivity configuration to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeletePrivateConnection(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 = datastreamClient.PollOnceDeletePrivateConnection(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;
}
DeletePrivateConnection(String, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeletePrivateConnection(string name, CallSettings callSettings = null)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the private connectivity configuration to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeletePrivateConnection(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 = datastreamClient.PollOnceDeletePrivateConnection(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;
}
DeletePrivateConnectionAsync(DeletePrivateConnectionRequest, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(DeletePrivateConnectionRequest request, CallSettings callSettings = null)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | DeletePrivateConnectionRequest 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 |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeletePrivateConnectionRequest request = new DeletePrivateConnectionRequest
{
PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
RequestId = "",
Force = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(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 datastreamClient.PollOnceDeletePrivateConnectionAsync(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;
}
DeletePrivateConnectionAsync(DeletePrivateConnectionRequest, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(DeletePrivateConnectionRequest request, CancellationToken cancellationToken)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | DeletePrivateConnectionRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeletePrivateConnectionRequest request = new DeletePrivateConnectionRequest
{
PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
RequestId = "",
Force = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(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 datastreamClient.PollOnceDeletePrivateConnectionAsync(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;
}
DeletePrivateConnectionAsync(PrivateConnectionName, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(PrivateConnectionName name, CallSettings callSettings = null)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | PrivateConnectionName Required. The name of the private connectivity configuration to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(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 datastreamClient.PollOnceDeletePrivateConnectionAsync(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;
}
DeletePrivateConnectionAsync(PrivateConnectionName, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(PrivateConnectionName name, CancellationToken cancellationToken)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | PrivateConnectionName Required. The name of the private connectivity configuration to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(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 datastreamClient.PollOnceDeletePrivateConnectionAsync(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;
}
DeletePrivateConnectionAsync(String, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(string name, CallSettings callSettings = null)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the private connectivity configuration to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(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 datastreamClient.PollOnceDeletePrivateConnectionAsync(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;
}
DeletePrivateConnectionAsync(String, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(string name, CancellationToken cancellationToken)
Use this method to delete a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the private connectivity configuration to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(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 datastreamClient.PollOnceDeletePrivateConnectionAsync(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;
}
DeleteRoute(DeleteRouteRequest, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeleteRoute(DeleteRouteRequest request, CallSettings callSettings = null)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
request | DeleteRouteRequest 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 |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeleteRouteRequest request = new DeleteRouteRequest
{
RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteRoute(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 = datastreamClient.PollOnceDeleteRoute(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;
}
DeleteRoute(RouteName, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeleteRoute(RouteName name, CallSettings callSettings = null)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
name | RouteName Required. The name of the Route resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteRoute(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 = datastreamClient.PollOnceDeleteRoute(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;
}
DeleteRoute(String, CallSettings)
public virtual Operation<Empty, OperationMetadata> DeleteRoute(string name, CallSettings callSettings = null)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the Route resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteRoute(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 = datastreamClient.PollOnceDeleteRoute(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;
}
DeleteRouteAsync(DeleteRouteRequest, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(DeleteRouteRequest request, CallSettings callSettings = null)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
request | DeleteRouteRequest 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 |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteRouteRequest request = new DeleteRouteRequest
{
RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(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 datastreamClient.PollOnceDeleteRouteAsync(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;
}
DeleteRouteAsync(DeleteRouteRequest, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(DeleteRouteRequest request, CancellationToken cancellationToken)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
request | DeleteRouteRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteRouteRequest request = new DeleteRouteRequest
{
RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(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 datastreamClient.PollOnceDeleteRouteAsync(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;
}
DeleteRouteAsync(RouteName, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(RouteName name, CallSettings callSettings = null)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
name | RouteName Required. The name of the Route resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(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 datastreamClient.PollOnceDeleteRouteAsync(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;
}
DeleteRouteAsync(RouteName, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(RouteName name, CancellationToken cancellationToken)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
name | RouteName Required. The name of the Route resource to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(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 datastreamClient.PollOnceDeleteRouteAsync(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;
}
DeleteRouteAsync(String, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(string name, CallSettings callSettings = null)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the Route resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(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 datastreamClient.PollOnceDeleteRouteAsync(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;
}
DeleteRouteAsync(String, CancellationToken)
public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(string name, CancellationToken cancellationToken)
Use this method to delete a route.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the Route resource to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(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 datastreamClient.PollOnceDeleteRouteAsync(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)
Use this method to delete a 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 |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.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 = datastreamClient.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)
Use this method to delete a stream.
Parameters | |
---|---|
Name | Description |
name | StreamName Required. The name of the stream resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.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 = datastreamClient.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)
Use this method to delete a stream.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.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 = datastreamClient.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)
Use this method to delete a 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 |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to delete a 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 |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to delete a stream.
Parameters | |
---|---|
Name | Description |
name | StreamName Required. The name of the stream resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to delete a stream.
Parameters | |
---|---|
Name | Description |
name | StreamName Required. The name of the stream resource to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to delete a stream.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream resource to delete. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.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 datastreamClient.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)
Use this method to delete a stream.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream resource to delete. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.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 datastreamClient.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;
}
DiscoverConnectionProfile(DiscoverConnectionProfileRequest, CallSettings)
public virtual DiscoverConnectionProfileResponse DiscoverConnectionProfile(DiscoverConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to discover a connection profile. The discover API call exposes the data objects and metadata belonging to the profile. Typically, a request returns children data objects of a parent data object that's optionally supplied in the request.
Parameters | |
---|---|
Name | Description |
request | DiscoverConnectionProfileRequest 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 |
DiscoverConnectionProfileResponse | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DiscoverConnectionProfileRequest request = new DiscoverConnectionProfileRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
FullHierarchy = false,
OracleRdbms = new OracleRdbms(),
ConnectionProfile = new ConnectionProfile(),
};
// Make the request
DiscoverConnectionProfileResponse response = datastreamClient.DiscoverConnectionProfile(request);
DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest, CallSettings)
public virtual Task<DiscoverConnectionProfileResponse> DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to discover a connection profile. The discover API call exposes the data objects and metadata belonging to the profile. Typically, a request returns children data objects of a parent data object that's optionally supplied in the request.
Parameters | |
---|---|
Name | Description |
request | DiscoverConnectionProfileRequest 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 |
Task<DiscoverConnectionProfileResponse> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DiscoverConnectionProfileRequest request = new DiscoverConnectionProfileRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
FullHierarchy = false,
OracleRdbms = new OracleRdbms(),
ConnectionProfile = new ConnectionProfile(),
};
// Make the request
DiscoverConnectionProfileResponse response = await datastreamClient.DiscoverConnectionProfileAsync(request);
DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest, CancellationToken)
public virtual Task<DiscoverConnectionProfileResponse> DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest request, CancellationToken cancellationToken)
Use this method to discover a connection profile. The discover API call exposes the data objects and metadata belonging to the profile. Typically, a request returns children data objects of a parent data object that's optionally supplied in the request.
Parameters | |
---|---|
Name | Description |
request | DiscoverConnectionProfileRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<DiscoverConnectionProfileResponse> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DiscoverConnectionProfileRequest request = new DiscoverConnectionProfileRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
FullHierarchy = false,
OracleRdbms = new OracleRdbms(),
ConnectionProfile = new ConnectionProfile(),
};
// Make the request
DiscoverConnectionProfileResponse response = await datastreamClient.DiscoverConnectionProfileAsync(request);
FetchStaticIps(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<FetchStaticIpsResponse, string> FetchStaticIps(LocationName name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
Parameters | |
---|---|
Name | Description |
name | LocationName Required. The resource name for the location for which static IPs should be returned.
Must be in the format |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<FetchStaticIpsResponse, String> | A pageable sequence of String resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName name = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIps(name);
// Iterate over all response items, lazily performing RPCs as required
foreach (string 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 (FetchStaticIpsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (string 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<string> 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 (string 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;
FetchStaticIps(FetchStaticIpsRequest, CallSettings)
public virtual PagedEnumerable<FetchStaticIpsResponse, string> FetchStaticIps(FetchStaticIpsRequest request, CallSettings callSettings = null)
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
Parameters | |
---|---|
Name | Description |
request | FetchStaticIpsRequest 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 |
PagedEnumerable<FetchStaticIpsResponse, String> | A pageable sequence of String resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
FetchStaticIpsRequest request = new FetchStaticIpsRequest
{
LocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
};
// Make the request
PagedEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIps(request);
// Iterate over all response items, lazily performing RPCs as required
foreach (string 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 (FetchStaticIpsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (string 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<string> 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 (string 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;
FetchStaticIps(String, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<FetchStaticIpsResponse, string> FetchStaticIps(string name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
Parameters | |
---|---|
Name | Description |
name | String Required. The resource name for the location for which static IPs should be returned.
Must be in the format |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<FetchStaticIpsResponse, String> | A pageable sequence of String resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIps(name);
// Iterate over all response items, lazily performing RPCs as required
foreach (string 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 (FetchStaticIpsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (string 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<string> 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 (string 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;
FetchStaticIpsAsync(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<FetchStaticIpsResponse, string> FetchStaticIpsAsync(LocationName name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
Parameters | |
---|---|
Name | Description |
name | LocationName Required. The resource name for the location for which static IPs should be returned.
Must be in the format |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<FetchStaticIpsResponse, String> | A pageable asynchronous sequence of String resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName name = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedAsyncEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIpsAsync(name);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((string item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((FetchStaticIpsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (string 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<string> 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 (string 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;
FetchStaticIpsAsync(FetchStaticIpsRequest, CallSettings)
public virtual PagedAsyncEnumerable<FetchStaticIpsResponse, string> FetchStaticIpsAsync(FetchStaticIpsRequest request, CallSettings callSettings = null)
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
Parameters | |
---|---|
Name | Description |
request | FetchStaticIpsRequest 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 |
PagedAsyncEnumerable<FetchStaticIpsResponse, String> | A pageable asynchronous sequence of String resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
FetchStaticIpsRequest request = new FetchStaticIpsRequest
{
LocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
};
// Make the request
PagedAsyncEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIpsAsync(request);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((string item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((FetchStaticIpsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (string 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<string> 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 (string 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;
FetchStaticIpsAsync(String, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<FetchStaticIpsResponse, string> FetchStaticIpsAsync(string name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
Parameters | |
---|---|
Name | Description |
name | String Required. The resource name for the location for which static IPs should be returned.
Must be in the format |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<FetchStaticIpsResponse, String> | A pageable asynchronous sequence of String resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedAsyncEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIpsAsync(name);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((string item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((FetchStaticIpsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (string 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<string> 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 (string 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;
GetConnectionProfile(ConnectionProfileName, CallSettings)
public virtual ConnectionProfile GetConnectionProfile(ConnectionProfileName name, CallSettings callSettings = null)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
name | ConnectionProfileName Required. The name of the connection profile resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
ConnectionProfile | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
ConnectionProfile response = datastreamClient.GetConnectionProfile(name);
GetConnectionProfile(GetConnectionProfileRequest, CallSettings)
public virtual ConnectionProfile GetConnectionProfile(GetConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
request | GetConnectionProfileRequest 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 |
ConnectionProfile | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetConnectionProfileRequest request = new GetConnectionProfileRequest
{
ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
};
// Make the request
ConnectionProfile response = datastreamClient.GetConnectionProfile(request);
GetConnectionProfile(String, CallSettings)
public virtual ConnectionProfile GetConnectionProfile(string name, CallSettings callSettings = null)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the connection profile resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
ConnectionProfile | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
ConnectionProfile response = datastreamClient.GetConnectionProfile(name);
GetConnectionProfileAsync(ConnectionProfileName, CallSettings)
public virtual Task<ConnectionProfile> GetConnectionProfileAsync(ConnectionProfileName name, CallSettings callSettings = null)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
name | ConnectionProfileName Required. The name of the connection profile resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<ConnectionProfile> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);
GetConnectionProfileAsync(ConnectionProfileName, CancellationToken)
public virtual Task<ConnectionProfile> GetConnectionProfileAsync(ConnectionProfileName name, CancellationToken cancellationToken)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
name | ConnectionProfileName Required. The name of the connection profile resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<ConnectionProfile> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);
GetConnectionProfileAsync(GetConnectionProfileRequest, CallSettings)
public virtual Task<ConnectionProfile> GetConnectionProfileAsync(GetConnectionProfileRequest request, CallSettings callSettings = null)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
request | GetConnectionProfileRequest 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 |
Task<ConnectionProfile> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetConnectionProfileRequest request = new GetConnectionProfileRequest
{
ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
};
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(request);
GetConnectionProfileAsync(GetConnectionProfileRequest, CancellationToken)
public virtual Task<ConnectionProfile> GetConnectionProfileAsync(GetConnectionProfileRequest request, CancellationToken cancellationToken)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
request | GetConnectionProfileRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<ConnectionProfile> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetConnectionProfileRequest request = new GetConnectionProfileRequest
{
ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
};
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(request);
GetConnectionProfileAsync(String, CallSettings)
public virtual Task<ConnectionProfile> GetConnectionProfileAsync(string name, CallSettings callSettings = null)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the connection profile resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<ConnectionProfile> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);
GetConnectionProfileAsync(String, CancellationToken)
public virtual Task<ConnectionProfile> GetConnectionProfileAsync(string name, CancellationToken cancellationToken)
Use this method to get details about a connection profile.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the connection profile resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<ConnectionProfile> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);
GetPrivateConnection(GetPrivateConnectionRequest, CallSettings)
public virtual PrivateConnection GetPrivateConnection(GetPrivateConnectionRequest request, CallSettings callSettings = null)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | GetPrivateConnectionRequest 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 |
PrivateConnection | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetPrivateConnectionRequest request = new GetPrivateConnectionRequest
{
PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
};
// Make the request
PrivateConnection response = datastreamClient.GetPrivateConnection(request);
GetPrivateConnection(PrivateConnectionName, CallSettings)
public virtual PrivateConnection GetPrivateConnection(PrivateConnectionName name, CallSettings callSettings = null)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | PrivateConnectionName Required. The name of the private connectivity configuration to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PrivateConnection | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PrivateConnection response = datastreamClient.GetPrivateConnection(name);
GetPrivateConnection(String, CallSettings)
public virtual PrivateConnection GetPrivateConnection(string name, CallSettings callSettings = null)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the private connectivity configuration to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PrivateConnection | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PrivateConnection response = datastreamClient.GetPrivateConnection(name);
GetPrivateConnectionAsync(GetPrivateConnectionRequest, CallSettings)
public virtual Task<PrivateConnection> GetPrivateConnectionAsync(GetPrivateConnectionRequest request, CallSettings callSettings = null)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | GetPrivateConnectionRequest 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 |
Task<PrivateConnection> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetPrivateConnectionRequest request = new GetPrivateConnectionRequest
{
PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
};
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(request);
GetPrivateConnectionAsync(GetPrivateConnectionRequest, CancellationToken)
public virtual Task<PrivateConnection> GetPrivateConnectionAsync(GetPrivateConnectionRequest request, CancellationToken cancellationToken)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
request | GetPrivateConnectionRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<PrivateConnection> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetPrivateConnectionRequest request = new GetPrivateConnectionRequest
{
PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
};
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(request);
GetPrivateConnectionAsync(PrivateConnectionName, CallSettings)
public virtual Task<PrivateConnection> GetPrivateConnectionAsync(PrivateConnectionName name, CallSettings callSettings = null)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | PrivateConnectionName Required. The name of the private connectivity configuration to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<PrivateConnection> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);
GetPrivateConnectionAsync(PrivateConnectionName, CancellationToken)
public virtual Task<PrivateConnection> GetPrivateConnectionAsync(PrivateConnectionName name, CancellationToken cancellationToken)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | PrivateConnectionName Required. The name of the private connectivity configuration to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<PrivateConnection> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);
GetPrivateConnectionAsync(String, CallSettings)
public virtual Task<PrivateConnection> GetPrivateConnectionAsync(string name, CallSettings callSettings = null)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the private connectivity configuration to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<PrivateConnection> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);
GetPrivateConnectionAsync(String, CancellationToken)
public virtual Task<PrivateConnection> GetPrivateConnectionAsync(string name, CancellationToken cancellationToken)
Use this method to get details about a private connectivity configuration.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the private connectivity configuration to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<PrivateConnection> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);
GetRoute(GetRouteRequest, CallSettings)
public virtual Route GetRoute(GetRouteRequest request, CallSettings callSettings = null)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
request | GetRouteRequest 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 |
Route | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetRouteRequest request = new GetRouteRequest
{
RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
};
// Make the request
Route response = datastreamClient.GetRoute(request);
GetRoute(RouteName, CallSettings)
public virtual Route GetRoute(RouteName name, CallSettings callSettings = null)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
name | RouteName Required. The name of the Route resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Route | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Route response = datastreamClient.GetRoute(name);
GetRoute(String, CallSettings)
public virtual Route GetRoute(string name, CallSettings callSettings = null)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the Route resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Route | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Route response = datastreamClient.GetRoute(name);
GetRouteAsync(GetRouteRequest, CallSettings)
public virtual Task<Route> GetRouteAsync(GetRouteRequest request, CallSettings callSettings = null)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
request | GetRouteRequest 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 |
Task<Route> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetRouteRequest request = new GetRouteRequest
{
RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
};
// Make the request
Route response = await datastreamClient.GetRouteAsync(request);
GetRouteAsync(GetRouteRequest, CancellationToken)
public virtual Task<Route> GetRouteAsync(GetRouteRequest request, CancellationToken cancellationToken)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
request | GetRouteRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Route> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetRouteRequest request = new GetRouteRequest
{
RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
};
// Make the request
Route response = await datastreamClient.GetRouteAsync(request);
GetRouteAsync(RouteName, CallSettings)
public virtual Task<Route> GetRouteAsync(RouteName name, CallSettings callSettings = null)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
name | RouteName Required. The name of the Route resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Route> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);
GetRouteAsync(RouteName, CancellationToken)
public virtual Task<Route> GetRouteAsync(RouteName name, CancellationToken cancellationToken)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
name | RouteName Required. The name of the Route resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Route> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);
GetRouteAsync(String, CallSettings)
public virtual Task<Route> GetRouteAsync(string name, CallSettings callSettings = null)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the Route resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Route> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);
GetRouteAsync(String, CancellationToken)
public virtual Task<Route> GetRouteAsync(string name, CancellationToken cancellationToken)
Use this method to get details about a route.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the Route resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Route> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);
GetStream(GetStreamRequest, CallSettings)
public virtual Stream GetStream(GetStreamRequest request, CallSettings callSettings = null)
Use this method to get details about a 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. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
Stream response = datastreamClient.GetStream(request);
GetStream(StreamName, CallSettings)
public virtual Stream GetStream(StreamName name, CallSettings callSettings = null)
Use this method to get details about a stream.
Parameters | |
---|---|
Name | Description |
name | StreamName Required. The name of the stream resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Stream | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Stream response = datastreamClient.GetStream(name);
GetStream(String, CallSettings)
public virtual Stream GetStream(string name, CallSettings callSettings = null)
Use this method to get details about a stream.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Stream | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Stream response = datastreamClient.GetStream(name);
GetStreamAsync(GetStreamRequest, CallSettings)
public virtual Task<Stream> GetStreamAsync(GetStreamRequest request, CallSettings callSettings = null)
Use this method to get details about a 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 |
Task<Stream> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
Stream response = await datastreamClient.GetStreamAsync(request);
GetStreamAsync(GetStreamRequest, CancellationToken)
public virtual Task<Stream> GetStreamAsync(GetStreamRequest request, CancellationToken cancellationToken)
Use this method to get details about a 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 |
Task<Stream> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
Stream response = await datastreamClient.GetStreamAsync(request);
GetStreamAsync(StreamName, CallSettings)
public virtual Task<Stream> GetStreamAsync(StreamName name, CallSettings callSettings = null)
Use this method to get details about a stream.
Parameters | |
---|---|
Name | Description |
name | StreamName Required. The name of the stream resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Stream> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);
GetStreamAsync(StreamName, CancellationToken)
public virtual Task<Stream> GetStreamAsync(StreamName name, CancellationToken cancellationToken)
Use this method to get details about a stream.
Parameters | |
---|---|
Name | Description |
name | StreamName Required. The name of the stream resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Stream> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);
GetStreamAsync(String, CallSettings)
public virtual Task<Stream> GetStreamAsync(string name, CallSettings callSettings = null)
Use this method to get details about a stream.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Stream> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);
GetStreamAsync(String, CancellationToken)
public virtual Task<Stream> GetStreamAsync(string name, CancellationToken cancellationToken)
Use this method to get details about a stream.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<Stream> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);
GetStreamObject(GetStreamObjectRequest, CallSettings)
public virtual StreamObject GetStreamObject(GetStreamObjectRequest request, CallSettings callSettings = null)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
request | GetStreamObjectRequest 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 |
StreamObject | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetStreamObjectRequest request = new GetStreamObjectRequest
{
StreamObjectName = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]"),
};
// Make the request
StreamObject response = datastreamClient.GetStreamObject(request);
GetStreamObject(StreamObjectName, CallSettings)
public virtual StreamObject GetStreamObject(StreamObjectName name, CallSettings callSettings = null)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
name | StreamObjectName Required. The name of the stream object resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
StreamObject | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
StreamObjectName name = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
// Make the request
StreamObject response = datastreamClient.GetStreamObject(name);
GetStreamObject(String, CallSettings)
public virtual StreamObject GetStreamObject(string name, CallSettings callSettings = null)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream object resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
StreamObject | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]/objects/[OBJECT]";
// Make the request
StreamObject response = datastreamClient.GetStreamObject(name);
GetStreamObjectAsync(GetStreamObjectRequest, CallSettings)
public virtual Task<StreamObject> GetStreamObjectAsync(GetStreamObjectRequest request, CallSettings callSettings = null)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
request | GetStreamObjectRequest 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 |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamObjectRequest request = new GetStreamObjectRequest
{
StreamObjectName = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]"),
};
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(request);
GetStreamObjectAsync(GetStreamObjectRequest, CancellationToken)
public virtual Task<StreamObject> GetStreamObjectAsync(GetStreamObjectRequest request, CancellationToken cancellationToken)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
request | GetStreamObjectRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamObjectRequest request = new GetStreamObjectRequest
{
StreamObjectName = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]"),
};
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(request);
GetStreamObjectAsync(StreamObjectName, CallSettings)
public virtual Task<StreamObject> GetStreamObjectAsync(StreamObjectName name, CallSettings callSettings = null)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
name | StreamObjectName Required. The name of the stream object resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamObjectName name = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(name);
GetStreamObjectAsync(StreamObjectName, CancellationToken)
public virtual Task<StreamObject> GetStreamObjectAsync(StreamObjectName name, CancellationToken cancellationToken)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
name | StreamObjectName Required. The name of the stream object resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamObjectName name = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(name);
GetStreamObjectAsync(String, CallSettings)
public virtual Task<StreamObject> GetStreamObjectAsync(string name, CallSettings callSettings = null)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream object resource to get. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]/objects/[OBJECT]";
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(name);
GetStreamObjectAsync(String, CancellationToken)
public virtual Task<StreamObject> GetStreamObjectAsync(string name, CancellationToken cancellationToken)
Use this method to get details about a stream object.
Parameters | |
---|---|
Name | Description |
name | String Required. The name of the stream object resource to get. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]/objects/[OBJECT]";
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(name);
ListConnectionProfiles(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> ListConnectionProfiles(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list connection profiles created in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of connection profiles. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> | A pageable sequence of ConnectionProfile resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> response = datastreamClient.ListConnectionProfiles(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (ConnectionProfile 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 (ListConnectionProfilesResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (ConnectionProfile 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<ConnectionProfile> 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 (ConnectionProfile 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;
ListConnectionProfiles(ListConnectionProfilesRequest, CallSettings)
public virtual PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> ListConnectionProfiles(ListConnectionProfilesRequest request, CallSettings callSettings = null)
Use this method to list connection profiles created in a project and location.
Parameters | |
---|---|
Name | Description |
request | ListConnectionProfilesRequest 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 |
PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> | A pageable sequence of ConnectionProfile resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ListConnectionProfilesRequest request = new ListConnectionProfilesRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> response = datastreamClient.ListConnectionProfiles(request);
// Iterate over all response items, lazily performing RPCs as required
foreach (ConnectionProfile 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 (ListConnectionProfilesResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (ConnectionProfile 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<ConnectionProfile> 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 (ConnectionProfile 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;
ListConnectionProfiles(String, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> ListConnectionProfiles(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list connection profiles created in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of connection profiles. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> | A pageable sequence of ConnectionProfile resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedEnumerable<ListConnectionProfilesResponse, ConnectionProfile> response = datastreamClient.ListConnectionProfiles(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (ConnectionProfile 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 (ListConnectionProfilesResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (ConnectionProfile 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<ConnectionProfile> 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 (ConnectionProfile 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;
ListConnectionProfilesAsync(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> ListConnectionProfilesAsync(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list connection profiles created in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of connection profiles. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> | A pageable asynchronous sequence of ConnectionProfile resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> response = datastreamClient.ListConnectionProfilesAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((ConnectionProfile item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListConnectionProfilesResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (ConnectionProfile 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<ConnectionProfile> 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 (ConnectionProfile 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;
ListConnectionProfilesAsync(ListConnectionProfilesRequest, CallSettings)
public virtual PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> ListConnectionProfilesAsync(ListConnectionProfilesRequest request, CallSettings callSettings = null)
Use this method to list connection profiles created in a project and location.
Parameters | |
---|---|
Name | Description |
request | ListConnectionProfilesRequest 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 |
PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> | A pageable asynchronous sequence of ConnectionProfile resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ListConnectionProfilesRequest request = new ListConnectionProfilesRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> response = datastreamClient.ListConnectionProfilesAsync(request);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((ConnectionProfile item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListConnectionProfilesResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (ConnectionProfile 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<ConnectionProfile> 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 (ConnectionProfile 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;
ListConnectionProfilesAsync(String, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> ListConnectionProfilesAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list connection profiles created in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of connection profiles. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> | A pageable asynchronous sequence of ConnectionProfile resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedAsyncEnumerable<ListConnectionProfilesResponse, ConnectionProfile> response = datastreamClient.ListConnectionProfilesAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((ConnectionProfile item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListConnectionProfilesResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (ConnectionProfile 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<ConnectionProfile> 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 (ConnectionProfile 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;
ListPrivateConnections(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> ListPrivateConnections(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list private connectivity configurations in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of private connectivity configurations. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> | A pageable sequence of PrivateConnection resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> response = datastreamClient.ListPrivateConnections(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (PrivateConnection 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 (ListPrivateConnectionsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (PrivateConnection 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<PrivateConnection> 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 (PrivateConnection 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;
ListPrivateConnections(ListPrivateConnectionsRequest, CallSettings)
public virtual PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> ListPrivateConnections(ListPrivateConnectionsRequest request, CallSettings callSettings = null)
Use this method to list private connectivity configurations in a project and location.
Parameters | |
---|---|
Name | Description |
request | ListPrivateConnectionsRequest 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 |
PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> | A pageable sequence of PrivateConnection resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ListPrivateConnectionsRequest request = new ListPrivateConnectionsRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> response = datastreamClient.ListPrivateConnections(request);
// Iterate over all response items, lazily performing RPCs as required
foreach (PrivateConnection 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 (ListPrivateConnectionsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (PrivateConnection 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<PrivateConnection> 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 (PrivateConnection 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;
ListPrivateConnections(String, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> ListPrivateConnections(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list private connectivity configurations in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of private connectivity configurations. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> | A pageable sequence of PrivateConnection resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedEnumerable<ListPrivateConnectionsResponse, PrivateConnection> response = datastreamClient.ListPrivateConnections(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (PrivateConnection 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 (ListPrivateConnectionsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (PrivateConnection 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<PrivateConnection> 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 (PrivateConnection 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;
ListPrivateConnectionsAsync(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> ListPrivateConnectionsAsync(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list private connectivity configurations in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of private connectivity configurations. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> | A pageable asynchronous sequence of PrivateConnection resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> response = datastreamClient.ListPrivateConnectionsAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((PrivateConnection item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListPrivateConnectionsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (PrivateConnection 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<PrivateConnection> 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 (PrivateConnection 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;
ListPrivateConnectionsAsync(ListPrivateConnectionsRequest, CallSettings)
public virtual PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> ListPrivateConnectionsAsync(ListPrivateConnectionsRequest request, CallSettings callSettings = null)
Use this method to list private connectivity configurations in a project and location.
Parameters | |
---|---|
Name | Description |
request | ListPrivateConnectionsRequest 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 |
PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> | A pageable asynchronous sequence of PrivateConnection resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ListPrivateConnectionsRequest request = new ListPrivateConnectionsRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> response = datastreamClient.ListPrivateConnectionsAsync(request);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((PrivateConnection item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListPrivateConnectionsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (PrivateConnection 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<PrivateConnection> 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 (PrivateConnection 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;
ListPrivateConnectionsAsync(String, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> ListPrivateConnectionsAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list private connectivity configurations in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of private connectivity configurations. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> | A pageable asynchronous sequence of PrivateConnection resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedAsyncEnumerable<ListPrivateConnectionsResponse, PrivateConnection> response = datastreamClient.ListPrivateConnectionsAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((PrivateConnection item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListPrivateConnectionsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (PrivateConnection 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<PrivateConnection> 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 (PrivateConnection 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;
ListRoutes(ListRoutesRequest, CallSettings)
public virtual PagedEnumerable<ListRoutesResponse, Route> ListRoutes(ListRoutesRequest request, CallSettings callSettings = null)
Use this method to list routes created for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
request | ListRoutesRequest 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 |
PagedEnumerable<ListRoutesResponse, Route> | A pageable sequence of Route resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ListRoutesRequest request = new ListRoutesRequest
{
ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedEnumerable<ListRoutesResponse, Route> response = datastreamClient.ListRoutes(request);
// Iterate over all response items, lazily performing RPCs as required
foreach (Route 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 (ListRoutesResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (Route 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<Route> 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 (Route 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;
ListRoutes(PrivateConnectionName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListRoutesResponse, Route> ListRoutes(PrivateConnectionName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list routes created for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | PrivateConnectionName Required. The parent that owns the collection of Routess. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListRoutesResponse, Route> | A pageable sequence of Route resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PagedEnumerable<ListRoutesResponse, Route> response = datastreamClient.ListRoutes(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (Route 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 (ListRoutesResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (Route 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<Route> 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 (Route 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;
ListRoutes(String, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListRoutesResponse, Route> ListRoutes(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list routes created for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of Routess. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListRoutesResponse, Route> | A pageable sequence of Route resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PagedEnumerable<ListRoutesResponse, Route> response = datastreamClient.ListRoutes(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (Route 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 (ListRoutesResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (Route 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<Route> 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 (Route 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;
ListRoutesAsync(ListRoutesRequest, CallSettings)
public virtual PagedAsyncEnumerable<ListRoutesResponse, Route> ListRoutesAsync(ListRoutesRequest request, CallSettings callSettings = null)
Use this method to list routes created for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
request | ListRoutesRequest 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 |
PagedAsyncEnumerable<ListRoutesResponse, Route> | A pageable asynchronous sequence of Route resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ListRoutesRequest request = new ListRoutesRequest
{
ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListRoutesResponse, Route> response = datastreamClient.ListRoutesAsync(request);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Route item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListRoutesResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (Route 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<Route> 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 (Route 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;
ListRoutesAsync(PrivateConnectionName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListRoutesResponse, Route> ListRoutesAsync(PrivateConnectionName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list routes created for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | PrivateConnectionName Required. The parent that owns the collection of Routess. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListRoutesResponse, Route> | A pageable asynchronous sequence of Route resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PagedAsyncEnumerable<ListRoutesResponse, Route> response = datastreamClient.ListRoutesAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Route item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListRoutesResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (Route 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<Route> 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 (Route 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;
ListRoutesAsync(String, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListRoutesResponse, Route> ListRoutesAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list routes created for a private connectivity configuration in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of Routess. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListRoutesResponse, Route> | A pageable asynchronous sequence of Route resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PagedAsyncEnumerable<ListRoutesResponse, Route> response = datastreamClient.ListRoutesAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Route item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListRoutesResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (Route 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<Route> 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 (Route 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;
ListStreamObjects(ListStreamObjectsRequest, CallSettings)
public virtual PagedEnumerable<ListStreamObjectsResponse, StreamObject> ListStreamObjects(ListStreamObjectsRequest request, CallSettings callSettings = null)
Use this method to list the objects of a specific stream.
Parameters | |
---|---|
Name | Description |
request | ListStreamObjectsRequest 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 |
PagedEnumerable<ListStreamObjectsResponse, StreamObject> | A pageable sequence of StreamObject resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ListStreamObjectsRequest request = new ListStreamObjectsRequest
{
ParentAsStreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
PagedEnumerable<ListStreamObjectsResponse, StreamObject> response = datastreamClient.ListStreamObjects(request);
// Iterate over all response items, lazily performing RPCs as required
foreach (StreamObject 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 (ListStreamObjectsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (StreamObject 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<StreamObject> 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 (StreamObject 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;
ListStreamObjects(StreamName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListStreamObjectsResponse, StreamObject> ListStreamObjects(StreamName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list the objects of a specific stream.
Parameters | |
---|---|
Name | Description |
parent | StreamName Required. The parent stream that owns the collection of objects. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListStreamObjectsResponse, StreamObject> | A pageable sequence of StreamObject resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
StreamName parent = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
PagedEnumerable<ListStreamObjectsResponse, StreamObject> response = datastreamClient.ListStreamObjects(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (StreamObject 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 (ListStreamObjectsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (StreamObject 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<StreamObject> 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 (StreamObject 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;
ListStreamObjects(String, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListStreamObjectsResponse, StreamObject> ListStreamObjects(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list the objects of a specific stream.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent stream that owns the collection of objects. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListStreamObjectsResponse, StreamObject> | A pageable sequence of StreamObject resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
PagedEnumerable<ListStreamObjectsResponse, StreamObject> response = datastreamClient.ListStreamObjects(parent);
// Iterate over all response items, lazily performing RPCs as required
foreach (StreamObject 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 (ListStreamObjectsResponse page in response.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (StreamObject 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<StreamObject> 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 (StreamObject 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;
ListStreamObjectsAsync(ListStreamObjectsRequest, CallSettings)
public virtual PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> ListStreamObjectsAsync(ListStreamObjectsRequest request, CallSettings callSettings = null)
Use this method to list the objects of a specific stream.
Parameters | |
---|---|
Name | Description |
request | ListStreamObjectsRequest 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 |
PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> | A pageable asynchronous sequence of StreamObject resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ListStreamObjectsRequest request = new ListStreamObjectsRequest
{
ParentAsStreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> response = datastreamClient.ListStreamObjectsAsync(request);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((StreamObject item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListStreamObjectsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (StreamObject 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<StreamObject> 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 (StreamObject 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;
ListStreamObjectsAsync(StreamName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> ListStreamObjectsAsync(StreamName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list the objects of a specific stream.
Parameters | |
---|---|
Name | Description |
parent | StreamName Required. The parent stream that owns the collection of objects. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> | A pageable asynchronous sequence of StreamObject resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName parent = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> response = datastreamClient.ListStreamObjectsAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((StreamObject item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListStreamObjectsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (StreamObject 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<StreamObject> 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 (StreamObject 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;
ListStreamObjectsAsync(String, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> ListStreamObjectsAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list the objects of a specific stream.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent stream that owns the collection of objects. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> | A pageable asynchronous sequence of StreamObject resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
PagedAsyncEnumerable<ListStreamObjectsResponse, StreamObject> response = datastreamClient.ListStreamObjectsAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((StreamObject item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListStreamObjectsResponse page) =>
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach (StreamObject 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<StreamObject> 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 (StreamObject 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(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListStreamsResponse, Stream> ListStreams(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list streams in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of streams. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListStreamsResponse, Stream> | A pageable sequence of Stream resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedEnumerable<ListStreamsResponse, Stream> response = datastreamClient.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)
Use this method to list streams in a 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 |
PagedEnumerable<ListStreamsResponse, Stream> | A pageable sequence of Stream resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ListStreamsRequest request = new ListStreamsRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedEnumerable<ListStreamsResponse, Stream> response = datastreamClient.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, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListStreamsResponse, Stream> ListStreams(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list streams in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of streams. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListStreamsResponse, Stream> | A pageable sequence of Stream resources. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedEnumerable<ListStreamsResponse, Stream> response = datastreamClient.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(LocationName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListStreamsResponse, Stream> ListStreamsAsync(LocationName parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list streams in a project and location.
Parameters | |
---|---|
Name | Description |
parent | LocationName Required. The parent that owns the collection of streams. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListStreamsResponse, Stream> | A pageable asynchronous sequence of Stream resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedAsyncEnumerable<ListStreamsResponse, Stream> response = datastreamClient.ListStreamsAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Stream item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListStreamsResponse page) =>
{
// 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)
Use this method to list streams in a 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 |
PagedAsyncEnumerable<ListStreamsResponse, Stream> | A pageable asynchronous sequence of Stream resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ListStreamsRequest request = new ListStreamsRequest
{
ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
Filter = "",
OrderBy = "",
};
// Make the request
PagedAsyncEnumerable<ListStreamsResponse, Stream> response = datastreamClient.ListStreamsAsync(request);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Stream item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListStreamsResponse page) =>
{
// 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, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListStreamsResponse, Stream> ListStreamsAsync(string parent, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)
Use this method to list streams in a project and location.
Parameters | |
---|---|
Name | Description |
parent | String Required. The parent that owns the collection of streams. |
pageToken | String The token returned from the previous request. A value of |
pageSize | Nullable<Int32> The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListStreamsResponse, Stream> | A pageable asynchronous sequence of Stream resources. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedAsyncEnumerable<ListStreamsResponse, Stream> response = datastreamClient.ListStreamsAsync(parent);
// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Stream item) =>
{
// Do something with each item
Console.WriteLine(item);
});
// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListStreamsResponse page) =>
{
// 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;
LookupStreamObject(LookupStreamObjectRequest, CallSettings)
public virtual StreamObject LookupStreamObject(LookupStreamObjectRequest request, CallSettings callSettings = null)
Use this method to look up a stream object by its source object identifier.
Parameters | |
---|---|
Name | Description |
request | LookupStreamObjectRequest 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 |
StreamObject | The RPC response. |
// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LookupStreamObjectRequest request = new LookupStreamObjectRequest
{
ParentAsStreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
SourceObjectIdentifier = new SourceObjectIdentifier(),
};
// Make the request
StreamObject response = datastreamClient.LookupStreamObject(request);
LookupStreamObjectAsync(LookupStreamObjectRequest, CallSettings)
public virtual Task<StreamObject> LookupStreamObjectAsync(LookupStreamObjectRequest request, CallSettings callSettings = null)
Use this method to look up a stream object by its source object identifier.
Parameters | |
---|---|
Name | Description |
request | LookupStreamObjectRequest 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 |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LookupStreamObjectRequest request = new LookupStreamObjectRequest
{
ParentAsStreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
SourceObjectIdentifier = new SourceObjectIdentifier(),
};
// Make the request
StreamObject response = await datastreamClient.LookupStreamObjectAsync(request);
LookupStreamObjectAsync(LookupStreamObjectRequest, CancellationToken)
public virtual Task<StreamObject> LookupStreamObjectAsync(LookupStreamObjectRequest request, CancellationToken cancellationToken)
Use this method to look up a stream object by its source object identifier.
Parameters | |
---|---|
Name | Description |
request | LookupStreamObjectRequest The request object containing all of the parameters for the API call. |
cancellationToken | CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
Task<StreamObject> | A Task containing the RPC response. |
// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LookupStreamObjectRequest request = new LookupStreamObjectRequest
{
ParentAsStreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
SourceObjectIdentifier = new SourceObjectIdentifier(),
};
// Make the request
StreamObject response = await datastreamClient.LookupStreamObjectAsync(request);
PollOnceCreateConnectionProfile(String, CallSettings)
public virtual Operation<ConnectionProfile, OperationMetadata> PollOnceCreateConnectionProfile(string operationName, CallSettings callSettings = null)
Poll an operation once, using an operationName
from a previous invocation of
CreateConnectionProfile
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<ConnectionProfile, OperationMetadata> | The result of polling the operation. |
PollOnceCreateConnectionProfileAsync(String, CallSettings)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> PollOnceCreateConnectionProfileAsync(string operationName, CallSettings callSettings = null)
Asynchronously poll an operation once, using an operationName
from a previous invocation of
CreateConnectionProfile
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<ConnectionProfile, OperationMetadata>> | A task representing the result of polling the operation. |
PollOnceCreatePrivateConnection(String, CallSettings)
public virtual Operation<PrivateConnection, OperationMetadata> PollOnceCreatePrivateConnection(string operationName, CallSettings callSettings = null)
Poll an operation once, using an operationName
from a previous invocation of
CreatePrivateConnection
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<PrivateConnection, OperationMetadata> | The result of polling the operation. |
PollOnceCreatePrivateConnectionAsync(String, CallSettings)
public virtual Task<Operation<PrivateConnection, OperationMetadata>> PollOnceCreatePrivateConnectionAsync(string operationName, CallSettings callSettings = null)
Asynchronously poll an operation once, using an operationName
from a previous invocation of
CreatePrivateConnection
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<PrivateConnection, OperationMetadata>> | A task representing the result of polling the operation. |
PollOnceCreateRoute(String, CallSettings)
public virtual Operation<Route, OperationMetadata> PollOnceCreateRoute(string operationName, CallSettings callSettings = null)
Poll an operation once, using an operationName
from a previous invocation of CreateRoute
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Route, OperationMetadata> | The result of polling the operation. |
PollOnceCreateRouteAsync(String, CallSettings)
public virtual Task<Operation<Route, OperationMetadata>> PollOnceCreateRouteAsync(string operationName, CallSettings callSettings = null)
Asynchronously poll an operation once, using an operationName
from a previous invocation of
CreateRoute
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Route, OperationMetadata>> | 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 |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Stream, OperationMetadata> | 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 |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Stream, OperationMetadata>> | A task representing the result of polling the operation. |
PollOnceDeleteConnectionProfile(String, CallSettings)
public virtual Operation<Empty, OperationMetadata> PollOnceDeleteConnectionProfile(string operationName, CallSettings callSettings = null)
Poll an operation once, using an operationName
from a previous invocation of
DeleteConnectionProfile
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The result of polling the operation. |
PollOnceDeleteConnectionProfileAsync(String, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> PollOnceDeleteConnectionProfileAsync(string operationName, CallSettings callSettings = null)
Asynchronously poll an operation once, using an operationName
from a previous invocation of
DeleteConnectionProfile
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A task representing the result of polling the operation. |
PollOnceDeletePrivateConnection(String, CallSettings)
public virtual Operation<Empty, OperationMetadata> PollOnceDeletePrivateConnection(string operationName, CallSettings callSettings = null)
Poll an operation once, using an operationName
from a previous invocation of
DeletePrivateConnection
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The result of polling the operation. |
PollOnceDeletePrivateConnectionAsync(String, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> PollOnceDeletePrivateConnectionAsync(string operationName, CallSettings callSettings = null)
Asynchronously poll an operation once, using an operationName
from a previous invocation of
DeletePrivateConnection
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A task representing the result of polling the operation. |
PollOnceDeleteRoute(String, CallSettings)
public virtual Operation<Empty, OperationMetadata> PollOnceDeleteRoute(string operationName, CallSettings callSettings = null)
Poll an operation once, using an operationName
from a previous invocation of DeleteRoute
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | The result of polling the operation. |
PollOnceDeleteRouteAsync(String, CallSettings)
public virtual Task<Operation<Empty, OperationMetadata>> PollOnceDeleteRouteAsync(string operationName, CallSettings callSettings = null)
Asynchronously poll an operation once, using an operationName
from a previous invocation of
DeleteRoute
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | 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 |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Empty, OperationMetadata> | 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 |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<Empty, OperationMetadata>> | A task representing the result of polling the operation. |
PollOnceUpdateConnectionProfile(String, CallSettings)
public virtual Operation<ConnectionProfile, OperationMetadata> PollOnceUpdateConnectionProfile(string operationName, CallSettings callSettings = null)
Poll an operation once, using an operationName
from a previous invocation of
UpdateConnectionProfile
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<ConnectionProfile, OperationMetadata> | The result of polling the operation. |
PollOnceUpdateConnectionProfileAsync(String, CallSettings)
public virtual Task<Operation<ConnectionProfile, OperationMetadata>> PollOnceUpdateConnectionProfileAsync(string operationName, CallSettings callSettings = null)
Asynchronously poll an operation once, using an operationName
from a previous invocation of
UpdateConnectionProfile
.
Parameters | |
---|---|
Name | Description |
operationName | String The name of a previously invoked operation. Must not be |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Operation<ConnectionProfile, OperationMetadata>> | 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 |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Operation<Stream, OperationMetadata> | The result of polling the operation. |