Parameters

subClasses

code.data.IPatchedRepository

superClasses

Any

code.data.Exceptor

code.data.HasLogSource

code.data.IFlowRepository

code.data.Timed

java.lang.Object

Js Constructors

new code_data_FlowRepositoryWrapper(
    fr, // code.data.IFlowRepository
)

ApplyMethods

Methods

$bang$eq(x$1:Any):boolean

$eq$eq(x$1:Any):boolean

$hash$hash():int

$init$():Unit

TimerStartTime():long

addDnsMapping(host:java.lang.String, mapping:code.data.IpAddressMapping, after:scala.Function0[Unit]):Unit

addDnsMapping$default$3():scala.Function0[Unit]

addStatefulBehaviour(triggerer:code.data.StatefulBehaviour, lock:code.data.FlowLock):code.data.StatefulBehaviour

analyseRepoEntity(entity:code.data.RepoEntity, depth:int, analysed:scala.collection.mutable.HashSet[code.data.RepoEntity], cfgCtx:scala.Option[code.data.ConfigurationContext]):code.data.RepoEntity

analyseRepoEntity$default$2():int

analyseRepoEntity$default$3():scala.collection.mutable.HashSet[code.data.RepoEntity]

analyseRepoEntity$default$4(entity:code.data.RepoEntity, depth:int, analysed:scala.collection.mutable.HashSet[code.data.RepoEntity]):scala.Option[code.data.ConfigurationContext]

asInstanceOf():scala.Any.T0

clearDnsMapping(name:java.lang.String, after:scala.Function0[Unit]):Unit

clearDnsMapping$default$2():scala.Function0[Unit]

countConsole(orchIds:scala.collection.immutable.List[code.data.OrchestrationIdentity], levels:scala.Option[scala.collection.immutable.List[java.lang.String]], recursive:boolean):long

countConsole$default$3():boolean

countMetrics(orchIds:scala.collection.immutable.List[code.data.OrchestrationIdentity], recursive:boolean):long

countMetrics$default$2():boolean

countMetricsByTimestamp(timestamp:long, recursive:boolean):long

countMetricsByTimestamp$default$2():boolean

createStatefulBehaviour(config:code.data.O, state:scala.Option[code.data.DataType[Any]], metadata:code.data.EntityMetadata):scala.util.Either[code.data.StatefulBehaviourjava.lang.Exception]

createStep(name:java.lang.String, configuration:code.data.O):scala.util.Either[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.Exception]

deleteBuiltinProcessor(n:java.lang.String):boolean

deleteBundle(repo:code.data.IFlowRepository, id:java.lang.String, lock:code.data.FlowLock):Unit

deleteSharedProcessor(n:java.lang.String, lock:code.data.FlowLock):boolean

dnsService():scala.Option[code.data.DnsService]

eq(x$1:java.lang.Object):boolean

equals(x$1:Any):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]

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:boolean):scala.collection.immutable.List[code.data.ResourceCollection]

getAllResourceCollections$default$2():boolean

getAllStatefulBehaviourFactories(repo:code.data.IFlowRepository):scala.collection.immutable.Map[code.data.StatefulBehaviourFactoryjava.lang.String]

getAllStatefulBehaviours(repo:code.data.IFlowRepository):scala.collection.immutable.Map[code.data.StatefulBehaviourjava.lang.String]

getAllStreamProcessorFactories(repo:code.data.IFlowRepository):scala.collection.immutable.List[code.data.StreamProcessorFactory]

getAuditLogFor(terms:Unknown Nothing):scala.collection.immutable.List[code.data.SerializableEntityAuditLog]

getAuditedActions(terms:Unknown Nothing):scala.collection.immutable.List[code.data.AuditedAction]

getBuiltinProcessor(n:java.lang.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):scala.Option[code.data.Bundle]

getBundles(repo:code.data.IFlowRepository):scala.collection.immutable.List[code.data.Bundle]

