Class QuerySubscriptionAggregate

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.dll

Represents a query-centric view of all active subscriptions for a single query.

public sealed record QuerySubscriptionAggregate : IEquatable<QuerySubscriptionAggregate>

Inheritance

object

QuerySubscriptionAggregate

Implements

IEquatable<QuerySubscriptionAggregate>

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>)

Remarks

QueryName matches the queryName property of the generated TypeScript proxy exactly, enabling cross-stack correlation between frontend cache diagnostics and backend subscription state regardless of transport mode (multiplexed WebSocket or direct SSE).

Constructors

QuerySubscriptionAggregate()

public QuerySubscriptionAggregate()

Properties

QueryName

Gets the fully qualified query name (e.g. MyApp.Authors.Listing.AllAuthors). Matches the queryName property on the generated TypeScript proxy.

public required string QueryName { get; init; }

Property Value

string

Subscribers

Gets all active subscribers for this query, one entry per physical connection/subscription pair.

public required IReadOnlyList<QuerySubscriber> Subscribers { get; init; }

Property Value

IReadOnlyList<QuerySubscriber>

TotalSubscriptions

Gets the total number of active subscribers for this query.

public int TotalSubscriptions { get; }

Property Value

int

Methods

Equals(QuerySubscriptionAggregate?)

public bool Equals(QuerySubscriptionAggregate? other)

Parameters

other QuerySubscriptionAggregate

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 ==(QuerySubscriptionAggregate?, QuerySubscriptionAggregate?)

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

Parameters

left QuerySubscriptionAggregate

right QuerySubscriptionAggregate

Returns

bool

operator !=(QuerySubscriptionAggregate?, QuerySubscriptionAggregate?)

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

Parameters

left QuerySubscriptionAggregate

right QuerySubscriptionAggregate

Returns

bool