com.gremlin

Class GremlinService

java.lang.Object

com.gremlin.GremlinService

public abstract class GremlinService
extends java.lang.Object

High-level orchestration of calls to Gremlin API. This provides a buffer between accessing experiments for Traffic Coordinates (getExperiment(TrafficCoordinates)) and actual calls to the Gremlin API. A user obtains an instance of GremlinService by invoking GremlinServiceFactory.getGremlinService(). The GremlinServiceFactory accepts GremlinCoordinatesProvider and GremlinConfigurationResolver as arguments, so those may be supplied if that functionality is opted into. The GremlinService is used in the injection points created by the user. It's an argument to the Gremlin-provided injection points, and also has methods like execute(TrafficCoordinates, Runnable) and execute(TrafficCoordinates, Supplier) to wrap arbitrary units of work in fault-injection.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GremlinService()

Method Summary

Modifier and Type	Method and Description
void	execute(TrafficCoordinates trafficCoordinates, java.lang.Runnable underlying)
<T> T	execute(TrafficCoordinates trafficCoordinates, java.util.function.Supplier<T> underlying)
abstract java.util.Optional<ExperimentImpact>	getExperiment(TrafficCoordinates trafficCoordinates) Given a specific injection point (TrafficCoordinates), find an impact to inject, if applicable.
abstract boolean	hasExperiments() Determine if any experiments are currently cached.
abstract void	shutdown() Shutdown all Gremlin resources
void	tryInjectImpact(java.lang.String clazz, java.lang.String method)
java.lang.Runnable	wrap(TrafficCoordinates trafficCoordinates, java.lang.Runnable underlying)
<T> java.util.function.Supplier<T>	wrap(TrafficCoordinates trafficCoordinates, java.util.function.Supplier<T> underlying)

Methods inherited from class java.lang.Object

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

Constructor Detail

GremlinService

protected GremlinService()

Method Detail

tryInjectImpact

public void tryInjectImpact(java.lang.String clazz,
                            java.lang.String method)

hasExperiments

public abstract boolean hasExperiments()

Determine if any experiments are currently cached.

Returns:

are there any experiments

getExperiment

public abstract java.util.Optional<ExperimentImpact> getExperiment(TrafficCoordinates trafficCoordinates)

Given a specific injection point (TrafficCoordinates), find an impact to inject, if applicable. Is subject to some latency, as reading experiments requires calls to API

Parameters:

trafficCoordinates - injection point

Returns:

impact to inject, if applicable

shutdown

public abstract void shutdown()
                       throws java.io.IOException

Shutdown all Gremlin resources

Throws:

java.io.IOException

wrap

public <T> java.util.function.Supplier<T> wrap(TrafficCoordinates trafficCoordinates,
                                               java.util.function.Supplier<T> underlying)

execute

public <T> T execute(TrafficCoordinates trafficCoordinates,
                     java.util.function.Supplier<T> underlying)

wrap

public java.lang.Runnable wrap(TrafficCoordinates trafficCoordinates,
                               java.lang.Runnable underlying)

execute

public void execute(TrafficCoordinates trafficCoordinates,
                    java.lang.Runnable underlying)