Parameters

subClasses

superClasses

code.data.CollectionComparators

code.data.Exceptor

code.data.HasLogSource

code.data.SerializableEntity

java.lang.Object

scala.lang.Any

Js Constructors

new code_data_FlowOrchestrator(
    name, // java.lang.String:String
    description, // java.lang.String:String
    metadata, // code.data.EntityMetadata
    bundle // scala.Option[java.lang.String:String]
)

ApplyMethods

Methods

$bang$eq(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean

$eq$eq(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean

$hash$hash():java.lang.Int:Int

$init$():scala.Unit:Unit

asInstanceOf():null:Null

bundle():scala.Option[java.lang.String:String]

configurationEquals(other:scala.lang.Any:Any, configurationContext:scala.Option[code.data.ConfigurationContext], ):java.lang.Boolean:Boolean

configurationEquals$default$2(other:scala.lang.Any:Any, ):scala.Option[code.data.ConfigurationContext]

description():java.lang.String:String

eq(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean

equals(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean

flowManager():code.data.IFlowManager

getClass():java.lang.Class[scala.lang.Any:Any]

getDefaultTimeout():scala.concurrent.duration.Duration

getExecutionStrategy():code.data.ExecutionStrategy

getIdentity():java.lang.String:String

getLogLevel():scala.Option[code.data.ConsoleFilter]

getMaintenanceModeSteps():scala.Option[scala.collection.immutable.List[java.lang.String:String]]

getSteps():scala.collection.immutable.List[java.lang.String:String]

getStreamProcessors():scala.collection.immutable.Map[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.String:String]

hashCode():java.lang.Int:Int

isInstanceOf():java.lang.Boolean:Boolean

listEquals(a:scala.collection.immutable.List[null:Null], b:scala.collection.immutable.List[null:Null], vFunc:scala.Function1[java.lang.Boolean:Booleanscala.Tuple2[null:Nullnull:Null]], ):java.lang.Boolean:Boolean

listEquals$default$3():scala.Function1[java.lang.Boolean:Booleanscala.Tuple2[null:Nullnull:Null]]

localShutdown(repo:code.data.IFlowRepository, lock:code.data.FlowLock, ):scala.Unit:Unit

localStartup(repo:code.data.IFlowRepository, lock:code.data.FlowLock, ):scala.Unit:Unit

logSource():scala.Some[code.data.LogSource]

mapEquals(a:scala.collection.immutable.Map[null:Nullnull:Null], b:scala.collection.immutable.Map[null:Nullnull:Null], vFunc:scala.Function1[java.lang.Boolean:Booleanscala.Tuple2[null:Nullnull:Null]], ):java.lang.Boolean:Boolean

mapEquals$default$3():scala.Function1[java.lang.Boolean:Booleanscala.Tuple2[null:Nullnull:Null]]

metadata():code.data.EntityMetadata

name():java.lang.String:String

ne(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean

newFromConfig(configurationContext:scala.Option[code.data.ConfigurationContext], ):code.data.FlowOrchestrator

newFromConfig$default$1():scala.Option[code.data.ConfigurationContext]

notify():scala.Unit:Unit

notifyAll():scala.Unit:Unit

recreateWithUpdatedStreamProcessor(sp:scala.Tuple2[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.String:String], ):code.data.FlowOrchestrator

repo():code.data.IFlowRepository

responseVerifier():scala.Option[java.lang.String:String]

setLogLevel(in:scala.Option[code.data.ConsoleFilter], ):scala.Unit:Unit

setSelfOrch(other:code.data.FlowOrchestrator, ):code.data.FlowOrchestrator

shouldForceStreams():java.lang.Boolean:Boolean

shouldLog(category:scala.Option[java.lang.String:String], ):java.lang.Boolean:Boolean

shouldPin():scala.collection.immutable.List[java.lang.String:String]

subscribeToRunningFlowsChanged(n:java.lang.String:String, f:scala.Function1[scala.Unit:Unitscala.collection.immutable.List[java.lang.String:String]], ):scala.Unit:Unit

synchronized(x$1:null:Null, ):null:Null

testData():scala.Option[net.liftweb.json.JsonAST$JValue]

toDataType(interceptor:scala.Function1, ):code.data.DataType[scala.lang.Any:Any]

toDataType$default$1():scala.Function1

toString():java.lang.String:String

transformTestDataFunc():scala.Option[java.lang.String:String]

trigger(startingPayload:scala.Option[code.data.Payload[code.data.Datum]], synchronous:java.lang.Boolean:Boolean, onStatusChange:scala.Function1[code.data.FlowOrchestrationStatusscala.Unit:Unit], overrideConsoleLevel:scala.Option[code.data.ConsoleFilter], timeout:scala.concurrent.duration.Duration, executionStrategy:code.data.ExecutionStrategy, parent:scala.Option[code.data.IFlowOrchestration], shutdownPayloadOnCompletion:java.lang.Boolean:Boolean, configContext:scala.Option[code.data.ConfigurationContext], ):code.data.IFlowOrchestration

trigger$default$1():scala.Option[code.data.Payload[code.data.Datum]]

trigger$default$2():java.lang.Boolean:Boolean

trigger$default$3():scala.Function1[code.data.FlowOrchestrationStatusscala.Unit:Unit]

trigger$default$4():scala.Option[code.data.ConsoleFilter]

trigger$default$5():scala.concurrent.duration.Duration

trigger$default$6():code.data.ExecutionStrategy

trigger$default$7():scala.Option[code.data.IFlowOrchestration]

trigger$default$8():java.lang.Boolean:Boolean

trigger$default$9(startingPayload:scala.Option[code.data.Payload[code.data.Datum]], synchronous:java.lang.Boolean:Boolean, onStatusChange:scala.Function1[code.data.FlowOrchestrationStatusscala.Unit:Unit], overrideConsoleLevel:scala.Option[code.data.ConsoleFilter], timeout:scala.concurrent.duration.Duration, executionStrategy:code.data.ExecutionStrategy, parent:scala.Option[code.data.IFlowOrchestration], shutdownPayloadOnCompletion:java.lang.Boolean:Boolean, ):scala.Option[code.data.ConfigurationContext]

unsubscribeFromRunningFlowsChanged(n:java.lang.String:String, ):scala.Unit:Unit

wait():scala.Unit:Unit

wait(x$1:java.lang.Long:Long, ):scala.Unit:Unit

wait(x$1:java.lang.Long:Long, x$2:java.lang.Int:Int, ):scala.Unit:Unit