@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public interface EndpointObserver extends Coprocessor
Coprocessor.State
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Modifier and Type | Method and Description |
---|---|
void |
postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx,
Service service,
java.lang.String methodName,
Message request,
Message.Builder responseBuilder)
Called after an Endpoint service method is invoked.
|
Message |
preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx,
Service service,
java.lang.String methodName,
Message request)
Called before an Endpoint service method is invoked.
|
start, stop
Message preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, Service service, java.lang.String methodName, Message request) throws java.io.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 messagejava.io.IOException
void postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, Service service, java.lang.String methodName, Message request, Message.Builder responseBuilder) throws java.io.IOException
ctx
- the environment provided by the region serverservice
- the endpoint servicemethodName
- the invoked service methodrequest
- the request messageresponseBuilder
- the response message builderjava.io.IOException