class MinimalKafkaExecutor extends StatelessExecutor[ObjectId] with DelegatedPiObservable[ObjectId]
Minimal implementation of a KafkaExecutor that needs to be present on the local machine to complete the Executor interface. Other components are required are required to run on the Kafka cluster but need not be situated on the local machine.
- Alphabetic
- By Inheritance
- MinimalKafkaExecutor
- DelegatedPiObservable
- PiObservable
- StatelessExecutor
- ProcessExecutor
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new MinimalKafkaExecutor()(implicit environment: KafkaExecutorEnvironment)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to any2stringadd[MinimalKafkaExecutor] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (MinimalKafkaExecutor, B)
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to ArrowAssoc[MinimalKafkaExecutor] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- implicit val actorSystem: ActorSystem
- lazy val allControls: Seq[DrainControl]
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
call[H <: PiEventHandler[ObjectId]](instance: PiInstance[_], factory: PiEventHandlerFactory[ObjectId, H]): Future[H]
A
init ; start
sequence that gives us a chance to subscribe a listener that is specific to this execution.A
init ; start
sequence that gives us a chance to subscribe a listener that is specific to this execution. A new ID will be generated for the PiInstance to ensure freshness.- instance
The PiInstance to be executed
- factory
A PiEventHandlerFactory which generates PiEventHandler's for a given ID
- returns
A Future with the PiEventHandler that was generated
- Definition Classes
- ProcessExecutor
-
def
call[H <: PiEventHandler[ObjectId]](process: PiProcess, args: Seq[Any], factory: PiEventHandlerFactory[ObjectId, H]): Future[H]
A
init ; start
sequence that gives us a chance to subscribe a listener that is specific to this execution.A
init ; start
sequence that gives us a chance to subscribe a listener that is specific to this execution.- process
The (atomic or composite) PiProcess to be executed
- args
The (real) arguments to be passed to the process
- factory
A PiEventHandlerFactory which generates PiEventHandler's for a given ID
- returns
A Future with the PiEventHandler that was generated
- Definition Classes
- ProcessExecutor
-
def
call(instance: PiInstance[_]): Future[ObjectId]
A simple
init ; start
sequence when we do not need any even listeners.A simple
init ; start
sequence when we do not need any even listeners. A new ID will be generated for the PiInstance to ensure freshness.- instance
The PiInstance to be executed
- returns
A Future with the ID corresponding to this execution
- Definition Classes
- ProcessExecutor
-
def
call(process: PiProcess, args: Seq[Any]): Future[ObjectId]
A simple
init ; start
sequence when we do not need any even listeners.A simple
init ; start
sequence when we do not need any even listeners.- process
The (atomic or composite) PiProcess to be executed
- args
The (real) arguments to be passed to the process
- returns
A Future with the ID corresponding to this execution
- Definition Classes
- ProcessExecutor
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
ensuring(cond: (MinimalKafkaExecutor) ⇒ Boolean, msg: ⇒ Any): MinimalKafkaExecutor
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to Ensuring[MinimalKafkaExecutor] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (MinimalKafkaExecutor) ⇒ Boolean): MinimalKafkaExecutor
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to Ensuring[MinimalKafkaExecutor] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): MinimalKafkaExecutor
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to Ensuring[MinimalKafkaExecutor] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): MinimalKafkaExecutor
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to Ensuring[MinimalKafkaExecutor] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- implicit val environment: KafkaExecutorEnvironment
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val eventHandler: ResultListener
- val eventHandlerControl: DrainControl
-
def
execute(instance: PiInstance[_]): Future[Any]
Executes a PiInstance with a PromiseHandler A new ID will be generated for the PiInstance to ensure freshness.
Executes a PiInstance with a PromiseHandler A new ID will be generated for the PiInstance to ensure freshness.
- returns
A Future with the result of the executed process
- Definition Classes
- ProcessExecutor
-
def
execute(process: PiProcess, args: Seq[Any]): Future[Any]
Executes a process with a PromiseHandler
Executes a process with a PromiseHandler
- returns
A Future with the result of the executed process
- Definition Classes
- ProcessExecutor
-
implicit
val
executionContext: ExecutionContext
- Definition Classes
- MinimalKafkaExecutor → ProcessExecutor
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
forceShutdown: Future[Done]
- Definition Classes
- MinimalKafkaExecutor → StatelessExecutor
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to StringFormat[MinimalKafkaExecutor] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
init(instance: PiInstance[_]): Future[ObjectId]
Initializes a PiInstance for a process execution.
Initializes a PiInstance for a process execution. A new ID will be generated for the PiInstance to ensure freshness. This is always and only invoked before a
start
, hence why it is protected. This separation gives a chance to PiEventHandlers to subscribe before execution starts.- instance
The PiInstance to be executed
- returns
A Future with the new unique ID that was generated
- Definition Classes
- MinimalKafkaExecutor → ProcessExecutor
-
def
init(process: PiProcess, args: Seq[PiObject]): Future[ObjectId]
Initializes a PiProcess call for a process execution.
Initializes a PiProcess call for a process execution. This is always and only invoked before a
start
, hence why it is protected. This separation gives a chance to PiEventHandlers to subscribe before execution starts.- process
The (atomic or composite) PiProcess to be executed
- args
The PiObject arguments to be passed to the process
- returns
A Future with the new unique ID that was generated
- Attributes
- protected
- Definition Classes
- ProcessExecutor
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isShutdown: Boolean
- implicit val materializer: Materializer
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
var
piiStore: PiInstanceStore[ObjectId]
- Attributes
- protected
-
def
shutdown: Future[Done]
- Definition Classes
- MinimalKafkaExecutor → StatelessExecutor
-
def
start(id: ObjectId): Unit
Starts the execution of an initialized PiInstance.
Starts the execution of an initialized PiInstance. This is always and only invoked after an
init
, hence why it is protected. This separation gives a chance to PiEventHandlers to subscribe before execution starts.- id
The ID of the instance to start executing
- Definition Classes
- MinimalKafkaExecutor → ProcessExecutor
-
def
subscribe(handler: PiEventHandler[ObjectId]): Future[PiSwitch]
Subscribes a com.workflowfm.pew.stream.PiEventHandler to observe.
Subscribes a com.workflowfm.pew.stream.PiEventHandler to observe.
- handler
the handler to subscribe
- returns
the com.workflowfm.pew.stream.PiSwitch that allows us to stop/unsubscribe the subscribed handler
- Definition Classes
- DelegatedPiObservable → PiObservable
-
final
def
syncShutdown(timeout: Duration = Duration.Inf): Done
- Definition Classes
- StatelessExecutor
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
val
worker: PiObservable[ObjectId]
- Definition Classes
- MinimalKafkaExecutor → DelegatedPiObservable
-
def
→[B](y: B): (MinimalKafkaExecutor, B)
- Implicit
- This member is added by an implicit conversion from MinimalKafkaExecutor to ArrowAssoc[MinimalKafkaExecutor] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc