public class SbcComputeEvenClusterLoadPlanEvent extends SbcEvent
SbcEvent.SbcEventHandlerResult
eventContext, LOG
Constructor and Description |
---|
SbcComputeEvenClusterLoadPlanEvent(SbcContext context,
kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.EvenClusterLoadPlanInternal> callback) |
Modifier and Type | Method and Description |
---|---|
protected SbcEvent.SbcEventHandlerResult |
handleEvent()
The "business logic" of an SbcEvent.
|
protected void |
respondToClient(org.apache.kafka.common.requests.ApiError error,
SbcEvent.SbcEventHandlerResult result)
Responds to the client with an error or a value.
|
public SbcComputeEvenClusterLoadPlanEvent(SbcContext context, kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.EvenClusterLoadPlanInternal> callback)
@Nonnull protected SbcEvent.SbcEventHandlerResult handleEvent()
SbcEvent
handleEvent
in class SbcEvent
protected void respondToClient(org.apache.kafka.common.requests.ApiError error, SbcEvent.SbcEventHandlerResult result)
Successful event processing will not respond to the client.
Issues during event processing will respond to the client with the corresponding exception.
Otherwise, the callback, which is passed down to the Data Balance Engine, will handle responding with a value, if such is computed, or an error, if such arises during plan computation.
respondToClient
in class SbcEvent
error
- the ApiError value for success or failure. handelEvent operations which completed
normally will have a result of ApiError.NONE.result
- The SbcEventHandlerResult which was returned from handleEvent()
}.