getClass():java.lang.Class[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]], recursive:boolean, count:scala.Option[int], skip:scala.Option[int]):scala.collection.Iterator[code.data.ConsoleMessage]

getConsole$default$3():boolean

getConsole$default$4():scala.Option[int]

getConsole$default$5():scala.Option[int]

getDnsMapping(repo:code.data.IFlowRepository, id:java.lang.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.Stringscala.collection.immutable.List[scala.Tuple3[java.lang.Stringlongscala.Enumeration$Value]]]]

getFlowStatuses(terms:Unknown Nothing):scala.collection.immutable.List[code.data.FlowStatus]

getLoggableStreamItems(terms:Unknown Nothing):scala.collection.immutable.List[code.data.LoggableStreamItem]

getMetrics(orchIds:scala.collection.immutable.List[code.data.OrchestrationIdentity], recursive:boolean, count:scala.Option[int], skip:scala.Option[int]):scala.collection.Iterator[code.data.Metric]

getMetrics$default$2():boolean

getMetrics$default$3():scala.Option[int]

getMetrics$default$4():scala.Option[int]

getMetricsByTimestamp(timestamp:long, recursive:boolean, count:scala.Option[int], skip:scala.Option[int]):scala.collection.Iterator[code.data.Metric]

getMetricsByTimestamp$default$2():boolean

getMetricsByTimestamp$default$3():scala.Option[int]

getMetricsByTimestamp$default$4():scala.Option[int]

getOrchestrator(repo:code.data.IFlowRepository, name:java.lang.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]]

getPatchSet(id:java.lang.String):scala.Option[code.data.PatchSet]

getPatchSets():scala.collection.immutable.List[code.data.PatchSet]

getRecipe(repo:code.data.IFlowRepository, id:java.lang.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, shallow:boolean, nobodies:boolean):scala.Option[code.data.ResourceCollection]

getResourceCollection$default$3():boolean

getResourceCollection$default$4():boolean

getSharedProcessor(repo:code.data.IFlowRepository, n:java.lang.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):scala.Option[code.data.StatefulBehaviour]

getTriggererLogs(terms:Unknown Nothing):scala.collection.Iterator[code.data.TriggererLog]

globals():code.data.config.IGlobals

hashCode():int

isHealthy(deep:boolean):boolean

isInstanceOf():boolean

localShutdown(lock:code.data.FlowLock):Unit

localStartup(lock:code.data.FlowLock):Unit

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

lookupConfigPanel(repo:code.data.IFlowRepository, id:java.lang.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:boolean, maxDepth:scala.Option[int]):scala.collection.Iterator[scala.Tuple2[code.data.OrchestrationIdentityint]]

lookupOrchestrationRelations$default$2():boolean

lookupOrchestrationRelations$default$3():scala.Option[int]

lookupStatefulBehaviourFactory(repo:code.data.IFlowRepository, classPath:java.lang.String):scala.Option[code.data.StatefulBehaviourFactory]

lookupStreamProcessorFactory(repo:code.data.IFlowRepository, name:java.lang.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):boolean

notify():Unit

notifyAll():Unit

persistAuditLogForSerializableEntity(se:code.data.SerializableEntityAuditLog):scala.util.Either[code.data.SerializableEntityAuditLogjava.lang.Exception]

persistAuditedAction(action:code.data.AuditedAction):java.lang.String

persistConsoleMessage(cm:code.data.ConsoleMessage, p:scala.Option[code.data.Payload[code.data.Datum]], consoleFilter:code.data.ConsoleFilter):Unit

persistFlowStatus(fs:code.data.FlowStatus, cf:code.data.ConsoleFilter):Unit

persistLoggableStreamItem(item:code.data.LoggableStreamItem):Unit

persistMetric(m:code.data.Metric, p:scala.Option[code.data.Payload[code.data.Datum]], consoleFilter:code.data.ConsoleFilter):Unit

