QuerySchemaEndpoint

@Endpoint(id = "wowQuerySchema")
class QuerySchemaEndpoint(catalog: QuerySchemaCatalog)

wowQuerySchema: per-instance query schema versions, and a manual revalidation. Replicas can differ while they revalidate; compare their versions here.

Constructors

Link copied to clipboard
constructor(catalog: QuerySchemaCatalog)

Functions

Link copied to clipboard
@WriteOperation
fun revalidate(@Nullable aggregate: String?): Mono<List<QuerySchemaCatalog.Status>>

Reloads every schema, or only aggregate's (context.aggregate, alias form).

Link copied to clipboard
@ReadOperation
fun versions(): Mono<List<QuerySchemaCatalog.Status>>