code.data.Payload

Aliases

Parameters

code.data.campus.CourseMutator$Action

subClasses

superClasses

code.data.Redactable
code.data.WithJValue
java.lang.Object
scala.lang.Any

Js Constructors

new code_data_Payload(
    orchestrationIdentity, // scala.Option[code.data.OrchestrationIdentity]
    repo, // scala.Option[code.data.IFlowRepository]
    incomingState, // scala.collection.mutable.HashMap[java.lang.String:Stringscala.lang.Any:Any]
    incomingStep, // scala.Tuple2[java.lang.String:Stringscala.Option[code.data.LogSource]]
    incomingConsole, // code.data.ConsoleMessageCollection
    incomingMetrics, // code.data.MetricsCollection
    incomingRedactions, // code.data.RedactionsCollection
    incomingMetadata // code.data.metadata.FlowMetaData
)

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
addRedaction(jv:net.liftweb.json.JsonAST$JValue, persist:java.lang.Boolean:Boolean, ):scala.Unit:Unit
addRedaction$default$2():java.lang.Boolean:Boolean
addRedactions(jv:scala.collection.immutable.List[net.liftweb.json.JsonAST$JValue], persist:java.lang.Boolean:Boolean, ):scala.Unit:Unit
addRedactions(r:scala.collection.immutable.List[net.liftweb.json.JsonAST$JValue], ):scala.Unit:Unit
addRedactions$default$2():java.lang.Boolean:Boolean
allData():code.data.FlowStream[null:Null]
allExceptions():code.data.FlowStream[java.lang.Exception]
asInstanceOf():null:Null
asJValue():net.liftweb.json.JsonAST$JValue
asJValue(explicit:java.lang.Boolean:Boolean, ):net.liftweb.json.JsonAST$JValue
debug(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], source:scala.Option[code.data.LogSource], ):scala.Unit:Unit
debug$default$3(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], ):scala.Option[code.data.LogSource]
eq(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
equals(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean
error(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], source:scala.Option[code.data.LogSource], ):scala.Unit:Unit
error$default$3(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], ):scala.Option[code.data.LogSource]
filterState(func:scala.Function1[java.lang.Boolean:Booleanjava.lang.String:String], ):code.data.Payload[null:Null]
firstError():scala.Option[java.lang.Exception]
firstSuccess():scala.Option[null:Null]
flowStream():code.data.FlowStream[scala.util.Either[java.lang.Exceptionnull:Null]]
get(key:java.lang.String:String, ):scala.Option[scala.lang.Any:Any]
getClass():java.lang.Class[scala.lang.Any:Any]
getConsole():scala.collection.immutable.List[code.data.ConsoleMessage]
getConsoleCollection():code.data.ConsoleMessageCollection
getHealth():null:Null
getJValue():net.liftweb.json.JsonAST$JValue
getLogLevel():code.data.ConsoleFilter
getMetrics():scala.collection.immutable.List[code.data.Metric]
getMetricsCollection():code.data.MetricsCollection
getOrchestration():scala.Option[code.data.IFlowOrchestration]
getRedactions():scala.collection.immutable.List[net.liftweb.json.JsonAST$JValue]
getState():scala.collection.mutable.HashMap[java.lang.String:Stringscala.lang.Any:Any]
getStep():scala.Tuple2[java.lang.String:Stringscala.Option[code.data.LogSource]]
getSummaryJValue():net.liftweb.json.JsonAST$JValue
hashCode():java.lang.Int:Int
head():null:Null
headData():scala.Option[null:Null]
in():scala.util.Either[code.data.FlowStream[scala.util.Either[java.lang.Exceptionnull:Null]]java.lang.Exception]
info(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], source:scala.Option[code.data.LogSource], ):scala.Unit:Unit
info$default$3(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], ):scala.Option[code.data.LogSource]
isEmpty():java.lang.Boolean:Boolean
isFailure():java.lang.Boolean:Boolean
isHealthy():java.lang.Boolean:Boolean
isInstanceOf():java.lang.Boolean:Boolean
isPartiallyHealthy():java.lang.Boolean:Boolean
logSource():scala.Some[code.data.LogSource]
metadata():code.data.metadata.FlowMetaData
metric(metric:code.data.Metric, source:scala.Option[code.data.LogSource], ):scala.Unit:Unit
metric$default$2(metric:code.data.Metric, ):scala.Option[code.data.LogSource]
ne(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
notify():scala.Unit:Unit
notifyAll():scala.Unit:Unit
orchestration():scala.Option[code.data.IFlowOrchestration]
orchestrationIdentity():scala.Option[code.data.OrchestrationIdentity]
print(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], source:scala.Option[code.data.LogSource], ):scala.Unit:Unit
print$default$3():scala.Option[code.data.LogSource]
purgeIn():scala.Unit:Unit
put(key:java.lang.String:String, obj:scala.lang.Any:Any, ):scala.Unit:Unit
putMany(items:scala.collection.immutable.Map[java.lang.String:Stringscala.Option[scala.lang.Any:Any]], ):scala.Unit:Unit
redactor():code.data.Redactor
remove(key:java.lang.String:String, ):scala.Unit:Unit
removeData():code.data.Payload[null:Null]
removeWhere(keyFunc:scala.Function1[java.lang.Boolean:Booleanjava.lang.String:String], ):scala.Unit:Unit
repo():scala.Option[code.data.IFlowRepository]
setHealth(ph:null:Null, ):code.data.Payload[null:Null]
setIn(incomingIn:scala.util.Either[code.data.FlowStream[scala.util.Either[java.lang.Exceptionnull:Null]]java.lang.Exception], ):scala.Unit:Unit
setLogLevel(cf:scala.Option[code.data.ConsoleFilter], ):scala.Unit:Unit
setOrchWeakly(orch:scala.Option[code.data.IFlowOrchestration], ):scala.Unit:Unit
shutdownPayload():scala.Unit:Unit
synchronized(x$1:null:Null, ):null:Null
toJValue():net.liftweb.json.JsonAST$JValue
toString():java.lang.String:String
trace(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], source:scala.Option[code.data.LogSource], ):scala.Unit:Unit
trace$default$3(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], ):scala.Option[code.data.LogSource]
transform(newValue:scala.util.Either[code.data.FlowStream[scala.util.Either[java.lang.Exceptionnull:Null]]java.lang.Exception], logSource:scala.Option[code.data.LogSource], ):code.data.Payload[null:Null]
transform(other:code.data.Payload[null:Null], logSource:scala.Option[code.data.LogSource], ):code.data.Payload[null:Null]
transform(transformer:code.data.StreamProcessor[code.data.Datumcode.data.Datum], newValue:scala.util.Either[code.data.FlowStream[scala.util.Either[java.lang.Exceptionnull:Null]]java.lang.Exception], logSource:scala.Option[code.data.LogSource], ):code.data.Payload[null:Null]
unredactedJValue():net.liftweb.json.JsonAST$JValue
unredactedJValue(explicit:java.lang.Boolean:Boolean, ):net.liftweb.json.JsonAST$JValue
unredactedJValue$default$1():java.lang.Boolean:Boolean
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
warn(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], source:scala.Option[code.data.LogSource], ):scala.Unit:Unit
warn$default$3(msg:java.lang.String:String, args:scala.collection.immutable.List[scala.lang.Any:Any], ):scala.Option[code.data.LogSource]
withOrchestration(fo:scala.Option[code.data.IFlowOrchestration], ):code.data.Payload[null:Null]