public abstract class ReasoningEngineExecutionServiceClient
Reference documentation and code samples for the Cloud AI Platform v1beta1 API class ReasoningEngineExecutionServiceClient.
ReasoningEngineExecutionService client wrapper, for convenient use.
Derived Types
Namespace
Google.Cloud.AIPlatform.V1Beta1Assembly
Google.Cloud.AIPlatform.V1Beta1.dll
Remarks
A service for executing queries on Reasoning Engine.
Properties
DefaultEndpoint
public static string DefaultEndpoint { get; }
The default endpoint for the ReasoningEngineExecutionService service, which is a host of "aiplatform.googleapis.com" and a port of 443.
Property Value | |
---|---|
Type | Description |
string |
DefaultScopes
public static IReadOnlyList<string> DefaultScopes { get; }
The default ReasoningEngineExecutionService scopes.
Property Value | |
---|---|
Type | Description |
IReadOnlyListstring |
The default ReasoningEngineExecutionService scopes are:
GrpcClient
public virtual ReasoningEngineExecutionService.ReasoningEngineExecutionServiceClient GrpcClient { get; }
The underlying gRPC ReasoningEngineExecutionService client
Property Value | |
---|---|
Type | Description |
ReasoningEngineExecutionServiceReasoningEngineExecutionServiceClient |
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 |
Methods
Create()
public static ReasoningEngineExecutionServiceClient Create()
Synchronously creates a ReasoningEngineExecutionServiceClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use ReasoningEngineExecutionServiceClientBuilder.
Returns | |
---|---|
Type | Description |
ReasoningEngineExecutionServiceClient |
The created ReasoningEngineExecutionServiceClient. |
CreateAsync(CancellationToken)
public static Task<ReasoningEngineExecutionServiceClient> CreateAsync(CancellationToken cancellationToken = default)
Asynchronously creates a ReasoningEngineExecutionServiceClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use ReasoningEngineExecutionServiceClientBuilder.
Parameter | |
---|---|
Name | Description |
cancellationToken |
CancellationToken The CancellationToken to use while creating the client. |
Returns | |
---|---|
Type | Description |
TaskReasoningEngineExecutionServiceClient |
The task representing the created ReasoningEngineExecutionServiceClient. |
QueryReasoningEngine(QueryReasoningEngineRequest, CallSettings)
public virtual QueryReasoningEngineResponse QueryReasoningEngine(QueryReasoningEngineRequest request, CallSettings callSettings = null)
Queries using a reasoning engine.
Parameters | |
---|---|
Name | Description |
request |
QueryReasoningEngineRequest 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 |
QueryReasoningEngineResponse |
The RPC response. |
// Create client
ReasoningEngineExecutionServiceClient reasoningEngineExecutionServiceClient = ReasoningEngineExecutionServiceClient.Create();
// Initialize request argument(s)
QueryReasoningEngineRequest request = new QueryReasoningEngineRequest
{
ReasoningEngineName = ReasoningEngineName.FromProjectLocationReasoningEngine("[PROJECT]", "[LOCATION]", "[REASONING_ENGINE]"),
Input = new Struct(),
ClassMethod = "",
};
// Make the request
QueryReasoningEngineResponse response = reasoningEngineExecutionServiceClient.QueryReasoningEngine(request);
QueryReasoningEngineAsync(QueryReasoningEngineRequest, CallSettings)
public virtual Task<QueryReasoningEngineResponse> QueryReasoningEngineAsync(QueryReasoningEngineRequest request, CallSettings callSettings = null)
Queries using a reasoning engine.
Parameters | |
---|---|
Name | Description |
request |
QueryReasoningEngineRequest 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 |
TaskQueryReasoningEngineResponse |
A Task containing the RPC response. |
// Create client
ReasoningEngineExecutionServiceClient reasoningEngineExecutionServiceClient = await ReasoningEngineExecutionServiceClient.CreateAsync();
// Initialize request argument(s)
QueryReasoningEngineRequest request = new QueryReasoningEngineRequest
{
ReasoningEngineName = ReasoningEngineName.FromProjectLocationReasoningEngine("[PROJECT]", "[LOCATION]", "[REASONING_ENGINE]"),
Input = new Struct(),
ClassMethod = "",
};
// Make the request
QueryReasoningEngineResponse response = await reasoningEngineExecutionServiceClient.QueryReasoningEngineAsync(request);
QueryReasoningEngineAsync(QueryReasoningEngineRequest, CancellationToken)
public virtual Task<QueryReasoningEngineResponse> QueryReasoningEngineAsync(QueryReasoningEngineRequest request, CancellationToken cancellationToken)
Queries using a reasoning engine.
Parameters | |
---|---|
Name | Description |
request |
QueryReasoningEngineRequest The request object containing all of the parameters for the API call. |
cancellationToken |
CancellationToken A CancellationToken to use for this RPC. |
Returns | |
---|---|
Type | Description |
TaskQueryReasoningEngineResponse |
A Task containing the RPC response. |
// Create client
ReasoningEngineExecutionServiceClient reasoningEngineExecutionServiceClient = await ReasoningEngineExecutionServiceClient.CreateAsync();
// Initialize request argument(s)
QueryReasoningEngineRequest request = new QueryReasoningEngineRequest
{
ReasoningEngineName = ReasoningEngineName.FromProjectLocationReasoningEngine("[PROJECT]", "[LOCATION]", "[REASONING_ENGINE]"),
Input = new Struct(),
ClassMethod = "",
};
// Make the request
QueryReasoningEngineResponse response = await reasoningEngineExecutionServiceClient.QueryReasoningEngineAsync(request);
ShutdownDefaultChannelsAsync()
public static Task ShutdownDefaultChannelsAsync()
Shuts down any channels automatically created by Create() and CreateAsync(CancellationToken). Channels which weren't automatically created are not affected.
Returns | |
---|---|
Type | Description |
Task |
A task representing the asynchronous shutdown operation. |
After calling this method, further calls to Create() and CreateAsync(CancellationToken) will create new channels, which could in turn be shut down by another call to this method.
StreamQueryReasoningEngine(StreamQueryReasoningEngineRequest, CallSettings)
public virtual ReasoningEngineExecutionServiceClient.StreamQueryReasoningEngineStream StreamQueryReasoningEngine(StreamQueryReasoningEngineRequest request, CallSettings callSettings = null)
Streams queries using a reasoning engine.
Parameters | |
---|---|
Name | Description |
request |
StreamQueryReasoningEngineRequest 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 |
ReasoningEngineExecutionServiceClientStreamQueryReasoningEngineStream |
The server stream. |
// Create client
ReasoningEngineExecutionServiceClient reasoningEngineExecutionServiceClient = ReasoningEngineExecutionServiceClient.Create();
// Initialize request argument(s)
StreamQueryReasoningEngineRequest request = new StreamQueryReasoningEngineRequest
{
ReasoningEngineName = ReasoningEngineName.FromProjectLocationReasoningEngine("[PROJECT]", "[LOCATION]", "[REASONING_ENGINE]"),
Input = new Struct(),
ClassMethod = "",
};
// Make the request, returning a streaming response
using ReasoningEngineExecutionServiceClient.StreamQueryReasoningEngineStream response = reasoningEngineExecutionServiceClient.StreamQueryReasoningEngine(request);
// Read streaming responses from server until complete
// Note that C# 8 code can use await foreach
AsyncResponseStream<HttpBody> responseStream = response.GetResponseStream();
while (await responseStream.MoveNextAsync())
{
HttpBody responseItem = responseStream.Current;
// Do something with streamed response
}
// The response stream has completed