persistRecipe(id:java.lang.String, recipe:code.data.recipes.Recipe):scala.util.Either[booleanjava.lang.Exception]

persistStateItem(key:java.lang.String, item:Any, p:code.data.Payload[code.data.Datum], cf:code.data.ConsoleFilter):Unit

persistStateItems(items:scala.collection.immutable.Map[java.lang.Stringscala.Option[Any]], p:code.data.Payload[code.data.Datum], cf:code.data.ConsoleFilter):Unit

persistTriggererLogs(log:code.data.TriggererLog):Unit

pinner():code.data.Pinner

putDnsMappings(ms:code.data.IpAddressMappings, after:scala.Function0[Unit]):Unit

putDnsMappings$default$2():scala.Function0[Unit]

registerConfigPanel(configPanel:code.data.ConfigurationPanel):Unit

registerFlow(name:java.lang.String, orchestrator:code.data.FlowOrchestrator, lock:code.data.FlowLock):Unit

registerStatefulBehaviourCreator(typeName:java.lang.String, providerFunc:scala.Function1[scala.Tuple3[code.data.EntityMetadatacode.data.Oscala.Option[code.data.DataType[Any]]]scala.util.Either[code.data.StatefulBehaviourjava.lang.Exception]]):Unit

registerStatefulBehaviourFactory(factory:code.data.StatefulBehaviourFactory):Unit

registerStepType(name:java.lang.String, creationFunc:scala.Function1[code.data.Oscala.util.Either[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.Exception]]):Unit

registerStreamProcessorFactory(factory:code.data.StreamProcessorFactory):Unit

relateOrchestration(parent:code.data.OrchestrationIdentity, child:code.data.OrchestrationIdentity):Unit

removeConfigPanel(id:java.lang.String):Unit

removeDnsMapping(host:java.lang.String, mapping:code.data.IpAddressMapping, after:scala.Function0[Unit]):Unit

removeDnsMapping$default$3():scala.Function0[Unit]

removePatchSet(id:java.lang.String):Unit

removeRecipe(id:java.lang.String):scala.util.Either[booleanjava.lang.Exception]

removeResourceCollection(id:java.lang.String, lock:code.data.FlowLock):boolean

removeStateItems(keys:scala.collection.immutable.List[java.lang.String], p:code.data.Payload[code.data.Datum], cf:code.data.ConsoleFilter):Unit

removeStatefulBehaviour(id:java.lang.String, lock:code.data.FlowLock):Unit

repo():code.data.IFlowRepository

setBuiltinProcessor(s:code.data.SharedProcessor[code.data.FlowRepositoryWrapper.TypeAcode.data.FlowRepositoryWrapper.TypeB], lock:code.data.FlowLock):scala.Option[code.data.SharedProcessor[code.data.FlowRepositoryWrapper.TypeAcode.data.FlowRepositoryWrapper.TypeB]]

setDnsService(dnsService:scala.Option[code.data.DnsService]):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[code.data.FlowRepositoryWrapper.TypeAcode.data.FlowRepositoryWrapper.TypeB], lock:code.data.FlowLock):scala.Option[code.data.SharedProcessor[code.data.FlowRepositoryWrapper.TypeAcode.data.FlowRepositoryWrapper.TypeB]]

synchronized(x$1:java.lang.Object.T0):java.lang.Object.T0

timeIt(msg:Unknown Nothing):Unit

timeIt(msg:Unknown Nothing, a:code.data.Timed.T):code.data.Timed.T

toString():java.lang.String

unregisterFlow(name:java.lang.String, lock:code.data.FlowLock):Unit

updateBundle(repo:code.data.IFlowRepository, id:java.lang.String, bundle:code.data.Bundle, lock:code.data.FlowLock):scala.util.Either[Unitscala.collection.immutable.List[java.lang.Exception]]

wait():Unit

wait(x$1:long):Unit

wait(x$1:long, x$2:int):Unit