code.data.IPatchedRepository

Aliases

Parameters

subClasses

superClasses

Any
code.data.Exceptor
code.data.FlowRepositoryWrapper
code.data.HasLogSource
code.data.IFlowRepository
code.data.Timed
java.lang.Object

Js Constructors

new code_data_IPatchedRepository(
    fr, // code.data.IFlowRepository
    ps, // code.data.PatchSet
    globals, // code.data.config.IGlobals
)

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:UnknownNothing):scala.collection.immutable.List[code.data.SerializableEntityAuditLog]
getAuditedActions(terms:UnknownNothing):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:UnknownNothing):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:UnknownNothing):scala.collection.immutable.List[code.data.FlowStatus]
getFlowStatusSummaries(terms:UnknownNothing):scala.collection.immutable.List[scala.Tuple2[java.lang.Stringscala.collection.immutable.List[scala.Tuple3[java.lang.Stringlongscala.Enumeration$Value]]]]
getFlowStatuses(terms:UnknownNothing):scala.collection.immutable.List[code.data.FlowStatus]
getLoggableStreamItems(terms:UnknownNothing):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, incomingName: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():code.data.PatchSet
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:UnknownNothing):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:UnknownNothing):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
patchConfigurationEntry(in:code.data.ConfigurationEntry):code.data.ConfigurationEntry
patchFlow(in:code.data.FlowOrchestrator):code.data.FlowOrchestrator
patchFlowName(incomingName:java.lang.String):java.lang.String
patchReferenceId(referenceId:java.lang.String):java.lang.String
patchResource(in:code.data.Resource, rc:code.data.ResourceCollection):code.data.Resource
patchResourceAccessor(accessor:code.data.ResourceAccessor):code.data.ResourceAccessor
patchResourceCollection(in:code.data.ResourceCollection):code.data.ResourceCollection
patchedResourceCollections():scala.collection.immutable.Map[code.data.ResourceCollectionjava.lang.String]
patchedResourceCollections_$eq(x$1:scala.collection.immutable.Map[code.data.ResourceCollectionjava.lang.String]):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:UnknownNothing):Unit
timeIt(msg:UnknownNothing, 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