Class WebSocketManagerService

Namespace

Virtufin.WebSocketManager.Protos

Assembly

Virtufin.WebSocketManager.dll

public sealed class WebSocketManagerService : WebSocketManager.WebSocketManagerBase

Inheritance

object

WebSocketManager.WebSocketManagerBase

WebSocketManagerService

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

WebSocketManagerService(IWebSocketService, ILogger<WebSocketManagerService>, IInstanceIdProvider, PeerRegistry, PeerChannelCache<WebSocketManagerClient>, IDaprConnectionRepository)

public WebSocketManagerService(IWebSocketService webSocketService, ILogger<WebSocketManagerService> logger, IInstanceIdProvider instanceId, PeerRegistry peerRegistry, PeerChannelCache<WebSocketManager.WebSocketManagerClient> peerChannels, IDaprConnectionRepository connectionStore)

Parameters

webSocketService IWebSocketService

logger ILogger<WebSocketManagerService>

instanceId IInstanceIdProvider

peerRegistry PeerRegistry

peerChannels PeerChannelCache<WebSocketManager.WebSocketManagerClient>

connectionStore IDaprConnectionRepository

Methods

Connect(ConnectRequest, ServerCallContext)

public override Task<ConnectResponse> Connect(ConnectRequest request, ServerCallContext context)

Parameters

request ConnectRequest

context ServerCallContext

Returns

Task<ConnectResponse>

Disconnect(DisconnectRequest, ServerCallContext)

public override Task<DisconnectResponse> Disconnect(DisconnectRequest request, ServerCallContext context)

Parameters

request DisconnectRequest

context ServerCallContext

Returns

Task<DisconnectResponse>

GetTag(GetTagRequest, ServerCallContext)

public override Task<GetTagResponse> GetTag(GetTagRequest request, ServerCallContext context)

Parameters

request GetTagRequest

context ServerCallContext

Returns

Task<GetTagResponse>

GetTags(GetTagsRequest, ServerCallContext)

public override Task<GetTagsResponse> GetTags(GetTagsRequest request, ServerCallContext context)

Parameters

request GetTagsRequest

context ServerCallContext

Returns

Task<GetTagsResponse>

List(ListRequest, ServerCallContext)

public override Task<ListResponse> List(ListRequest request, ServerCallContext context)

Parameters

request ListRequest

context ServerCallContext

Returns

Task<ListResponse>

MapException(Exception)

public static RpcException MapException(Exception ex)

Parameters

ex Exception

Returns

RpcException

Send(SendRequest, ServerCallContext)

public override Task<SendResponse> Send(SendRequest request, ServerCallContext context)

Parameters

request SendRequest

context ServerCallContext

Returns

Task<SendResponse>

SendRaw(SendRawRequest, ServerCallContext)

public override Task<SendRawResponse> SendRaw(SendRawRequest request, ServerCallContext context)

Parameters

request SendRawRequest

context ServerCallContext

Returns

Task<SendRawResponse>

SetTag(SetTagRequest, ServerCallContext)

public override Task<SetTagResponse> SetTag(SetTagRequest request, ServerCallContext context)

Parameters

request SetTagRequest

context ServerCallContext

Returns

Task<SetTagResponse>

SetTags(SetTagsRequest, ServerCallContext)

public override Task<SetTagsResponse> SetTags(SetTagsRequest request, ServerCallContext context)

Parameters

request SetTagsRequest

context ServerCallContext

Returns

Task<SetTagsResponse>

StartPublish(StartPublishRequest, ServerCallContext)

public override Task<StartPublishResponse> StartPublish(StartPublishRequest request, ServerCallContext context)

Parameters

request StartPublishRequest

context ServerCallContext

Returns

Task<StartPublishResponse>

StopPublish(StopPublishRequest, ServerCallContext)

public override Task<StopPublishResponse> StopPublish(StopPublishRequest request, ServerCallContext context)

Parameters

request StopPublishRequest

context ServerCallContext

Returns

Task<StopPublishResponse>