@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public interface EndpointObserver
IOException
are reported back to client.CoprocessorHost.ABORT_ON_ERROR_KEY
is set to true, then the
server aborts.DoNotRetryIOException
is returned to the client.Modifier and Type | Method and Description |
---|---|
default void |
postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx,
com.google.protobuf.Service service,
String methodName,
com.google.protobuf.Message request,
com.google.protobuf.Message.Builder responseBuilder)
Called after an Endpoint service method is invoked.
|
default com.google.protobuf.Message |
preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx,
com.google.protobuf.Service service,
String methodName,
com.google.protobuf.Message request)
Called before an Endpoint service method is invoked.
|
default com.google.protobuf.Message preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request) throws IOException
ObserverContext.bypass()
has no effect in this
hook.ctx
- the environment provided by the region serverservice
- the endpoint servicerequest
- Request message expected by given Service
's method (by the name
methodName
).methodName
- the invoked service methodIOException
default void postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request, com.google.protobuf.Message.Builder responseBuilder) throws IOException
ctx
- the environment provided by the region serverservice
- the endpoint servicemethodName
- the invoked service methodrequest
- Request message expected by given Service
's method (by the name
methodName
).responseBuilder
- Builder for final response to the client, with original response from
Service's method merged into it.IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.