-
- All Implemented Interfaces:
-
java.io.Closeable,java.lang.AutoCloseable
@RestrictTo(value = {RestrictTo.Scope.LIBRARY_GROUP}) public interface EngineImplementation implements Closeable
Interface of an engine implementation, used by EventSyncEngine/StateSyncEngine.
-
-
Method Summary
Modifier and Type Method Description abstract UnitsetCallbacks(Function1<String, Unit> stateChange, Function1<String, Unit> errors)Set the callbacks for state change & errors when evaluating scripts. abstract Objectevaluate(String script)Evaluate the given script & return the result (if any). abstract Unitcreate(String script)abstract Unitinit(Environment environment, String externalStateMap)abstract UnitsetEventsCache(List<Event> events)abstract UnitupdateInternalState(Map<String, QueryState.StateSyncQueryState> internalState)abstract Set<String>getQueryIds()abstract UnitprocessEvents(List<Event> events)abstract StringcalculateDelta(Map<String, QueryState.StateSyncQueryState> stateMap, Map<String, QueryState.StateSyncQueryState> lastSentState)abstract UnitupdateEnvironment(Environment environment)abstract StringupdateExternalState(String externalState)abstract UnitmigrateViaCache(Environment environment)abstract Pair<String, String>mergeMigratedStates()abstract UnitmigrateDirect(Map<String, QueryState.StateSyncQueryState> legacyState)-
-
Method Detail
-
setCallbacks
abstract Unit setCallbacks(Function1<String, Unit> stateChange, Function1<String, Unit> errors)
Set the callbacks for state change & errors when evaluating scripts. This should be called once upon creation of the EngineImplementation.
-
evaluate
abstract Object evaluate(String script)
Evaluate the given script & return the result (if any).
-
init
abstract Unit init(Environment environment, String externalStateMap)
-
setEventsCache
abstract Unit setEventsCache(List<Event> events)
-
updateInternalState
abstract Unit updateInternalState(Map<String, QueryState.StateSyncQueryState> internalState)
-
getQueryIds
abstract Set<String> getQueryIds()
-
processEvents
abstract Unit processEvents(List<Event> events)
-
calculateDelta
abstract String calculateDelta(Map<String, QueryState.StateSyncQueryState> stateMap, Map<String, QueryState.StateSyncQueryState> lastSentState)
-
updateEnvironment
abstract Unit updateEnvironment(Environment environment)
-
updateExternalState
abstract String updateExternalState(String externalState)
-
migrateViaCache
abstract Unit migrateViaCache(Environment environment)
-
mergeMigratedStates
abstract Pair<String, String> mergeMigratedStates()
-
migrateDirect
abstract Unit migrateDirect(Map<String, QueryState.StateSyncQueryState> legacyState)
-
-
-
-