wow-query/me.ahoo.wow.query.snapshot.filter

Package-level declarations

Types

object Contexts

CountSnapshotQueryContext

class CountSnapshotQueryContext(val namedAggregate: NamedAggregate, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : SnapshotQueryContext<CountSnapshotQueryContext, Condition, Mono<Long>>

DefaultSnapshotQueryHandler

class DefaultSnapshotQueryHandler(chain: FilterChain<SnapshotQueryContext<*, *, *>>, errorHandler: ErrorHandler<SnapshotQueryContext<*, *, *>> = LogErrorHandler()) : AbstractHandler<SnapshotQueryContext<*, *, *>> , SnapshotQueryHandler

ListSnapshotQueryContext

class ListSnapshotQueryContext<R : Any>(val namedAggregate: NamedAggregate, val queryType: QueryType, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : SnapshotQueryContext<ListSnapshotQueryContext<R>, IListQuery, Flux<R>>

MaskingSnapshotQueryFilter

@Order(value = 2147483647, before = [TailSnapshotQueryFilter::class])

object MaskingSnapshotQueryFilter : SnapshotQueryFilter

PagedSnapshotQueryContext

class PagedSnapshotQueryContext<R : Any>(val namedAggregate: NamedAggregate, val queryType: QueryType, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : SnapshotQueryContext<PagedSnapshotQueryContext<R>, IPagedQuery, Mono<PagedList<R>>>

enum QueryType : Enum<QueryType>

SingleSnapshotQueryContext

class SingleSnapshotQueryContext<R : Any>(val namedAggregate: NamedAggregate, val queryType: QueryType, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : SnapshotQueryContext<SingleSnapshotQueryContext<R>, ISingleQuery, Mono<R>>

SnapshotQueryContext

interface SnapshotQueryContext<SOURCE : SnapshotQueryContext<SOURCE, Q, R>, Q : Any, R : Any>

SnapshotQueryFilter

interface SnapshotQueryFilter : Filter<SnapshotQueryContext<*, *, *>>

SnapshotQueryHandler

interface SnapshotQueryHandler : Handler<SnapshotQueryContext<*, *, *>>

TailSnapshotQueryFilter

@Order(value = 2147483647)

class TailSnapshotQueryFilter<S : Any>(snapshotQueryServiceFactory: SnapshotQueryServiceFactory) : SnapshotQueryFilter

Properties

const val QUERY_KEY: String

const val RESULT_KEY: String