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
callInvoker
CallInvokerThe callInvoker to use to make remote calls.
AgentRpcClient(ChannelBase)
Creates a new client for AgentRpc
public AgentRpcClient(ChannelBase channel)
Parameters
channel
ChannelBaseThe channel to use to make remote calls.
AgentRpcClient(ClientBaseConfiguration)
Protected constructor to allow creation of configured clients.
protected AgentRpcClient(ClientBase.ClientBaseConfiguration configuration)
Parameters
configuration
ClientBase.ClientBaseConfigurationThe client configuration.
Methods
GetState(AgentId, CallOptions)
public virtual GetStateResponse GetState(AgentId request, CallOptions options)
Parameters
request
AgentIdoptions
CallOptions
Returns
GetState(AgentId, Metadata, DateTime?, CancellationToken)
public virtual GetStateResponse GetState(AgentId request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
request
AgentIdheaders
Metadatadeadline
DateTime?cancellationToken
CancellationToken
Returns
GetStateAsync(AgentId, CallOptions)
public virtual AsyncUnaryCall<GetStateResponse> GetStateAsync(AgentId request, CallOptions options)
Parameters
request
AgentIdoptions
CallOptions
Returns
GetStateAsync(AgentId, Metadata, DateTime?, CancellationToken)
public virtual AsyncUnaryCall<GetStateResponse> GetStateAsync(AgentId request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
request
AgentIdheaders
Metadatadeadline
DateTime?cancellationToken
CancellationToken
Returns
NewInstance(ClientBaseConfiguration)
Creates a new instance of client from given ClientBaseConfiguration
.
protected override AgentRpc.AgentRpcClient NewInstance(ClientBase.ClientBaseConfiguration configuration)
Parameters
configuration
ClientBase.ClientBaseConfiguration
Returns
OpenChannel(CallOptions)
public virtual AsyncDuplexStreamingCall<Message, Message> OpenChannel(CallOptions options)
Parameters
options
CallOptions
Returns
OpenChannel(Metadata, DateTime?, CancellationToken)
public virtual AsyncDuplexStreamingCall<Message, Message> OpenChannel(Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
headers
Metadatadeadline
DateTime?cancellationToken
CancellationToken
Returns
SaveState(AgentState, CallOptions)
public virtual SaveStateResponse SaveState(AgentState request, CallOptions options)
Parameters
request
AgentStateoptions
CallOptions
Returns
SaveState(AgentState, Metadata, DateTime?, CancellationToken)
public virtual SaveStateResponse SaveState(AgentState request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
request
AgentStateheaders
Metadatadeadline
DateTime?cancellationToken
CancellationToken
Returns
SaveStateAsync(AgentState, CallOptions)
public virtual AsyncUnaryCall<SaveStateResponse> SaveStateAsync(AgentState request, CallOptions options)
Parameters
request
AgentStateoptions
CallOptions
Returns
SaveStateAsync(AgentState, Metadata, DateTime?, CancellationToken)
public virtual AsyncUnaryCall<SaveStateResponse> SaveStateAsync(AgentState request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)
Parameters
request
AgentStateheaders
Metadatadeadline
DateTime?cancellationToken
CancellationToken