@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public interface EndpointObserver extends Coprocessor
Coprocessor.StatePRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION| Modifier and Type | Method and Description |
|---|---|
void |
postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx,
Service service,
String methodName,
Message request,
Message.Builder responseBuilder)
Called after an Endpoint service method is invoked.
|
Message |
preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx,
Service service,
String methodName,
Message request)
Called before an Endpoint service method is invoked.
|
start, stopMessage preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, Service service, String methodName, Message request) throws IOException
ObserverContext.bypass() has no
effect in this hook.ctx - the environment provided by the region serverservice - the endpoint servicemethodName - the invoked service methodrequest - the request messageIOExceptionvoid postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, Service service, String methodName, Message request, Message.Builder responseBuilder) throws IOException
ctx - the environment provided by the region serverservice - the endpoint servicemethodName - the invoked service methodrequest - the request messageresponseBuilder - the response message builderIOException