Class AgentRpc.AgentRpcClient

Namespace

Microsoft.AutoGen.Protobuf

Assembly

Microsoft.AutoGen.Core.Grpc.dll

Client for AgentRpc

public class AgentRpc.AgentRpcClient : ClientBase<AgentRpc.AgentRpcClient>

Inheritance

object

ClientBase

ClientBase<AgentRpc.AgentRpcClient>

AgentRpc.AgentRpcClient

Inherited Members

ClientBase<AgentRpc.AgentRpcClient>.WithHost(string)

ClientBase.CallInvoker

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

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 CallInvoker

The callInvoker to use to make remote calls.

AgentRpcClient(ChannelBase)

Creates a new client for AgentRpc

public AgentRpcClient(ChannelBase channel)

Parameters

channel ChannelBase

The 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.ClientBaseConfiguration

The client configuration.

Methods

AddSubscription(AddSubscriptionRequest, CallOptions)

public virtual AddSubscriptionResponse AddSubscription(AddSubscriptionRequest request, CallOptions options)

Parameters

request AddSubscriptionRequest

options CallOptions

Returns

AddSubscriptionResponse

AddSubscription(AddSubscriptionRequest, Metadata, DateTime?, CancellationToken)

public virtual AddSubscriptionResponse AddSubscription(AddSubscriptionRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request AddSubscriptionRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

AddSubscriptionResponse

AddSubscriptionAsync(AddSubscriptionRequest, CallOptions)

public virtual AsyncUnaryCall<AddSubscriptionResponse> AddSubscriptionAsync(AddSubscriptionRequest request, CallOptions options)

Parameters

request AddSubscriptionRequest

options CallOptions

Returns

AsyncUnaryCall<AddSubscriptionResponse>

AddSubscriptionAsync(AddSubscriptionRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<AddSubscriptionResponse> AddSubscriptionAsync(AddSubscriptionRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request AddSubscriptionRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

AsyncUnaryCall<AddSubscriptionResponse>

GetSubscriptions(GetSubscriptionsRequest, CallOptions)

public virtual GetSubscriptionsResponse GetSubscriptions(GetSubscriptionsRequest request, CallOptions options)

Parameters

request GetSubscriptionsRequest

options CallOptions

Returns

GetSubscriptionsResponse

GetSubscriptions(GetSubscriptionsRequest, Metadata, DateTime?, CancellationToken)

public virtual GetSubscriptionsResponse GetSubscriptions(GetSubscriptionsRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request GetSubscriptionsRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

GetSubscriptionsResponse

GetSubscriptionsAsync(GetSubscriptionsRequest, CallOptions)

public virtual AsyncUnaryCall<GetSubscriptionsResponse> GetSubscriptionsAsync(GetSubscriptionsRequest request, CallOptions options)

Parameters

request GetSubscriptionsRequest

options CallOptions

Returns

AsyncUnaryCall<GetSubscriptionsResponse>

GetSubscriptionsAsync(GetSubscriptionsRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<GetSubscriptionsResponse> GetSubscriptionsAsync(GetSubscriptionsRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request GetSubscriptionsRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

AsyncUnaryCall<GetSubscriptionsResponse>

NewInstance(ClientBaseConfiguration)

Creates a new instance of client from given ClientBaseConfiguration.

protected override AgentRpc.AgentRpcClient NewInstance(ClientBase.ClientBaseConfiguration configuration)

Parameters

configuration ClientBase.ClientBaseConfiguration

Returns

AgentRpc.AgentRpcClient

OpenChannel(CallOptions)

public virtual AsyncDuplexStreamingCall<Message, Message> OpenChannel(CallOptions options)

Parameters

options CallOptions

Returns

AsyncDuplexStreamingCall<Message, Message>

OpenChannel(Metadata, DateTime?, CancellationToken)

public virtual AsyncDuplexStreamingCall<Message, Message> OpenChannel(Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

AsyncDuplexStreamingCall<Message, Message>

OpenControlChannel(CallOptions)

public virtual AsyncDuplexStreamingCall<ControlMessage, ControlMessage> OpenControlChannel(CallOptions options)

Parameters

options CallOptions

Returns

AsyncDuplexStreamingCall<ControlMessage, ControlMessage>

OpenControlChannel(Metadata, DateTime?, CancellationToken)

public virtual AsyncDuplexStreamingCall<ControlMessage, ControlMessage> OpenControlChannel(Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

AsyncDuplexStreamingCall<ControlMessage, ControlMessage>

RegisterAgent(RegisterAgentTypeRequest, CallOptions)

public virtual RegisterAgentTypeResponse RegisterAgent(RegisterAgentTypeRequest request, CallOptions options)

Parameters

request RegisterAgentTypeRequest

options CallOptions

Returns

RegisterAgentTypeResponse

RegisterAgent(RegisterAgentTypeRequest, Metadata, DateTime?, CancellationToken)

public virtual RegisterAgentTypeResponse RegisterAgent(RegisterAgentTypeRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request RegisterAgentTypeRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

RegisterAgentTypeResponse

RegisterAgentAsync(RegisterAgentTypeRequest, CallOptions)

public virtual AsyncUnaryCall<RegisterAgentTypeResponse> RegisterAgentAsync(RegisterAgentTypeRequest request, CallOptions options)

Parameters

request RegisterAgentTypeRequest

options CallOptions

Returns

AsyncUnaryCall<RegisterAgentTypeResponse>

RegisterAgentAsync(RegisterAgentTypeRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<RegisterAgentTypeResponse> RegisterAgentAsync(RegisterAgentTypeRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request RegisterAgentTypeRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

AsyncUnaryCall<RegisterAgentTypeResponse>

RemoveSubscription(RemoveSubscriptionRequest, CallOptions)

public virtual RemoveSubscriptionResponse RemoveSubscription(RemoveSubscriptionRequest request, CallOptions options)

Parameters

request RemoveSubscriptionRequest

options CallOptions

Returns

RemoveSubscriptionResponse

RemoveSubscription(RemoveSubscriptionRequest, Metadata, DateTime?, CancellationToken)

public virtual RemoveSubscriptionResponse RemoveSubscription(RemoveSubscriptionRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request RemoveSubscriptionRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

RemoveSubscriptionResponse

RemoveSubscriptionAsync(RemoveSubscriptionRequest, CallOptions)

public virtual AsyncUnaryCall<RemoveSubscriptionResponse> RemoveSubscriptionAsync(RemoveSubscriptionRequest request, CallOptions options)

Parameters

request RemoveSubscriptionRequest

options CallOptions

Returns

AsyncUnaryCall<RemoveSubscriptionResponse>

RemoveSubscriptionAsync(RemoveSubscriptionRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<RemoveSubscriptionResponse> RemoveSubscriptionAsync(RemoveSubscriptionRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Parameters

request RemoveSubscriptionRequest

headers Metadata

deadline DateTime?

cancellationToken CancellationToken

Returns

AsyncUnaryCall<RemoveSubscriptionResponse>