Class DistributedWebSocketConnectionStore

Namespace

Virtufin.WebSocketManager.Services

Assembly

Virtufin.WebSocketManager.dll

Distributed implementation of IWebSocketConnectionStore that uses Dapr state store for persistence.

public class DistributedWebSocketConnectionStore : IWebSocketConnectionStore

Inheritance

object

DistributedWebSocketConnectionStore

Implements

IWebSocketConnectionStore

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

DistributedWebSocketConnectionStore(IDaprConnectionRepository, IInstanceIdProvider)

Initializes a new instance of the DistributedWebSocketConnectionStore class.

public DistributedWebSocketConnectionStore(IDaprConnectionRepository repository, IInstanceIdProvider instanceIdProvider)

Parameters

repository IDaprConnectionRepository

The Dapr connection repository for persistence.

instanceIdProvider IInstanceIdProvider

The instance ID provider.

Methods

ClearAllConnectionsAsync(CancellationToken)

Removes all WebSocket connections.

public Task ClearAllConnectionsAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task

CreateConnectionAsync(string, bool, CancellationToken)

Creates a new WebSocket connection entry.

public ValueTask<WebSocketConnection> CreateConnectionAsync(string url, bool autoReconnect, CancellationToken cancellationToken = default)

Parameters

url string

autoReconnect bool

cancellationToken CancellationToken

Returns

ValueTask<WebSocketConnection>

GetAllConnectionsAsync(CancellationToken)

Gets all WebSocket connections.

public Task<IEnumerable<WebSocketConnection>> GetAllConnectionsAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task<IEnumerable<WebSocketConnection>>

GetConnectionAsync(string, CancellationToken)

Gets a WebSocket connection by its ID.

public Task<WebSocketConnection?> GetConnectionAsync(string id, CancellationToken cancellationToken = default)

Parameters

id string

cancellationToken CancellationToken

Returns

Task<WebSocketConnection>

RemoveConnectionAsync(string, CancellationToken)

Removes a WebSocket connection by its ID.

public Task RemoveConnectionAsync(string id, CancellationToken cancellationToken = default)

Parameters

id string

cancellationToken CancellationToken

Returns

Task

UpdateConnectionAsync(WebSocketConnection, CancellationToken)

Updates an existing WebSocket connection.

public Task UpdateConnectionAsync(WebSocketConnection connection, CancellationToken cancellationToken = default)

Parameters

connection WebSocketConnection

cancellationToken CancellationToken

Returns

Task