Class PubsubService

Namespace

Virtufin.Api.Services

Assembly

Virtufin.Api.dll

Implements the Pubsub gRPC service for publish/subscribe messaging via Dapr. Publish receives a CloudEvent proto; Subscribe streams reconstructed CloudEvents.

public class PubsubService : Pubsub.PubsubBase

Inheritance

object

Pubsub.PubsubBase

PubsubService

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PubsubService(DaprClient, IServiceProvider, PubsubSubscriptionManager, TopicDaprSubscriptionRegistry, ILogger<PubsubService>)

public PubsubService(DaprClient daprClient, IServiceProvider serviceProvider, PubsubSubscriptionManager subscriptionManager, TopicDaprSubscriptionRegistry registry, ILogger<PubsubService> logger)

Parameters

daprClient DaprClient

serviceProvider IServiceProvider

subscriptionManager PubsubSubscriptionManager

registry TopicDaprSubscriptionRegistry

logger ILogger<PubsubService>

Methods

PublishEvent(PublishRequest, ServerCallContext)

public override Task<PublishResponse> PublishEvent(PublishRequest request, ServerCallContext context)

Parameters

request PublishRequest

context ServerCallContext

Returns

Task<PublishResponse>

Subscribe(SubscribeRequest, IServerStreamWriter<SubscribeResponse>, ServerCallContext)

Subscribe to one or more Dapr topics. Each topic gets its own Dapr subscription; all messages are multiplexed into a single response stream.

public override Task Subscribe(SubscribeRequest request, IServerStreamWriter<SubscribeResponse> responseStream, ServerCallContext context)

Parameters

request SubscribeRequest

responseStream IServerStreamWriter<SubscribeResponse>

context ServerCallContext

Returns

Task

Unsubscribe(UnsubscribeRequest, ServerCallContext)

public override Task<UnsubscribeResponse> Unsubscribe(UnsubscribeRequest request, ServerCallContext context)

Parameters

request UnsubscribeRequest

context ServerCallContext

Returns

Task<UnsubscribeResponse>