Package ch.rswk.meta.engine

Class ActionService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

ch.rswk.meta.engine.AbstractEngineIdleService<ActionService.ActionServiceConfig>

ch.rswk.meta.engine.ActionService

All Implemented Interfaces:

EngineServices.ConfigurableService<ActionService.ActionServiceConfig>, EngineServices.InfoProvidingService, com.google.common.util.concurrent.Service

@Singleton
public class ActionService
extends AbstractEngineIdleService<ActionService.ActionServiceConfig>

ActionService receives and dispatches MetaAction to services that are registered to handle them. Does validation of parameter and result schemas, in case schemas are defined.

See Also:

• registerExecuteDelegate(String, ActionExecuteDelegate)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ActionService.AbstractActionExecuteDelegate<T,R>
static interface	ActionService.ActionExecuteDelegate
static final record	ActionService.ActionServiceConfig
private static final record	ActionService.DelegateWrapper

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<String,ActionService.DelegateWrapper>	delegates
private com.codahale.metrics.Meter	executeErrorMeter
private com.codahale.metrics.Meter	executeMeter
private static final Protocol.ErrorReplyFactory	EXECUTION_ERROR
private static final Protocol.ErrorReplyFactory	INVALID_PARAM_ERROR
private static final Protocol.ErrorReplyFactory	INVALID_RESULT_ERROR
private static final org.slf4j.Logger	LOG
private final MetaService	metaService
private static final Protocol.ErrorReplyFactory	NO_ACTIONID_ERROR
private com.codahale.metrics.Meter	paramErrorMeter
private com.codahale.metrics.Meter	resultErrorMeter
private static final Protocol.ErrorReplyFactory	UNHANDLED_ACTION_ERROR
private static final Protocol.ErrorReplyFactory	UNKNOWN_ACTION_ERROR
private final MetaValidator	validator

Fields inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

runtime

Constructor Summary

Constructors

Constructor	Description
ActionService(ActionService.ActionServiceConfig config, MetaService metaService, EngineRuntime runtime, MetaValidator validator)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<ExecuteReply>	execute(@Nullable String clientId, @Nullable String ipAddress, ExecuteRequest request, @Nullable String userName)
com.google.common.util.concurrent.ListenableFuture<Void>	registerExecuteDelegate(String actionId, ActionService.ActionExecuteDelegate delegate)
protected void	shutDown()
protected void	startUp()

Methods inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

configClass, configReference, onConfigWatcherNotification, serviceId, serviceName

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ch.rswk.meta.engine.EngineServices.ConfigurableService

config, handleConfigWatcherNotification, onConfigChanged

Methods inherited from interface ch.rswk.meta.engine.EngineServices.InfoProvidingService

getServiceInfo

Field Details

LOG

private static final org.slf4j.Logger LOG

EXECUTION_ERROR

private static final Protocol.ErrorReplyFactory EXECUTION_ERROR

INVALID_PARAM_ERROR

private static final Protocol.ErrorReplyFactory INVALID_PARAM_ERROR

INVALID_RESULT_ERROR

private static final Protocol.ErrorReplyFactory INVALID_RESULT_ERROR

NO_ACTIONID_ERROR

private static final Protocol.ErrorReplyFactory NO_ACTIONID_ERROR

UNHANDLED_ACTION_ERROR

private static final Protocol.ErrorReplyFactory UNHANDLED_ACTION_ERROR

UNKNOWN_ACTION_ERROR

private static final Protocol.ErrorReplyFactory UNKNOWN_ACTION_ERROR

delegates

private final Map<String,ActionService.DelegateWrapper> delegates

metaService

private final MetaService metaService

validator

private final MetaValidator validator

executeErrorMeter

private com.codahale.metrics.Meter executeErrorMeter

executeMeter

private com.codahale.metrics.Meter executeMeter

paramErrorMeter

private com.codahale.metrics.Meter paramErrorMeter

resultErrorMeter

private com.codahale.metrics.Meter resultErrorMeter

Constructor Details

ActionService

@Inject
public ActionService(ActionService.ActionServiceConfig config,
 MetaService metaService,
 EngineRuntime runtime,
 MetaValidator validator)

Method Details

execute

public com.google.common.util.concurrent.ListenableFuture<ExecuteReply> execute(@Nullable String clientId,
 @Nullable String ipAddress,
 ExecuteRequest request,
 @Nullable String userName)

registerExecuteDelegate

public com.google.common.util.concurrent.ListenableFuture<Void> registerExecuteDelegate(String actionId,
 ActionService.ActionExecuteDelegate delegate)

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class AbstractEngineIdleService<ActionService.ActionServiceConfig>

Throws:

Exception

shutDown

protected void shutDown()
                 throws Exception

Overrides:

shutDown in class AbstractEngineIdleService<ActionService.ActionServiceConfig>

Throws:

Exception