Class AgentRpc.AgentRpcClient
Client for AgentRpc
public class AgentRpc.AgentRpcClient : ClientBase<AgentRpc.AgentRpcClient>
- Inheritance
-
AgentRpc.AgentRpcClient
- Inherited Members
Constructors
AgentRpcClient()
Protected parameterless constructor to allow creation of test doubles.
protected AgentRpcClient()
AgentRpcClient(CallInvoker)
Creates a new client for AgentRpc that uses a custom CallInvoker.
public AgentRpcClient(CallInvoker callInvoker)
Parameters
callInvokerCallInvokerThe callInvoker to use to make remote calls.
AgentRpcClient(ChannelBase)
Creates a new client for AgentRpc
public AgentRpcClient(ChannelBase channel)
Parameters
channelChannelBaseThe channel to use to make remote calls.
AgentRpcClient(ClientBaseConfiguration)
Protected constructor to allow creation of configured clients.
protected AgentRpcClient(ClientBase.ClientBaseConfiguration configuration)
Parameters
configurationClientBase.ClientBaseConfigurationThe client configuration.
Methods
GetState(AgentId, CallOptions)
public virtual GetStateResponse GetState(AgentId request, CallOptions options)
Parameters
requestAgentIdoptionsCallOptions
Returns
GetState(AgentId, Metadata, DateTime?, CancellationToken)
public virtual GetStateResponse GetState(AgentId request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
requestAgentIdheadersMetadatadeadlineDateTime?cancellationTokenCancellationToken
Returns
GetStateAsync(AgentId, CallOptions)
public virtual AsyncUnaryCall<GetStateResponse> GetStateAsync(AgentId request, CallOptions options)
Parameters
requestAgentIdoptionsCallOptions
Returns
GetStateAsync(AgentId, Metadata, DateTime?, CancellationToken)
public virtual AsyncUnaryCall<GetStateResponse> GetStateAsync(AgentId request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
requestAgentIdheadersMetadatadeadlineDateTime?cancellationTokenCancellationToken
Returns
NewInstance(ClientBaseConfiguration)
Creates a new instance of client from given ClientBaseConfiguration.
protected override AgentRpc.AgentRpcClient NewInstance(ClientBase.ClientBaseConfiguration configuration)
Parameters
configurationClientBase.ClientBaseConfiguration
Returns
OpenChannel(CallOptions)
public virtual AsyncDuplexStreamingCall<Message, Message> OpenChannel(CallOptions options)
Parameters
optionsCallOptions
Returns
OpenChannel(Metadata, DateTime?, CancellationToken)
public virtual AsyncDuplexStreamingCall<Message, Message> OpenChannel(Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
headersMetadatadeadlineDateTime?cancellationTokenCancellationToken
Returns
SaveState(AgentState, CallOptions)
public virtual SaveStateResponse SaveState(AgentState request, CallOptions options)
Parameters
requestAgentStateoptionsCallOptions
Returns
SaveState(AgentState, Metadata, DateTime?, CancellationToken)
public virtual SaveStateResponse SaveState(AgentState request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
requestAgentStateheadersMetadatadeadlineDateTime?cancellationTokenCancellationToken
Returns
SaveStateAsync(AgentState, CallOptions)
public virtual AsyncUnaryCall<SaveStateResponse> SaveStateAsync(AgentState request, CallOptions options)
Parameters
requestAgentStateoptionsCallOptions
Returns
SaveStateAsync(AgentState, Metadata, DateTime?, CancellationToken)
public virtual AsyncUnaryCall<SaveStateResponse> SaveStateAsync(AgentState request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
requestAgentStateheadersMetadatadeadlineDateTime?cancellationTokenCancellationToken