public final class FluxMethods extends Object
Constructor and Description |
---|
FluxMethods(io.toro.fluxengine.service.context.FluxContextService contextService) |
Modifier and Type | Method and Description |
---|---|
static void |
fluxAddTags(Long contextId,
String... tags)
Add tags to a running Flux service.
|
static Long |
fluxExecute(String fluxName)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
io.toro.gloop.object.property.GloopModel input)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
io.toro.gloop.object.property.GloopModel input,
Set<String> tags)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
io.toro.gloop.object.property.GloopModel input,
String startState,
Set<String> tags)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
Map<String,Object> input)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
Map<String,Object> input,
Set<String> tags)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
Map<String,Object> input,
String startState,
Set<String> tags)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
Set<String> tags)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
Set<String> tags,
Object... inputs)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
String startState)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
String startState,
io.toro.gloop.object.property.GloopModel input)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
String startState,
Map<String,Object> input)
Execute a Flux service belonging to a certain package.
|
static Long |
fluxExecute(String fluxName,
String startState,
Set<String> tags)
Execute a Flux service belonging to a certain package.
|
static io.toro.fluxengine.model.FluxContext |
fluxGetContext(Long contextId)
Retrieve a
FluxContext by ID. |
static List<io.toro.fluxengine.model.FluxContext> |
fluxGetContexts()
Retrieve all
FluxContext s from the repository. |
static List<io.toro.fluxengine.model.FluxContext> |
fluxGetContexts(String... tags)
Retrieve all
FluxContext s with the specified tags. |
static List<io.toro.fluxengine.model.FluxContext> |
fluxGetContexts(String name)
Retrieve all
FluxContext s with the specified name. |
static List<io.toro.fluxengine.model.FluxContext> |
fluxGetContexts(String name,
String... tags)
Retrieve all
FluxContext s with the specified name and tags. |
static io.toro.fluxengine.debugger.FluxStateContext |
fluxGetStateContext(Long contextId,
String stateName)
Retrieve the
FluxStateContext of a running Flux service. |
static void |
fluxRemoveTags(Long contextId,
String... tags)
Remove certain tags of a running Flux service.
|
static String |
fluxSendEvent(Long contextId,
String event)
Send an external event to one Flux service, which is identified using
contextId . |
static String |
fluxSendEvent(Long contextId,
String event,
io.toro.gloop.object.property.GloopModel input)
Send an external event to one Flux service, which is identified using
contextId . |
static String |
fluxSendEvent(Long contextId,
String event,
Map<String,Object> input)
Send an external event to one Flux service, which is identified using
contextId . |
static io.toro.fluxengine.model.event.FluxEventSummary |
fluxSendEvent(String event,
io.toro.gloop.object.property.GloopModel input,
Set<String> tags)
Send an external event to all Flux services.
|
static io.toro.fluxengine.model.event.FluxEventSummary |
fluxSendEvent(String event,
Map<String,Object> input,
Set<String> tags)
Send an external event to all Flux services.
|
static io.toro.fluxengine.model.event.FluxEventSummary |
fluxSendEvent(String event,
Set<String> tags)
Send an external event to all Flux services.
|
static void |
fluxTerminate(Long contextId)
Terminate the execution of a Flux service.
|
static io.toro.gloop.object.property.GloopModel |
getContext(Long contextId)
Retrieve a Flux context by ID.
|
static io.toro.gloop.object.property.GloopModel |
getContexts()
Retrieve all Flux contexts from the repository.
|
static io.toro.gloop.object.property.GloopModel |
getContexts(String... tags)
Retrieve all Flux contexts with the specified tags.
|
static io.toro.gloop.object.property.GloopModel |
getContexts(String name)
Retrieve all Flux contexts with the specified name.
|
static io.toro.gloop.object.property.GloopModel |
getContexts(String name,
String... tags)
Retrieve all Flux contexts with the specified name and tags.
|
static io.toro.gloop.object.property.GloopModel |
getFluxStateContext(Long contextId,
String stateName)
Retrieve the state context of a running Flux service.
|
@Autowired FluxMethods(io.toro.fluxengine.service.context.FluxContextService contextService)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, io.toro.gloop.object.property.GloopModel input, String startState, Set<String> tags)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.startState
- The name of the state where the execution should start.
If this is undefined, or not a state of the Flux,
execution starts at the first state defined in the Flux service.input
- model containing the inputs for the Flux service.tags
- collection of tags that may be used to start the Flux using
fluxSendEvent(String, Set)
fluxExecute(String, Map, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, Map<String,Object> input, String startState, Set<String> tags)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.startState
- The name of the state where the execution should start.
If this is undefined, or not a state of the Flux,
execution starts at the first state defined in the Flux service.input
- map containing the inputs for the Flux servicetags
- collection of tags that may be used to start the Flux using
fluxSendEvent(String, Set)
fluxExecute(String, GloopModel, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.fluxExecute(String, GloopModel, String, Set)
,
fluxExecute(String, Map, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, String startState)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.startState
- The name of the state where the execution should start.
If this is undefined, or not a state of the Flux,
execution starts at the first state defined in the Flux service.fluxExecute(String, GloopModel, String, Set)
,
fluxExecute(String, Map, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, io.toro.gloop.object.property.GloopModel input)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.input
- model containing the inputs for the Flux servicefluxExecute(String, GloopModel, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, Map<String,Object> input)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.input
- map containing the inputs for the Flux servicefluxExecute(String, Map, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, String startState, io.toro.gloop.object.property.GloopModel input)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.input
- map containing the inputs for the Flux servicestartState
- The name of the state where the execution should start.
If this is undefined, or not a state of the Flux,
execution starts at the first state defined in the Flux service.fluxExecute(String, GloopModel, String, Set)
,
fluxExecute(String, String, Map)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, String startState, Map<String,Object> input)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.startState
- The name of the state where the execution should start.
If this is undefined, or not a state of the Flux,
execution starts at the first state defined in the Flux service.input
- map containing the inputs for the Flux servicefluxExecute(String, Map, String, Set)
,
fluxExecute(String, String, GloopModel)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, Set<String> tags)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.tags
- collection of tags that may be used to start the Flux using
fluxSendEvent(String, Set)
fluxExecute(String, GloopModel, String, Set)
,
fluxExecute(String, Map, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, String startState, Set<String> tags)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.startState
- The name of the state where the execution should start.
If this is undefined, or not a state of the Flux,
execution starts at the first state defined in the Flux service.tags
- collection of tags that may be used to start the Flux using
fluxSendEvent(String, Set)
fluxExecute(String, GloopModel, String, Set)
,
fluxExecute(String, Map, String, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, io.toro.gloop.object.property.GloopModel input, Set<String> tags)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.input
- model containing the inputs for the Flux service.tags
- collection of tags that may be used to start the Flux using
fluxSendEvent(String, Set)
fluxExecute(String, GloopModel, String, Set)
,
fluxExecute(String, Map, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, Map<String,Object> input, Set<String> tags)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.input
- map containing the inputs for the Flux servicetags
- collection of tags that may be used to start the Flux using
fluxSendEvent(String, Set)
fluxExecute(String, Map, String, Set)
,
fluxExecute(String, GloopModel, Set)
@GloopParameter(name="contextId") public static Long fluxExecute(@GloopParameter(allowNull=false) String fluxName, Set<String> tags, Object... inputs)
fluxName
- The name of the Flux file (with or without the file extension) to execute.
If nested within a directory, parent directories must be prefixed
while using . as a separator (e.g path.to.FluxService.tags
- collection of tags that may be used to start the Flux using
fluxSendEvent(String, Set)
inputs
- ordered inputs for the Flux servicefluxExecute(String, Map, String, Set)
,
fluxExecute(String, GloopModel, Set)
,
fluxExecute(String, GloopModel, Set)
,
fluxExecute(String, Map, Set)
public static void fluxTerminate(@GloopParameter(allowNull=false) Long contextId)
contextId
- the ID of a running Flux context@GloopParameter(name="summary") public static io.toro.fluxengine.model.event.FluxEventSummary fluxSendEvent(@GloopParameter(allowNull=false) String event, io.toro.gloop.object.property.GloopModel input, Set<String> tags)
event
- the external event to sendinput
- model containing the inputs for each triggered Flux servicetags
- Tags of Flux services to execute. A Flux will only be execute, if and only if, it contains all
the tags specified.@GloopParameter(name="summary") public static io.toro.fluxengine.model.event.FluxEventSummary fluxSendEvent(@GloopParameter(allowNull=false) String event, Map<String,Object> input, Set<String> tags)
event
- the external event to sendinput
- map containing the inputs for each triggered Flux servicetags
- Tags of Flux services to execute. A Flux will only be execute, if and only if, it contains all
the tags specified.@GloopParameter(name="summary") public static io.toro.fluxengine.model.event.FluxEventSummary fluxSendEvent(@GloopParameter(allowNull=false) String event, Set<String> tags)
event
- the external event to sendtags
- Tags of Flux services to execute. A Flux will only be execute, if and only if, it contains all
the tags specified.fluxSendEvent(Long, String, GloopModel)
,
fluxSendEvent(Long, String, Map)
@GloopParameter(name="stateName") public static String fluxSendEvent(@GloopParameter(allowNull=false) Long contextId, @GloopParameter(allowNull=false) String event, io.toro.gloop.object.property.GloopModel input)
contextId
.event
- the external event to sendinput
- model containing the inputs for each triggered Flux servicefluxSendEvent(Long, String, Map)
@GloopParameter(name="stateName") public static String fluxSendEvent(@GloopParameter(allowNull=false) Long contextId, @GloopParameter(allowNull=false) String event, Map<String,Object> input)
contextId
.contextId
- the ID of the Fluxevent
- the external event to sendinput
- map containing the inputs for each triggered Flux servicefluxSendEvent(Long, String, GloopModel)
@GloopParameter(name="stateName") public static String fluxSendEvent(@GloopParameter(allowNull=false) Long contextId, @GloopParameter(allowNull=false) String event)
contextId
.
This implementation does not specify inputs for the recipient Flux service.contextId
- the ID of the Fluxevent
- the external event to sendfluxSendEvent(Long, String, GloopModel)
,
fluxSendEvent(Long, String, Map)
public static void fluxAddTags(@GloopParameter(allowNull=false) Long contextId, String... tags)
contextId
- the ID of the Fluxtags
- the tags to add to the Fluxpublic static void fluxRemoveTags(@GloopParameter(allowNull=false) Long contextId, String... tags)
contextId
- the ID of the Fluxtags
- the tags to remove from the Fluxpublic static io.toro.fluxengine.model.FluxContext fluxGetContext(Long contextId)
FluxContext
by ID.contextId
- the ID of the Flux being queriedpublic static List<io.toro.fluxengine.model.FluxContext> fluxGetContexts()
FluxContext
s from the repository.public static List<io.toro.fluxengine.model.FluxContext> fluxGetContexts(String name)
FluxContext
s with the specified name.name
- the name of the Flux servicespublic static List<io.toro.fluxengine.model.FluxContext> fluxGetContexts(String name, String... tags)
FluxContext
s with the specified name and tags.name
- the name of the Flux servicestags
- the tags of the Flux servicespublic static List<io.toro.fluxengine.model.FluxContext> fluxGetContexts(String... tags)
FluxContext
s with the specified tags.tags
- the tags of the Flux servicespublic static io.toro.fluxengine.debugger.FluxStateContext fluxGetStateContext(Long contextId, String stateName)
FluxStateContext
of a running Flux service.contextId
- the ID of the FluxstateName
- the name of the state@GloopObjectParameter(value="output:context of a running flux service{\nfluxContext#io.toro.martini.flux.FluxContext{\n}\n}") public static io.toro.gloop.object.property.GloopModel getContext(@GloopParameter(allowNull=false) Long contextId)
contextId
- the ID of the Flux context@GloopObjectParameter(value="output:list of context of running flux services{\nfluxContexts#io.toro.martini.flux.FluxContext[]{\n}\n}") public static io.toro.gloop.object.property.GloopModel getContexts()
@GloopObjectParameter(value="output:list of context of running flux services{\nfluxContexts#io.toro.martini.flux.FluxContext[]{\n}\n}") public static io.toro.gloop.object.property.GloopModel getContexts(@GloopParameter(allowNull=false) String name)
name
- the name of the Flux services@GloopObjectParameter(value="output:list of context of running flux services{\nfluxContexts#io.toro.martini.flux.FluxContext[]{\n}\n}") public static io.toro.gloop.object.property.GloopModel getContexts(@GloopParameter(allowNull=false) String name, String... tags)
name
- the name of the Flux servicestags
- the tags of the Flux services@GloopObjectParameter(value="output:list of context of running flux services{\nfluxContexts#io.toro.martini.flux.FluxContext[]{\n}\n}") public static io.toro.gloop.object.property.GloopModel getContexts(@GloopParameter(allowNull=false) String... tags)
tags
- the tags of the Flux services@GloopObjectParameter(value="output:context of a running flux\' state{\nfluxStateContext#io.toro.martini.flux.FluxStateContext{\n}\n}") public static io.toro.gloop.object.property.GloopModel getFluxStateContext(@GloopParameter(allowNull=false) Long contextId, @GloopParameter(allowNull=false) String stateName)
contextId
- the ID of the FluxstateName
- the name of the stateCopyright © 2020. All rights reserved.