Interface IQueryPipeline

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.dll

Defines a system can execute queries.

public interface IQueryPipeline

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

Methods

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

Performs the given query.

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.