Class GrpcAgentWorker

Namespace

Microsoft.AutoGen.Core

Assembly

Microsoft.AutoGen.Core.Grpc.dll

public sealed class GrpcAgentWorker : IHostedService, IDisposable, IAgentWorker

Inheritance

object

GrpcAgentWorker

Implements

IHostedService

IDisposable

IAgentWorker

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

GrpcAgentWorker(AgentRpcClient, IHostApplicationLifetime, IServiceProvider, IEnumerable<Tuple<string, Type>>, ILogger<GrpcAgentWorker>)

public GrpcAgentWorker(AgentRpc.AgentRpcClient client, IHostApplicationLifetime hostApplicationLifetime, IServiceProvider serviceProvider, IEnumerable<Tuple<string, Type>> configuredAgentTypes, ILogger<GrpcAgentWorker> logger)

Parameters

client AgentRpc.AgentRpcClient

hostApplicationLifetime IHostApplicationLifetime

serviceProvider IServiceProvider

configuredAgentTypes IEnumerable<Tuple<string, Type>>

logger ILogger<GrpcAgentWorker>

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

PublishEventAsync(CloudEvent, CancellationToken)

public ValueTask PublishEventAsync(CloudEvent @event, CancellationToken cancellationToken = default)

Parameters

event CloudEvent

cancellationToken CancellationToken

Returns

ValueTask

ReadAsync(AgentId, CancellationToken)

public ValueTask<AgentState> ReadAsync(AgentId agentId, CancellationToken cancellationToken = default)

Parameters

agentId AgentId

cancellationToken CancellationToken

Returns

ValueTask<AgentState>

SendMessageAsync(Message, CancellationToken)

public ValueTask SendMessageAsync(Message message, CancellationToken cancellationToken = default)

Parameters

message Message

cancellationToken CancellationToken

Returns

ValueTask

SendRequestAsync(Agent, RpcRequest, CancellationToken)

public ValueTask SendRequestAsync(Agent agent, RpcRequest request, CancellationToken cancellationToken = default)

Parameters

agent Agent

request RpcRequest

cancellationToken CancellationToken

Returns

ValueTask

SendResponseAsync(RpcResponse, CancellationToken)

public ValueTask SendResponseAsync(RpcResponse response, CancellationToken cancellationToken = default)

Parameters

response RpcResponse

cancellationToken CancellationToken

Returns

ValueTask

StartAsync(CancellationToken)

Triggered when the application host is ready to start the service.

public Task StartAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Indicates that the start process has been aborted.

Returns

Task

A Task that represents the asynchronous Start operation.

StopAsync(CancellationToken)

Triggered when the application host is performing a graceful shutdown.

public Task StopAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Indicates that the shutdown process should no longer be graceful.

Returns

Task

A Task that represents the asynchronous Stop operation.

StoreAsync(AgentState, CancellationToken)

public ValueTask StoreAsync(AgentState value, CancellationToken cancellationToken = default)

Parameters

value AgentState

cancellationToken CancellationToken

Returns

ValueTask