code.data.StreamProcessor

Aliases

Parameters

code.data.SharedProcessor.TypeA, code.data.SharedProcessor.TypeB

subClasses

superClasses

Any

code.common.Telemetry

code.data.Exceptor

code.data.HasEntityDependencies

code.data.HasLogSource

code.data.PayloadCoercion

java.lang.Object

Js Constructors

new code_data_StreamProcessor(
    incomingConfig, // code.data.O
    repo, // code.data.IFlowRepository
    typeTagA, // scala.reflect.api.TypeTags$TypeTag[code.data.StreamProcessor.TypeA]
    typeTagB, // scala.reflect.api.TypeTags$TypeTag[code.data.StreamProcessor.TypeB]
)

ApplyMethods

Methods

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

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

$hash$hash():int

$init$():Unit

FlowOrchestrationStatusExtensions(status:code.data.FlowOrchestrationStatus):code.common.Telemetry$FlowOrchestrationStatusExtensions

TriggererLogExtensions(log:code.data.TriggererLog):code.common.Telemetry$TriggererLogExtensions

_clazzName():java.lang.String

act(in:code.data.Payload[code.data.Datum], flowOrchestration:code.data.IFlowOrchestration):code.data.Payload[code.data.StreamProcessor.TypeB]

asInstanceOf():scala.Any.T0

config():code.data.O

configurationContext():scala.Option[code.data.ConfigurationContext]

configurationEquals(other:Any):boolean

connectorTestConfigUniqueness():scala.Option[Any]

connectorTestPayloadDefinition(unused:Any):scala.Option[code.data.O]

createTestPayloadAroundItems(items:Unknown Nothing):code.data.Payload[code.data.StreamProcessor.C]

defaultPayload():code.data.Payload[code.data.StreamProcessor.TypeB]

delegateConnectorTestTo():scala.collection.immutable.List[code.data.StreamProcessor[code.data.Datumcode.data.Datum]]

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

equals(x$1:Any):boolean

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

getClassPath():java.lang.String

getConfiguration():code.data.O

getNextStepNameFunc(payload:scala.Option[code.data.Payload[code.data.Datum]], streamProcessors:scala.collection.immutable.Map[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.String]):scala.Option[scala.Function0[scala.Option[java.lang.String]]]

hashCode():int

inType():code.data.documentation.Doc

isConnector():boolean

isDependentUpon(dependencyEntityId:java.lang.String):boolean

isInstanceOf():boolean

localDependencies():scala.collection.immutable.Set[java.lang.String]

localShutdown(repo:code.data.IFlowRepository, lock:code.data.FlowLock):Unit

localStartup(repo:code.data.IFlowRepository, lock:code.data.FlowLock):Unit

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

meter():io.opentelemetry.api.metrics.Meter

name():java.lang.String

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

newFromConfig():scala.util.Either[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.Exception]

noopTracer(name:java.lang.String):io.opentelemetry.api.trace.Tracer

notify():Unit

notifyAll():Unit

outType():code.data.documentation.Doc

parseConnectorTestPayload(in:code.data.O):scala.Option[scala.Tuple2[code.data.Payload[code.data.StreamProcessor.TypeA]scala.Option[code.data.O]]]

preCacheDependencies():Unit

repo():code.data.IFlowRepository

responseVerifier():scala.Option[java.lang.String]

rootSpan(t:io.opentelemetry.api.trace.Tracer, name:java.lang.String, differentiator:java.lang.String, group:code.common.TelemetryGroup, func:scala.Function1[code.common.Telemetry.Rio.opentelemetry.api.trace.Span]):code.common.Telemetry.R

runningStreamProcessors():io.opentelemetry.api.metrics.LongUpDownCounter

shouldPin():scala.collection.immutable.List[java.lang.String]

span(t:io.opentelemetry.api.trace.Tracer, name:java.lang.String, differentiator:java.lang.String, group:code.common.TelemetryGroup, func:scala.Function1[code.common.Telemetry.Rio.opentelemetry.api.trace.Span]):code.common.Telemetry.R

spanName(name:java.lang.String, instance:java.lang.String):java.lang.String

startSpan(t:io.opentelemetry.api.trace.Tracer, name:java.lang.String, group:code.common.TelemetryGroup):io.opentelemetry.api.trace.Span

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

testData():scala.Option[net.liftweb.json.JsonAST$JValue]

toString():java.lang.String

tracer():io.opentelemetry.api.trace.Tracer

transformTestDataFunc():scala.Option[java.lang.String]

typeTagA():scala.reflect.api.TypeTags$TypeTag[code.data.StreamProcessor.TypeA]

typeTagB():scala.reflect.api.TypeTags$TypeTag[code.data.StreamProcessor.TypeB]

wait():Unit

wait(x$1:long):Unit

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

withParent(t:io.opentelemetry.api.trace.Tracer, oParent:scala.Option[io.opentelemetry.api.trace.Span], name:java.lang.String, differentiator:java.lang.String, group:code.common.TelemetryGroup, func:scala.Function1[code.common.Telemetry.Rio.opentelemetry.api.trace.Span]):code.common.Telemetry.R