code.data.IFlowRepository

Aliases

Parameters

subClasses

code.data.IPatchedRepository

superClasses

code.data.HasLogSource
code.data.Timed
java.lang.Object
scala.lang.Any

Js Constructors

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
TimerStartTime():java.lang.Long:Long
addDnsMapping(host:java.lang.String:String, mapping:code.data.IpAddressMapping, after:scala.Function0[scala.Unit:Unit], ):scala.Unit:Unit
addDnsMapping$default$3():scala.Function0[scala.Unit:Unit]
addStatefulBehaviour(triggerer:code.data.StatefulBehaviour, lock:code.data.FlowLock, ):code.data.StatefulBehaviour
analyseRepoEntity(entity:code.data.RepoEntity, depth:java.lang.Int:Int, analysed:scala.collection.mutable.HashSet[code.data.RepoEntity], cfgCtx:scala.Option[code.data.ConfigurationContext], ):code.data.RepoEntity
analyseRepoEntity$default$2():java.lang.Int:Int
analyseRepoEntity$default$3():scala.collection.mutable.HashSet[code.data.RepoEntity]
analyseRepoEntity$default$4(entity:code.data.RepoEntity, depth:java.lang.Int:Int, analysed:scala.collection.mutable.HashSet[code.data.RepoEntity], ):scala.Option[code.data.ConfigurationContext]
asInstanceOf():null:Null
clearDnsMapping(name:java.lang.String:String, after:scala.Function0[scala.Unit:Unit], ):scala.Unit:Unit
clearDnsMapping$default$2():scala.Function0[scala.Unit:Unit]
countConsole(orchIds:scala.collection.immutable.List[code.data.OrchestrationIdentity], levels:scala.Option[scala.collection.immutable.List[java.lang.String:String]], recursive:java.lang.Boolean:Boolean, ):java.lang.Long:Long
countConsole$default$3():java.lang.Boolean:Boolean
countMetrics(orchIds:scala.collection.immutable.List[code.data.OrchestrationIdentity], recursive:java.lang.Boolean:Boolean, ):java.lang.Long:Long
countMetrics$default$2():java.lang.Boolean:Boolean
countMetricsByTimestamp(timestamp:java.lang.Long:Long, recursive:java.lang.Boolean:Boolean, ):java.lang.Long:Long
countMetricsByTimestamp$default$2():java.lang.Boolean:Boolean
createStatefulBehaviour(config:code.data.O, state:scala.Option[code.data.DataType[scala.lang.Any:Any]], metadata:code.data.EntityMetadata, ):scala.util.Either[code.data.StatefulBehaviourjava.lang.Exception]
createStep(name:java.lang.String:String, configuration:code.data.O, ):scala.util.Either[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.Exception]
deleteBuiltinProcessor(n:java.lang.String:String, ):java.lang.Boolean:Boolean
deleteBundle(repo:code.data.IFlowRepository, id:java.lang.String:String, lock:code.data.FlowLock, ):scala.Unit:Unit
deleteSharedProcessor(n:java.lang.String:String, lock:code.data.FlowLock, ):java.lang.Boolean:Boolean
dnsService():scala.Option[code.data.DnsService]
eq(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
equals(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean
fetchHistoryList(query:scala.collection.immutable.List[code.data.AppQuery[code.data.FlowStatus]], ):scala.collection.immutable.List[code.data.OrchestrationHistory]
flowManager():code.data.IFlowManager
getAllDnsMappings(repo:code.data.IFlowRepository, ):scala.collection.immutable.Map[code.data.IpAddressMappingsjava.lang.String:String]
getAllFlows(repo:code.data.IFlowRepository, ):scala.collection.immutable.List[code.data.FlowOrchestrator]
getAllRecipes(repo:code.data.IFlowRepository, ):scala.util.Either[java.lang.Exceptionscala.collection.immutable.List[code.data.recipes.Recipe]]
getAllResourceCollections(repo:code.data.IFlowRepository, shallow:java.lang.Boolean:Boolean, ):scala.collection.immutable.List[code.data.ResourceCollection]
getAllResourceCollections$default$2():java.lang.Boolean:Boolean
getAllStatefulBehaviourFactories(repo:code.data.IFlowRepository, ):scala.collection.immutable.Map[code.data.StatefulBehaviourFactoryjava.lang.String:String]
getAllStatefulBehaviours(repo:code.data.IFlowRepository, ):scala.collection.immutable.Map[code.data.StatefulBehaviourjava.lang.String:String]
getAllStreamProcessorFactories(repo:code.data.IFlowRepository, ):scala.collection.immutable.List[code.data.StreamProcessorFactory]
getAuditedActions(terms:Unknown:Nothing, ):scala.collection.immutable.List[code.data.AuditedAction]
getBuiltinProcessor(n:java.lang.String:String, ):scala.Option[code.data.SharedProcessor[code.data.Datumcode.data.Datum]]
getBuiltinProcessors():scala.collection.immutable.List[code.data.SharedProcessor[code.data.Datumcode.data.Datum]]
getBundle(repo:code.data.IFlowRepository, id:java.lang.String:String, ):scala.Option[code.data.Bundle]
getBundles(repo:code.data.IFlowRepository, ):scala.collection.immutable.List[code.data.Bundle]
getClass():java.lang.Class[scala.lang.Any:Any]
getConfigPanels(repo:code.data.IFlowRepository, by:Unknown:Nothing, ):scala.collection.immutable.List[code.data.ConfigurationPanel]
getConfigurationContext(repo:code.data.IFlowRepository, ):scala.Option[code.data.ConfigurationContext]
getConsole(orchIds:scala.collection.immutable.List[code.data.OrchestrationIdentity], levels:scala.Option[scala.collection.immutable.List[java.lang.String:String]], recursive:java.lang.Boolean:Boolean, count:scala.Option[java.lang.Int:Int], skip:scala.Option[java.lang.Int:Int], ):scala.collection.immutable.List[code.data.ConsoleMessage]
getConsole$default$3():java.lang.Boolean:Boolean
getConsole$default$4():scala.Option[java.lang.Int:Int]
getConsole$default$5():scala.Option[java.lang.Int:Int]
getDnsMapping(repo:code.data.IFlowRepository, id:java.lang.String:String, ):scala.Option[code.data.IpAddressMappings]
getFlowManager():code.data.IFlowManager
getFlowStatus(by:Unknown:Nothing, ):scala.collection.immutable.List[code.data.FlowStatus]
getFlowStatusSummaries(terms:Unknown:Nothing, ):scala.collection.immutable.List[scala.Tuple2[java.lang.String:Stringscala.collection.immutable.List[scala.Tuple3[java.lang.Long:Longjava.lang.String:Stringnull:Null]]]]
getFlowStatuses(terms:Unknown:Nothing, ):scala.collection.immutable.List[code.data.FlowStatus]
getMetrics(orchIds:scala.collection.immutable.List[code.data.OrchestrationIdentity], recursive:java.lang.Boolean:Boolean, count:scala.Option[java.lang.Int:Int], skip:scala.Option[java.lang.Int:Int], ):scala.collection.immutable.List[code.data.Metric]
getMetrics$default$2():java.lang.Boolean:Boolean
getMetrics$default$3():scala.Option[java.lang.Int:Int]
getMetrics$default$4():scala.Option[java.lang.Int:Int]
getMetricsByTimestamp(timestamp:java.lang.Long:Long, recursive:java.lang.Boolean:Boolean, count:scala.Option[java.lang.Int:Int], skip:scala.Option[java.lang.Int:Int], ):scala.collection.immutable.List[code.data.Metric]
getMetricsByTimestamp$default$2():java.lang.Boolean:Boolean
getMetricsByTimestamp$default$3():scala.Option[java.lang.Int:Int]
getMetricsByTimestamp$default$4():scala.Option[java.lang.Int:Int]
getOrchestrator(repo:code.data.IFlowRepository, name:java.lang.String:String, ):scala.util.Either[code.data.FlowOrchestratorjava.lang.Exception]
getOrchestrators(repo:code.data.IFlowRepository, ):scala.collection.immutable.List[scala.Tuple2[code.data.FlowOrchestratorjava.lang.String:String]]
getPatchSet(id:java.lang.String:String, ):scala.Option[code.data.PatchSet]
getPatchSets():scala.collection.immutable.List[code.data.PatchSet]
getRecipe(repo:code.data.IFlowRepository, id:java.lang.String:String, ):scala.util.Either[code.data.recipes.Recipejava.lang.Exception]
getResource(repo:code.data.IFlowRepository, accessor:code.data.ResourceAccessor, ):scala.Option[code.data.Resource]
getResourceCollection(repo:code.data.IFlowRepository, id:java.lang.String:String, shallow:java.lang.Boolean:Boolean, nobodies:java.lang.Boolean:Boolean, ):scala.Option[code.data.ResourceCollection]
getResourceCollection$default$3():java.lang.Boolean:Boolean
getResourceCollection$default$4():java.lang.Boolean:Boolean
getSharedProcessor(repo:code.data.IFlowRepository, n:java.lang.String:String, ):scala.Option[code.data.SharedProcessor[code.data.Datumcode.data.Datum]]
getSharedProcessors(repo:code.data.IFlowRepository, ):scala.collection.immutable.List[code.data.SharedProcessor[code.data.Datumcode.data.Datum]]
getStatefulBehaviour(repo:code.data.IFlowRepository, id:java.lang.String:String, ):scala.Option[code.data.StatefulBehaviour]
getTriggererLogs(terms:Unknown:Nothing, ):scala.collection.immutable.List[code.data.TriggererLog]
globals():code.data.IGlobals
hashCode():java.lang.Int:Int
isHealthy():java.lang.Boolean:Boolean
isInstanceOf():java.lang.Boolean:Boolean
localShutdown(lock:code.data.FlowLock, ):scala.Unit:Unit
localStartup(lock:code.data.FlowLock, ):scala.Unit:Unit
logSource():scala.Some[code.data.LogSource]
lookupConfigPanel(repo:code.data.IFlowRepository, id:java.lang.String:String, ):scala.util.Either[code.data.ConfigurationPaneljava.lang.Exception]
lookupOrchestrationIdentities(terms:Unknown:Nothing, ):scala.collection.immutable.List[code.data.OrchestrationIdentity]
lookupOrchestrationRelations(orch:code.data.OrchestrationIdentity, children:java.lang.Boolean:Boolean, maxDepth:scala.Option[java.lang.Int:Int], ):scala.collection.immutable.List[scala.Tuple2[code.data.OrchestrationIdentityjava.lang.Int:Int]]
lookupOrchestrationRelations$default$2():java.lang.Boolean:Boolean
lookupOrchestrationRelations$default$3():scala.Option[java.lang.Int:Int]
lookupStatefulBehaviourFactory(repo:code.data.IFlowRepository, classPath:java.lang.String:String, ):scala.Option[code.data.StatefulBehaviourFactory]
lookupStreamProcessorFactory(repo:code.data.IFlowRepository, name:java.lang.String:String, ):scala.Option[code.data.StreamProcessorFactory]
lookupStreamProcessorFactory(repo:code.data.IFlowRepository, streamProcessor:code.data.StreamProcessor[code.data.Datumcode.data.Datum], ):scala.Option[code.data.StreamProcessorFactory]
ne(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
notify():scala.Unit:Unit
notifyAll():scala.Unit:Unit
persistAuditedAction(action:code.data.AuditedAction, ):java.lang.String:String
persistConsoleMessage(cm:code.data.ConsoleMessage, p:scala.Option[code.data.Payload[code.data.Datum]], consoleFilter:code.data.ConsoleFilter, ):scala.Unit:Unit
persistFlowStatus(fs:code.data.FlowStatus, cf:code.data.ConsoleFilter, ):scala.Unit:Unit
persistMetric(m:code.data.Metric, p:scala.Option[code.data.Payload[code.data.Datum]], consoleFilter:code.data.ConsoleFilter, ):scala.Unit:Unit
persistRecipe(id:java.lang.String:String, recipe:code.data.recipes.Recipe, ):scala.util.Either[java.lang.Boolean:Booleanjava.lang.Exception]
persistStateItem(key:java.lang.String:String, item:scala.lang.Any:Any, p:code.data.Payload[code.data.Datum], cf:code.data.ConsoleFilter, ):scala.Unit:Unit
persistStateItems(items:scala.collection.immutable.Map[java.lang.String:Stringscala.Option[scala.lang.Any:Any]], p:code.data.Payload[code.data.Datum], cf:code.data.ConsoleFilter, ):scala.Unit:Unit
persistTriggererLogs(log:code.data.TriggererLog, ):scala.Unit:Unit
pinner():code.data.Pinner
putDnsMappings(ms:code.data.IpAddressMappings, after:scala.Function0[scala.Unit:Unit], ):scala.Unit:Unit
putDnsMappings$default$2():scala.Function0[scala.Unit:Unit]
registerConfigPanel(configPanel:code.data.ConfigurationPanel, ):scala.Unit:Unit
registerFlow(name:java.lang.String:String, orchestrator:code.data.FlowOrchestrator, lock:code.data.FlowLock, ):scala.Unit:Unit
registerStatefulBehaviourCreator(typeName:java.lang.String:String, providerFunc:scala.Function1[scala.Tuple3[code.data.EntityMetadatacode.data.Oscala.Option[code.data.DataType[scala.lang.Any:Any]]]scala.util.Either[code.data.StatefulBehaviourjava.lang.Exception]], ):scala.Unit:Unit
registerStatefulBehaviourFactory(factory:code.data.StatefulBehaviourFactory, ):scala.Unit:Unit
registerStepType(name:java.lang.String:String, creationFunc:scala.Function1[code.data.Oscala.util.Either[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.Exception]], ):scala.Unit:Unit
registerStreamProcessorFactory(factory:code.data.StreamProcessorFactory, ):scala.Unit:Unit
relateOrchestration(parent:code.data.OrchestrationIdentity, child:code.data.OrchestrationIdentity, ):scala.Unit:Unit
removeConfigPanel(id:java.lang.String:String, ):scala.Unit:Unit
removeDnsMapping(host:java.lang.String:String, mapping:code.data.IpAddressMapping, after:scala.Function0[scala.Unit:Unit], ):scala.Unit:Unit
removeDnsMapping$default$3():scala.Function0[scala.Unit:Unit]
removePatchSet(id:java.lang.String:String, ):scala.Unit:Unit
removeRecipe(id:java.lang.String:String, ):scala.util.Either[java.lang.Boolean:Booleanjava.lang.Exception]
removeResourceCollection(id:java.lang.String:String, lock:code.data.FlowLock, ):java.lang.Boolean:Boolean
removeStateItems(keys:scala.collection.immutable.List[java.lang.String:String], p:code.data.Payload[code.data.Datum], cf:code.data.ConsoleFilter, ):scala.Unit:Unit
removeStatefulBehaviour(id:java.lang.String:String, lock:code.data.FlowLock, ):scala.Unit:Unit
repo():code.data.IFlowRepository
setBuiltinProcessor(s:code.data.SharedProcessor[null:Nullnull:Null], lock:code.data.FlowLock, ):scala.Option[code.data.SharedProcessor[null:Nullnull:Null]]
setDnsService(dnsService:scala.Option[code.data.DnsService], ):scala.Unit:Unit
setPatchSet(patchSet:code.data.PatchSet, ):scala.Option[code.data.PatchSet]
setRepo(other:code.data.IFlowRepository, ):code.data.IFlowRepository
setResourceCollection(coll:code.data.ResourceCollection, lock:code.data.FlowLock, ):scala.Option[code.data.ResourceCollection]
setSharedProcessor(s:code.data.SharedProcessor[null:Nullnull:Null], lock:code.data.FlowLock, ):scala.Option[code.data.SharedProcessor[null:Nullnull:Null]]
synchronized(x$1:null:Null, ):null:Null
timeIt(msg:Unknown:Nothing, a:null:Null, ):null:Null
timeIt(msg:Unknown:Nothing, ):scala.Unit:Unit
toString():java.lang.String:String
unregisterFlow(name:java.lang.String:String, lock:code.data.FlowLock, ):scala.Unit:Unit
updateBundle(repo:code.data.IFlowRepository, id:java.lang.String:String, bundle:code.data.Bundle, lock:code.data.FlowLock, ):scala.util.Either[scala.Unit:Unitscala.collection.immutable.List[java.lang.Exception]]
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