Class DaprConnectionRepository

Namespace

Virtufin.WebSocketManager.Services

Assembly

Virtufin.WebSocketManager.dll

public class DaprConnectionRepository : IDaprConnectionRepository

Inheritance

object

DaprConnectionRepository

Implements

IDaprConnectionRepository

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

DaprConnectionRepository(StateClient, ILogger<DaprConnectionRepository>, DaprResiliencePipeline, ConnectionStoreOptions)

public DaprConnectionRepository(State.StateClient stateClient, ILogger<DaprConnectionRepository> logger, DaprResiliencePipeline resilience, ConnectionStoreOptions options)

Parameters

stateClient State.StateClient

logger ILogger<DaprConnectionRepository>

resilience DaprResiliencePipeline

options ConnectionStoreOptions

Methods

ClearAllAsync(CancellationToken)

public Task ClearAllAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task

DeleteAsync(string, CancellationToken)

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

Parameters

id string

cancellationToken CancellationToken

Returns

Task

GetAllAsync(CancellationToken)

public Task<IEnumerable<DaprStateStoreEntry>> GetAllAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task<IEnumerable<DaprStateStoreEntry>>

GetAsync(string, CancellationToken)

public Task<DaprStateStoreEntry?> GetAsync(string id, CancellationToken cancellationToken = default)

Parameters

id string

cancellationToken CancellationToken

Returns

Task<DaprStateStoreEntry>

GetByInstanceIdAsync(string, CancellationToken)

public Task<IEnumerable<DaprStateStoreEntry>> GetByInstanceIdAsync(string instanceId, CancellationToken cancellationToken = default)

Parameters

instanceId string

cancellationToken CancellationToken

Returns

Task<IEnumerable<DaprStateStoreEntry>>

SaveAsync(DaprStateStoreEntry, CancellationToken)

public Task SaveAsync(DaprStateStoreEntry entry, CancellationToken cancellationToken = default)

Parameters

entry DaprStateStoreEntry

cancellationToken CancellationToken

Returns

Task

TouchAsync(string, CancellationToken)

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

Parameters

id string

cancellationToken CancellationToken

Returns

Task