ServerVerticle¶
ServerVerticle is a Verticle (Vert.x).
A verticle is a piece of code that can be deployed by Vert.x (...) to provide an actor-like deployment and concurrency model, out of the box.
Creating Instance¶
ServerVerticle takes the following to be created:
- Endpoints
-
HttpServerOptions(Vert.x) - Server
-
isInternalListenerflag -
PullQueryExecutorMetrics -
LoggingRateLimiter
ServerVerticle is created when:
Serveris requested to start
Starting Verticle¶
void start(
Promise<Void> startPromise)
start creates a ConnectionQueryManager.
start creates an HttpServer (Vert.x) (with the HttpServerOptions) and registers the request handlers.
start is part of the Verticle (Vert.x) abstraction.
URIs¶
Router setupRouter()
setupRouter registers the query handlers.
| URI | HTTP Method | Handler |
|---|---|---|
/ | GET | ServerVerticle::handleInfoRedirect |
/close-query | POST | CloseQueryHandler |
/clusterStatus | GET | this::handleClusterStatusRequest |
/healthcheck | GET | this::handleHealthcheckRequest |
/heartbeat | POST | this::handleHeartbeatRequest |
/info | GET | this::handleInfoRequest |
/inserts-stream | POST | InsertsStreamHandler |
/is_valid_property/:property | GET | this::handleIsValidPropertyRequest |
/ksql | POST | handleKsqlRequest |
/ksql/terminate | POST | this::handleTerminateRequest |
/lag | POST | this::handleLagReportRequest |
/query | POST | this::handleQueryRequest |
/query-stream | POST | QueryStreamHandler |
/status/:type/:entity/:action | GET | this::handleStatusRequest |
/status | GET | this::handleAllStatusesRequest |
/v1/metadata | GET | this::handleServerMetadataRequest |
/v1/metadata/id | GET | this::handleServerMetadataClusterIdRequest |
/ws/query | GET | this::handleWebsocket |
Handling KsqlRequest¶
void handleKsqlRequest(
RoutingContext routingContext)
handleKsqlRequest requests the Endpoints to execute the KsqlRequest.