Class GrpcGateway

Namespace

Microsoft.AutoGen.RuntimeGateway.Grpc

Assembly

Microsoft.AutoGen.RuntimeGateway.Grpc.dll

Represents the gRPC gateway service that handles communication between the agent worker and the cluster.

public sealed class GrpcGateway : BackgroundService, IHostedService, IDisposable, IGateway, IGrainObserver, IAddressable

Inheritance

object

BackgroundService

GrpcGateway

Implements

IHostedService

IDisposable

IGateway

IGrainObserver

IAddressable

Inherited Members

BackgroundService.StartAsync(CancellationToken)

BackgroundService.StopAsync(CancellationToken)

BackgroundService.Dispose()

BackgroundService.ExecuteTask

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

GrpcGateway(IClusterClient, ILogger<GrpcGateway>)

Initializes a new instance of the GrpcGateway class.

public GrpcGateway(IClusterClient clusterClient, ILogger<GrpcGateway> logger)

Parameters

clusterClient IClusterClient

The cluster client.

logger ILogger<GrpcGateway>

The logger.

Fields

_controlWorkers

public readonly ConcurrentDictionary<string, GrpcWorkerConnection<ControlMessage>> _controlWorkers

Field Value

ConcurrentDictionary<string, GrpcWorkerConnection<ControlMessage>>

_workers

public readonly ConcurrentDictionary<string, GrpcWorkerConnection<Message>> _workers

Field Value

ConcurrentDictionary<string, GrpcWorkerConnection<Message>>

Methods

ExecuteAsync(CancellationToken)

Executes the background service.

protected override Task ExecuteAsync(CancellationToken stoppingToken)

Parameters

stoppingToken CancellationToken

The cancellation token.

Returns

Task

A task that represents the asynchronous operation.

GetSubscriptionsAsync(GetSubscriptionsRequest, CancellationToken)

Gets the subscriptions asynchronously.

public ValueTask<List<Subscription>> GetSubscriptionsAsync(GetSubscriptionsRequest request, CancellationToken cancellationToken = default)

Parameters

request GetSubscriptionsRequest

The get subscriptions request.

cancellationToken CancellationToken

The cancellation token.

Returns

ValueTask<List<Subscription>>

A task that represents the asynchronous operation. The task result contains the list of subscriptions.

InvokeRequestAsync(RpcRequest, CancellationToken)

Invokes a request asynchronously.

public ValueTask<RpcResponse> InvokeRequestAsync(RpcRequest request, CancellationToken cancellationToken = default)

Parameters

request RpcRequest

The RPC request.

cancellationToken CancellationToken

The cancellation token.

Returns

ValueTask<RpcResponse>

A task that represents the asynchronous operation. The task result contains the RPC response.

RegisterAgentTypeAsync(RegisterAgentTypeRequest, ServerCallContext, CancellationToken)

Registers an agent type asynchronously.

public ValueTask<RegisterAgentTypeResponse> RegisterAgentTypeAsync(RegisterAgentTypeRequest request, ServerCallContext context, CancellationToken cancellationToken = default)

Parameters

request RegisterAgentTypeRequest

The register agent type request.

context ServerCallContext

The server call context.

cancellationToken CancellationToken

The cancellation token.

Returns

ValueTask<RegisterAgentTypeResponse>

A task that represents the asynchronous operation. The task result contains the register agent type response.

SubscribeAsync(AddSubscriptionRequest, CancellationToken)

Subscribes to a topic asynchronously.

public ValueTask<AddSubscriptionResponse> SubscribeAsync(AddSubscriptionRequest request, CancellationToken cancellationToken = default)

Parameters

request AddSubscriptionRequest

The add subscription request.

cancellationToken CancellationToken

The cancellation token.

Returns

ValueTask<AddSubscriptionResponse>

A task that represents the asynchronous operation. The task result contains the add subscription response.

UnsubscribeAsync(RemoveSubscriptionRequest, CancellationToken)

Unsubscribes from a topic asynchronously.

public ValueTask<RemoveSubscriptionResponse> UnsubscribeAsync(RemoveSubscriptionRequest request, CancellationToken cancellationToken = default)

Parameters

request RemoveSubscriptionRequest

The remove subscription request.

cancellationToken CancellationToken

The cancellation token.

Returns

ValueTask<RemoveSubscriptionResponse>

A task that represents the asynchronous operation. The task result contains the remove subscription response.