Class QuerySubscriptionMetadata

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.dll

Represents metadata for a single query subscription.

public sealed record QuerySubscriptionMetadata : IEquatable<QuerySubscriptionMetadata>

Inheritance

object

QuerySubscriptionMetadata

Implements

IEquatable<QuerySubscriptionMetadata>

Inherited Members

object.GetType()

object.Equals(object, object)

object.ReferenceEquals(object, object)

Extension Methods

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Constructors

QuerySubscriptionMetadata()

public QuerySubscriptionMetadata()

Properties

ClientInfo

Gets the client information (headers, user agent, etc.).

public required QuerySubscriptionClientInfo ClientInfo { get; init; }

Property Value

QuerySubscriptionClientInfo

ConnectedAt

Gets when the subscription was first connected.

public required DateTimeOffset ConnectedAt { get; init; }

Property Value

DateTimeOffset

LastDataServedAt

Gets the last time data was served to the client.

public DateTimeOffset? LastDataServedAt { get; set; }

Property Value

DateTimeOffset?

LastPingSentAt

Gets the last time a ping was sent to the client.

public DateTimeOffset? LastPingSentAt { get; set; }

Property Value

DateTimeOffset?

LastPongReceivedAt

Gets the last time a pong was received from the client.

public DateTimeOffset? LastPongReceivedAt { get; set; }

Property Value

DateTimeOffset?

QueryIdentifier

Gets the query identifier (fully qualified query name).

public required string QueryIdentifier { get; init; }

Property Value

string

ReadModelType

Gets the read model type.

public required string ReadModelType { get; init; }

Property Value

string

SubscriptionId

Gets the unique identifier for this subscription (client-generated queryId).

public required string SubscriptionId { get; init; }

Property Value

string

Methods

Equals(QuerySubscriptionMetadata?)

public bool Equals(QuerySubscriptionMetadata? other)

Parameters

other QuerySubscriptionMetadata

Returns

bool

Equals(object?)

public override bool Equals(object? obj)

Parameters

obj object

Returns

bool

GetHashCode()

public override int GetHashCode()

Returns

int

ToString()

public override string ToString()

Returns

string

Operators

operator ==(QuerySubscriptionMetadata?, QuerySubscriptionMetadata?)

public static bool operator ==(QuerySubscriptionMetadata? left, QuerySubscriptionMetadata? right)

Parameters

left QuerySubscriptionMetadata

right QuerySubscriptionMetadata

Returns

bool

operator !=(QuerySubscriptionMetadata?, QuerySubscriptionMetadata?)

public static bool operator !=(QuerySubscriptionMetadata? left, QuerySubscriptionMetadata? right)

Parameters

left QuerySubscriptionMetadata

right QuerySubscriptionMetadata

Returns

bool