Uses of Class
com.soklet.Request
Packages that use Request
-
Uses of Request in com.soklet
Methods in com.soklet that return RequestModifier and TypeMethodDescriptionRequest.PathBuilder.build()Request.RawBuilder.build()Request.Copier.finish()Request.fromPath(@NonNull HttpMethod httpMethod, @NonNull String path) Creates aRequestfrom a path without additional customization.Request.fromRawUrl(@NonNull HttpMethod httpMethod, @NonNull String rawUrl) Creates aRequestfrom a raw request target without additional customization.McpAdmissionContext.getRequest()Provides the transport request being evaluated for admission.McpInitializationContext.getRequest()Provides the transport request that carried theinitializecall.McpRequestContext.getRequest()Provides the transport request being handled.SseConnection.getRequest()The request made by the client to the Event Source Method which accepted the SSE handshake and established the connection.McpCorsContext.request()Returns the value of therequestrecord component.Methods in com.soklet that return types with arguments of type RequestModifier and TypeMethodDescriptionLogEvent.getRequest()The request associated with this log event, if available.Methods in com.soklet with parameters of type RequestModifier and TypeMethodDescriptionAuthorizes a non-preflight CORS request.CorsAuthorizer.authorizePreflight(@NonNull Request request, @NonNull CorsPreflight corsPreflight, @NonNull Map<@NonNull HttpMethod, @NonNull ResourceMethod> availableResourceMethodsByHttpMethod) Authorizes a CORS preflight request.default voidLifecycleObserver.didCreateMcpSession(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull String sessionId) Called after an MCP session is durably created.default voidMetricsCollector.didCreateMcpSession(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull String sessionId) Called after an MCP session is durably created.default voidLifecycleObserver.didEstablishMcpSseStream(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull String sessionId) Called after an MCP GET stream is established.default voidMetricsCollector.didEstablishMcpSseStream(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull String sessionId) Called after an MCP GET stream is established.default voidLifecycleObserver.didFailToEstablishSseConnection(@NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull SseConnection.HandshakeFailureReason reason, @Nullable Throwable throwable) Called if an SSE connection fails to establish.default voidMetricsCollector.didFailToEstablishSseConnection(@NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull SseConnection.HandshakeFailureReason reason, @Nullable Throwable throwable) Called if an SSE connection fails to establish.default voidLifecycleObserver.didFailToWriteResponse(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse, @NonNull Duration responseWriteDuration, @NonNull Throwable throwable) Called after response data fails to write.default voidMetricsCollector.didFailToWriteResponse(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse, @NonNull Duration responseWriteDuration, @NonNull Throwable throwable) Called after response data fails to write.default voidLifecycleObserver.didFinishMcpRequestHandling(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @Nullable String sessionId, @NonNull String jsonRpcMethod, @Nullable McpJsonRpcRequestId jsonRpcRequestId, @NonNull McpRequestOutcome requestOutcome, @Nullable McpJsonRpcError jsonRpcError, @NonNull Duration duration, @NonNull List<@NonNull Throwable> throwables) Called after MCP JSON-RPC request handling finishes.default voidMetricsCollector.didFinishMcpRequestHandling(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @Nullable String sessionId, @NonNull String jsonRpcMethod, @Nullable McpJsonRpcRequestId jsonRpcRequestId, @NonNull McpRequestOutcome requestOutcome, @Nullable McpJsonRpcError jsonRpcError, @NonNull Duration duration, @NonNull List<@NonNull Throwable> throwables) Called after MCP JSON-RPC request handling finishes.default voidLifecycleObserver.didFinishRequestHandling(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse, @NonNull Duration duration, @NonNull List<@NonNull Throwable> throwables) Called after a request finishes processing.default voidMetricsCollector.didFinishRequestHandling(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse, @NonNull Duration duration, @NonNull List<@NonNull Throwable> throwables) Called after a request finishes processing.default voidLifecycleObserver.didStartMcpRequestHandling(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @Nullable String sessionId, @NonNull String jsonRpcMethod, @Nullable McpJsonRpcRequestId jsonRpcRequestId) Called after a valid MCP JSON-RPC request begins handling.default voidMetricsCollector.didStartMcpRequestHandling(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @Nullable String sessionId, @NonNull String jsonRpcMethod, @Nullable McpJsonRpcRequestId jsonRpcRequestId) Called after a valid MCP JSON-RPC request begins handling.default voidLifecycleObserver.didStartRequestHandling(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod) Called as soon as a request is received and a Resource Method has been resolved to handle it.default voidMetricsCollector.didStartRequestHandling(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod) Called as soon as a request is received and a Resource Method has been resolved to handle it.default voidLifecycleObserver.didTerminateMcpSseStream(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull String sessionId, @NonNull Duration connectionDuration, @NonNull McpStreamTerminationReason terminationReason, @Nullable Throwable throwable) Called after an MCP GET stream is terminated.default voidMetricsCollector.didTerminateMcpSseStream(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull String sessionId, @NonNull Duration connectionDuration, @NonNull McpStreamTerminationReason terminationReason, @Nullable Throwable throwable) Called after an MCP GET stream is terminated.default voidLifecycleObserver.didWriteResponse(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse, @NonNull Duration responseWriteDuration) Called after response data is written.default voidMetricsCollector.didWriteResponse(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse, @NonNull Duration responseWriteDuration) Called after response data is written.MultipartParser.extractMultipartFields(@NonNull Request request) Given a request, detect all HTML form fields withmultipart/form-dataencoding and parse their values.ResponseMarshaler.forContentTooLarge(@NonNull Request request, @Nullable ResourceMethod resourceMethod) Prepares a response for a request that triggers an HTTP 413 Content Too Large.ResponseMarshaler.forCorsAllowed(@NonNull Request request, @NonNull Cors cors, @NonNull CorsResponse corsResponse, @NonNull MarshaledResponse marshaledResponse) Applies "CORS is permitted for this request" data to a response.ResponseMarshaler.forCorsPreflightAllowed(@NonNull Request request, @NonNull CorsPreflight corsPreflight, @NonNull CorsPreflightResponse corsPreflightResponse) Prepares a response for "CORS preflight allowed" scenario when yourCorsAuthorizerapproves a preflight request.ResponseMarshaler.forCorsPreflightRejected(@NonNull Request request, @NonNull CorsPreflight corsPreflight) Prepares a response for "CORS preflight rejected" scenario when yourCorsAuthorizerdenies a preflight request.ResponseMarshaler.forHead(@NonNull Request request, @NonNull MarshaledResponse getMethodMarshaledResponse) Prepares a response for an HTTPHEADrequest.ResponseMarshaler.forMethodNotAllowed(@NonNull Request request, @NonNull Set<@NonNull HttpMethod> allowedHttpMethods) Prepares a response for a request that triggers an HTTP 405 Method Not Allowed.ResponseMarshaler.forNotFound(@NonNull Request request) Prepares a response for a request that does not have a matching Resource Method, which triggers an HTTP 404 Not Found.ResponseMarshaler.forOptions(@NonNull Request request, @NonNull Set<@NonNull HttpMethod> allowedHttpMethods) Prepares a response for an HTTPOPTIONSrequest.ResponseMarshaler.forOptionsSplat(@NonNull Request request) Prepares a response for an HTTPOPTIONS *(colloquially, "OPTIONSSplat") request.ResponseMarshaler.forResourceMethod(@NonNull Request request, @NonNull Response response, @NonNull ResourceMethod resourceMethod) Prepares a response for a request that was matched to a Resource Method and returned normally (i.e., without throwing an exception).ResponseMarshaler.forServiceUnavailable(@NonNull Request request, @Nullable ResourceMethod resourceMethod) Prepares a response for a request that is rejected because the server is overloaded (e.g. connection limit reached), triggering an HTTP 503 Service Unavailable.ResponseMarshaler.forThrowable(@NonNull Request request, @NonNull Throwable throwable, @Nullable ResourceMethod resourceMethod) Prepares a response for scenarios in which an uncaught exception is encountered.IdGenerator.generateId(@NonNull Request request) Generates an identifier for the givenRequest.ResponseMarshaler.Builder.ContentTooLargeHandler.handle(@NonNull Request request, @Nullable ResourceMethod resourceMethod) Prepares a response for a request that triggers an HTTP 413 Content Too Large.ResponseMarshaler.Builder.CorsAllowedHandler.handle(@NonNull Request request, @NonNull Cors cors, @NonNull CorsResponse corsResponse, @NonNull MarshaledResponse marshaledResponse) Applies "CORS is permitted for this request" data to a response.ResponseMarshaler.Builder.CorsPreflightAllowedHandler.handle(@NonNull Request request, @NonNull CorsPreflight corsPreflight, @NonNull CorsPreflightResponse corsPreflightResponse) Prepares a response for "CORS preflight allowed" scenario when yourCorsAuthorizerapproves a preflight request.ResponseMarshaler.Builder.CorsPreflightRejectedHandler.handle(@NonNull Request request, @NonNull CorsPreflight corsPreflight) Prepares a response for "CORS preflight rejected" scenario when yourCorsAuthorizerdenies a preflight request.ResponseMarshaler.Builder.HeadHandler.handle(@NonNull Request request, @NonNull MarshaledResponse getMethodMarshaledResponse) Prepares a response for an HTTPHEADrequest.ResponseMarshaler.Builder.MethodNotAllowedHandler.handle(@NonNull Request request, @NonNull Set<@NonNull HttpMethod> allowedHttpMethods) Prepares a response for a request that triggers an HTTP 405 Method Not Allowed.Prepares a response for a request that triggers an HTTP 404 Not Found.ResponseMarshaler.Builder.OptionsHandler.handle(@NonNull Request request, @NonNull Set<@NonNull HttpMethod> allowedHttpMethods) Prepares a response for an HTTPOPTIONSrequest.Prepares a response for an HTTPOPTIONS *(colloquially, "OPTIONSSplat") request.ResponseMarshaler.Builder.ResourceMethodHandler.handle(@NonNull Request request, @NonNull Response response, @NonNull ResourceMethod resourceMethod) Prepares a response for the scenario in which the request was matched to a Resource Method and executed non-exceptionally.ResponseMarshaler.Builder.ServiceUnavailableHandler.handle(@NonNull Request request, @Nullable ResourceMethod resourceMethod) Prepares a response for a request that triggers an HTTP 503 Service Unavailable.ResponseMarshaler.Builder.ThrowableHandler.handle(@NonNull Request request, @NonNull Throwable throwable, @Nullable ResourceMethod resourceMethod) Prepares a response for scenarios in which an uncaught exception is encountered.voidHttpServer.RequestHandler.handleRequest(@NonNull Request request, @NonNull Consumer<HttpRequestResult> requestResultConsumer) Callback to be invoked by aHttpServerimplementation after it has received an HTTP request but prior to writing an HTTP response.voidMcpServer.RequestHandler.handleRequest(@NonNull Request request, @NonNull Consumer<HttpRequestResult> requestResultConsumer) Handles an MCP transport request.voidSseServer.RequestHandler.handleRequest(@NonNull Request request, @NonNull Consumer<HttpRequestResult> requestResultConsumer) Callback to be invoked by aSseServerimplementation after it has received a Server-Sent Event Source HTTP request but prior to writing initial data to the HTTP response.default voidRequestInterceptor.interceptRequest(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull Function<Request, MarshaledResponse> responseGenerator, @NonNull Consumer<MarshaledResponse> responseWriter) Intercepts request processing, allowing the request to be replaced and/or the response to be transformed.RequestBodyMarshaler.marshalRequestBody(@NonNull Request request, @NonNull ResourceMethod resourceMethod, @NonNull Parameter parameter, @NonNull Type requestBodyType) Given a request, the Resource Method that will handle it, and aRequestBody-annotated parameter + its type, convert the request body bytes into an instance of typerequestBodyType.ResourceMethodParameterProvider.parameterValuesForResourceMethod(@NonNull Request request, @NonNull ResourceMethod resourceMethod) For the givenrequestandresourceMethod, vends the list of parameters to use when invoking the underlying Java method located atResourceMethod.getMethod().Simulator.performHttpRequest(@NonNull Request request) Given a request that would normally be handled by your standardHttpServer, process it and return response data (both logicalResponse, if present, and theMarshaledResponsebytes to be sent over the wire) as well as the matching Resource Method, if available.default @NonNull McpRequestResultSimulator.performMcpRequest(@NonNull Request request) Given a request that would normally be handled by your MCP server, process it and return the corresponding MCP-oriented simulator result.Simulator.performSseRequest(@NonNull Request request) Given a request that would normally be handled by yourSseServer(that is, for a Resource Method decorated with theSseEventSourceannotation), process it and return response data (SseRequestResult.HandshakeAccepted,SseRequestResult.HandshakeRejected, orSseRequestResult.RequestFailed);ResourceMethodResolver.resourceMethodForRequest(@NonNull Request request, @NonNull ServerType serverType) Given an HTTP request, provide a matching Resource Method to invoke.default voidLifecycleObserver.willEstablishSseConnection(@NonNull Request request, @Nullable ResourceMethod resourceMethod) Called before an SSE connection is established.default voidMetricsCollector.willEstablishSseConnection(@NonNull Request request, @Nullable ResourceMethod resourceMethod) Called before an SSE connection is established.default voidLifecycleObserver.willTerminateMcpSseStream(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull String sessionId, @NonNull McpStreamTerminationReason terminationReason, @Nullable Throwable throwable) Called before an MCP GET stream is terminated.default voidLifecycleObserver.willWriteResponse(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse) Called before response data is written.default voidMetricsCollector.willWriteResponse(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull MarshaledResponse marshaledResponse) Called before response data is written.Utilities.EffectiveOriginResolver.withRequest(@NonNull Request request, @NonNull Utilities.EffectiveOriginResolver.TrustPolicy trustPolicy) Acquires a builder seeded with aRequestand a trust policy.default voidRequestInterceptor.wrapRequest(@NonNull ServerType serverType, @NonNull Request request, @NonNull Consumer<Request> requestProcessor) Called before Soklet begins request processing, allowing the request to be wrapped or replaced.Method parameters in com.soklet with type arguments of type RequestModifier and TypeMethodDescriptiondefault voidRequestInterceptor.interceptRequest(@NonNull ServerType serverType, @NonNull Request request, @Nullable ResourceMethod resourceMethod, @NonNull Function<Request, MarshaledResponse> responseGenerator, @NonNull Consumer<MarshaledResponse> responseWriter) Intercepts request processing, allowing the request to be replaced and/or the response to be transformed.default voidRequestInterceptor.wrapRequest(@NonNull ServerType serverType, @NonNull Request request, @NonNull Consumer<Request> requestProcessor) Called before Soklet begins request processing, allowing the request to be wrapped or replaced.Constructors in com.soklet with parameters of type RequestModifierConstructorDescriptionMcpCorsContext(@NonNull Request request, @NonNull Class<? extends McpEndpoint> endpointClass, @NonNull HttpMethod httpMethod, @Nullable String origin, @Nullable String sessionId) Creates an instance of aMcpCorsContextrecord class.