< Back

Packages

package root
Just Another Fine Pipeline Language
Just Another Fine Pipeline Language
This is a pipeline framework. It’s built on top of Akka actors to support arbitrary data flow pipelines. It is wholly agnostic to the kinds of data that flow through the pipelines and the implementations of the steps that process them.
See http://jafpl.com/ for more general information.

Definition Classes
root
package com
The com package.
The com package.
Nothing to see here, keep going deeper.

Definition Classes
root
package jafpl
The jafpl package.
The jafpl package.
Nothing to see here either, keep going deeper.

Definition Classes
com
package runtime
The graph runtime APIs.
The graph runtime APIs.

Definition Classes
jafpl
ExpressionEvaluator
GraphRuntime
InputProxy
OutputProxy
Reaper
RuntimeConfiguration
TraceEvent
TracingActor

t

com.jafpl.runtime

RuntimeConfiguration

trait RuntimeConfiguration extends AnyRef

The runtime configuration for pipeline execution.

This object provides configuration information to the pipeline execution engine.

Linear Supertypes

AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

RuntimeConfiguration
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Abstract Value Members

abstract def expressionEvaluator: ExpressionEvaluator
Returns the expression evaluator.
Returns the expression evaluator.
An com.jafpl.runtime.ExpressionEvaluator is required to evaluate expressions for variable bindings and the when branches of a choose.
returns
The evaluator.
abstract def traceEnabled(trace: String): Boolean
Enable trace events.
Enable trace events.
The actors that run steps will emit log messages if the appropriate traces are enabled. This method is called to determine if a particular trace is enabled.
trace
A trace event.
returns
True, if that event should be considered enabled.
abstract def watchdogTimeout: Long
The watchdog timeout.
The watchdog timeout.
Pipelines are a message passing, data flow system. Progress only occurs when steps are producing and consuming items. If no messages are sent for a period of watchdogTimeout milliseconds, the pipeline will be treated as "hung" and terminated.
In practice, this exists to help debug the execution engine. (Implementation bugs can cause pipelines to hang.)
Disable the watchdog timer by returning 0.
When the com.jafpl.runtime.GraphRuntime is waiting for a pipeline

Concrete Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@native() @throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
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()
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
@native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped