code.data.Payload

Aliases

Parameters

code.data.campus.CourseMutator$Action

subClasses

superClasses

Any

code.data.HasLogSource

code.data.Redactable

code.data.WithJValue

java.lang.Object

Js Constructors

new code_data_Payload(
    orchestrationIdentity, // scala.Option[code.data.OrchestrationIdentity]
    repo, // scala.Option[code.data.IFlowRepository]
    incomingState, // scala.collection.mutable.HashMap[Anyjava.lang.String]
    incomingStep, // scala.Tuple2[java.lang.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:Any):boolean

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

$hash$hash():int

$init$():Unit

addRedaction(jv:net.liftweb.json.JsonAST$JValue, persist:boolean):Unit

addRedaction$default$2():boolean

addRedactions(jv:scala.collection.immutable.List[net.liftweb.json.JsonAST$JValue], persist:boolean):Unit

addRedactions(r:scala.collection.immutable.List[net.liftweb.json.JsonAST$JValue]):Unit

addRedactions$default$2():boolean

allData():code.data.FlowStream[code.data.Payload.PAYLOAD_TYPE]

allExceptions():code.data.FlowStream[java.lang.Exception]

asInstanceOf():scala.Any.T0

asJValue():net.liftweb.json.JsonAST$JValue

asJValue(explicit:boolean):net.liftweb.json.JsonAST$JValue

clearLiftSession():Unit

debug(msg:java.lang.String, args:scala.collection.immutable.List[Any], source:scala.Option[code.data.LogSource]):Unit

debug$default$3(msg:java.lang.String, args:scala.collection.immutable.List[Any]):scala.Option[code.data.LogSource]

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

equals(x$1:Any):boolean

error(msg:java.lang.String, args:scala.collection.immutable.List[Any], source:scala.Option[code.data.LogSource]):Unit

error$default$3(msg:java.lang.String, args:scala.collection.immutable.List[Any]):scala.Option[code.data.LogSource]

filterState(func:scala.Function1[booleanjava.lang.String]):code.data.Payload[code.data.Payload.PAYLOAD_TYPE]

firstError():scala.Option[java.lang.Exception]

firstSuccess():scala.Option[code.data.Payload.PAYLOAD_TYPE]

flowStream():code.data.FlowStream[scala.util.Either[code.data.FlowDataStreamExceptioncode.data.Payload.PAYLOAD_TYPE]]

get(key:java.lang.String):scala.Option[Any]

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

getConsole():scala.collection.immutable.List[code.data.ConsoleMessage]

getConsoleCollection():code.data.ConsoleMessageCollection

getHealth():scala.Enumeration$Value

getJValue():net.liftweb.json.JsonAST$JValue

getLiftSession():scala.Option[net.liftweb.http.LiftSession]

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[Anyjava.lang.String]

getStep():scala.Tuple2[java.lang.Stringscala.Option[code.data.LogSource]]

getSummaryJValue():net.liftweb.json.JsonAST$JValue

hashCode():int

head():code.data.Payload.PAYLOAD_TYPE

headData():scala.Option[code.data.Payload.PAYLOAD_TYPE]

in():scala.util.Either[code.data.FlowStream[scala.util.Either[code.data.FlowDataStreamExceptioncode.data.Payload.PAYLOAD_TYPE]]java.lang.Exception]

info(msg:java.lang.String, args:scala.collection.immutable.List[Any], source:scala.Option[code.data.LogSource]):Unit

info$default$3(msg:java.lang.String, args:scala.collection.immutable.List[Any]):scala.Option[code.data.LogSource]

isEmpty():boolean

isFailure():boolean

isHealthy():boolean

isInstanceOf():boolean

isPartiallyHealthy():boolean

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

metadata():code.data.metadata.FlowMetaData

metric(metric:code.data.Metric):Unit

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

notify():Unit

notifyAll():Unit

orchestration():scala.Option[code.data.IFlowOrchestration]

orchestrationIdentity():scala.Option[code.data.OrchestrationIdentity]

print(msg:java.lang.String, args:scala.collection.immutable.List[Any], source:scala.Option[code.data.LogSource]):Unit

print$default$3():scala.Option[code.data.LogSource]

purgeIn():Unit

put(key:java.lang.String, obj:Any):Unit

putMany(items:scala.collection.immutable.Map[java.lang.Stringscala.Option[Any]]):Unit

redactor():code.data.Redactor

remove(key:java.lang.String):Unit

removeData():code.data.Payload[code.data.Datum]

removeWhere(keyFunc:scala.Function1[booleanjava.lang.String]):Unit

repo():scala.Option[code.data.IFlowRepository]

setHealth(ph:scala.Enumeration$Value):code.data.Payload[code.data.Payload.PAYLOAD_TYPE]

setIn(incomingIn:scala.util.Either[code.data.FlowStream[scala.util.Either[code.data.FlowDataStreamExceptioncode.data.Payload.PAYLOAD_TYPE]]java.lang.Exception]):Unit

setLiftSession(ls:net.liftweb.http.LiftSession):Unit

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

setOrchWeakly(orch:scala.Option[code.data.IFlowOrchestration]):Unit

shutdownPayload():Unit

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

toJValue():net.liftweb.json.JsonAST$JValue

toString():java.lang.String

trace(msg:java.lang.String, args:scala.collection.immutable.List[Any], source:scala.Option[code.data.LogSource]):Unit

trace$default$3(msg:java.lang.String, args:scala.collection.immutable.List[Any]):scala.Option[code.data.LogSource]

transform(newValue:scala.util.Either[code.data.FlowStream[scala.util.Either[code.data.FlowDataStreamExceptioncode.data.Payload.TRANSFORM_TYPE]]java.lang.Exception], logSource:scala.Option[code.data.LogSource]):code.data.Payload[code.data.Payload.TRANSFORM_TYPE]

transform(other:code.data.Payload[code.data.Payload.TRANSFORM_TYPE], logSource:scala.Option[code.data.LogSource]):code.data.Payload[code.data.Payload.TRANSFORM_TYPE]

transform(transformer:code.data.StreamProcessor[code.data.Datumcode.data.Datum], newValue:scala.util.Either[code.data.FlowStream[scala.util.Either[code.data.FlowDataStreamExceptioncode.data.Payload.TRANSFORM_TYPE]]java.lang.Exception], logSource:scala.Option[code.data.LogSource]):code.data.Payload[code.data.Payload.TRANSFORM_TYPE]

unredactedJValue():net.liftweb.json.JsonAST$JValue

unredactedJValue(explicit:boolean):net.liftweb.json.JsonAST$JValue

unredactedJValue$default$1():boolean

wait():Unit

wait(x$1:long):Unit

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

warn(msg:java.lang.String, args:scala.collection.immutable.List[Any], source:scala.Option[code.data.LogSource]):Unit

warn$default$3(msg:java.lang.String, args:scala.collection.immutable.List[Any]):scala.Option[code.data.LogSource]

withOrchestration(fo:scala.Option[code.data.IFlowOrchestration]):code.data.Payload[code.data.Payload.PAYLOAD_TYPE]