Class QueryPipeline

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.dll

Represents a query pipeline.

public class QueryPipeline : IQueryPipeline

Inheritance

object

QueryPipeline

Implements

IQueryPipeline

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

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

QueryPipeline(ICorrelationIdAccessor, IQueryContextManager, IQueryFilters, IQueryPerformerProviders, IQueryRenderers, IReadModelInterceptors, IDiscoverableValidators, IActivitySource<QueryPipeline>)

Represents a query pipeline.

public QueryPipeline(ICorrelationIdAccessor correlationIdAccessor, IQueryContextManager queryContextManager, IQueryFilters queryFilters, IQueryPerformerProviders queryPerformerProviders, IQueryRenderers queryRenderers, IReadModelInterceptors readModelInterceptors, IDiscoverableValidators discoverableValidators, IActivitySource<QueryPipeline> activitySource)

Parameters

correlationIdAccessor ICorrelationIdAccessor

Accessor for the current correlation ID.

queryContextManager IQueryContextManager

Manages the current query context.

queryFilters IQueryFilters

The query filters.

queryPerformerProviders IQueryPerformerProviders

The query performer providers.

queryRenderers IQueryRenderers

The query renderers.

readModelInterceptors IReadModelInterceptors

The IReadModelInterceptors for intercepting read models.

discoverableValidators IDiscoverableValidators

The IDiscoverableValidators for validating paging and sorting.

activitySource IActivitySource<QueryPipeline>

The IActivitySource<T> for tracing.

Methods

Perform(FullyQualifiedQueryName, QueryArguments, Paging, Sorting, IServiceProvider, CancellationToken)

Performs the given query.

public Task<QueryResult> Perform(FullyQualifiedQueryName queryName, QueryArguments arguments, Paging paging, Sorting sorting, IServiceProvider serviceProvider, CancellationToken cancellationToken = default)

Parameters

queryName FullyQualifiedQueryName

The name of the query to perform.

arguments QueryArguments

The arguments for the query.

paging Paging

The paging to apply to the query.

sorting Sorting

The sorting to apply to the query.

serviceProvider IServiceProvider

The IServiceProvider scoped to the current request, used to resolve dependencies.

cancellationToken CancellationToken

The CancellationToken for cancelling the query.

Returns

Task<QueryResult>

A QueryResult representing the result of executing the command.