portals-core
API
Generated with
portals-core/portals/portals.application

portals.application

package portals.application

Members list

Packages

package portals.application.generator
package portals.application.sequencer
package portals.application.splitter
package portals.application.task

Type members

Classlikes

sealed trait AST

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Application
class AtomicConnection[T]
class AtomicGenerator[T]
class AtomicPortal[T, R]
trait AtomicPortalRefKind[T, R]
class AtomicPortalRef[T, R]
class ExtAtomicPortalRef[T, R]
class AtomicSequencer[T]
class AtomicSplit[T]
class AtomicSplitter[T]
class AtomicStream[T]
class AtomicStreamRef[T]
class Workflow[T, U]
Show all
object ASTPrinter

Attributes

Supertypes
class Object
trait Matchable
class Any
Self type
ASTPrinter.type
case class Application(path: String, workflows: List[Workflow[_, _]], generators: List[AtomicGenerator[_]], streams: List[AtomicStream[_]], sequencers: List[AtomicSequencer[_]], splitters: List[AtomicSplitter[_]], connections: List[AtomicConnection[_]], splits: List[AtomicSplit[_]], portals: List[AtomicPortal[_, _]], externalStreams: List[ExtAtomicStreamRef[_]], externalSequencers: List[ExtAtomicSequencerRef[_]], externalSplitters: List[ExtAtomicSplitterRef[_]], externalPortals: List[ExtAtomicPortalRef[_, _]]) extends AST

Application.

Application.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicConnection[T](path: String, from: AtomicStreamRefKind[T], to: AtomicSequencerRefKind[T]) extends AST

Atomic Connection.

Atomic Connection.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicGenerator[T](path: String, stream: AtomicStreamRef[T], generator: Generator[T]) extends AST

Atomic Generator.

Atomic Generator.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicGeneratorRef[T](path: String, stream: AtomicStreamRef[T]) extends AST

Atomic Generator Ref.

Atomic Generator Ref.

Attributes

Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
object AtomicGeneratorRef

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
case class AtomicPortal[T, R](path: String, key: Option[T => Long]) extends AST

Atomic Portal.

Atomic Portal.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicPortalRef[T, R](path: String) extends AtomicPortalRefKind[T, R]

Atomic Portal Reference.

Atomic Portal Reference.

Attributes

Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait AtomicPortalRefKind[T, R]
trait AST
class Object
trait Matchable
class Any
Show all
object AtomicPortalRef

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
sealed trait AtomicPortalRefKind[T, R] extends AST

Atomic Portal Reference.

Atomic Portal Reference.

Attributes

Supertypes
trait AST
class Object
trait Matchable
class Any
Known subtypes
class AtomicPortalRef[T, R]
class ExtAtomicPortalRef[T, R]
case class AtomicSequencer[T](path: String, stream: AtomicStreamRef[T], sequencer: Sequencer[T]) extends AST

Atomic Sequencer.

Atomic Sequencer.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicSequencerRef[T](path: String, stream: AtomicStreamRef[T]) extends AtomicSequencerRefKind[T]

Atomic Sequencer Ref.

Atomic Sequencer Ref.

Attributes

Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
object AtomicSequencerRef

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
sealed trait AtomicSequencerRefKind[T] extends AST

Atomic Sequencer Ref.

Atomic Sequencer Ref.

Attributes

Supertypes
trait AST
class Object
trait Matchable
class Any
Known subtypes
case class AtomicSplit[T](path: String, from: AtomicSplitterRefKind[T], to: AtomicStreamRefKind[T], filter: T => Boolean) extends AST

Atomic Split.

Atomic Split.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicSplitter[T](path: String, in: AtomicStreamRefKind[T], streams: List[AtomicStreamRefKind[T]], splitter: Splitter[T]) extends AST

Atomic Splitter.

Atomic Splitter.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicSplitterRef[T](path: String) extends AtomicSplitterRefKind[T]

Atomic Splitter Ref.

Atomic Splitter Ref.

Attributes

Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
object AtomicSplitterRef

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
sealed trait AtomicSplitterRefKind[T] extends AST

Atomic Splitter Ref.

Atomic Splitter Ref.

Attributes

Supertypes
trait AST
class Object
trait Matchable
class Any
Known subtypes
case class AtomicStream[T](path: String) extends AST

Atomic Stream.

Atomic Stream.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class AtomicStreamRef[T](path: String) extends AtomicStreamRefKind[T]

Atomic Stream Ref.

Atomic Stream Ref.

Attributes

Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
object AtomicStreamRef

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
sealed trait AtomicStreamRefKind[T] extends AST

Atomic Stream Ref Kind.

Atomic Stream Ref Kind.

Attributes

Supertypes
trait AST
class Object
trait Matchable
class Any
Known subtypes
class AtomicStreamRef[T]
case class ExtAtomicPortalRef[T, R](path: String) extends AtomicPortalRefKind[T, R]

External Atomic Portal Reference.

External Atomic Portal Reference.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AtomicPortalRefKind[T, R]
trait AST
class Object
trait Matchable
class Any
Show all
case class ExtAtomicSequencerRef[T](path: String, stream: ExtAtomicStreamRef[T]) extends AtomicSequencerRefKind[T]

External Atomic Sequencer Ref.

External Atomic Sequencer Ref.

Attributes

Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
object ExtAtomicSequencerRef

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
case class ExtAtomicSplitterRef[T](path: String) extends AtomicSplitterRefKind[T]

External Atomic Splitter Ref.

External Atomic Splitter Ref.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class ExtAtomicStreamRef[T](path: String) extends AtomicStreamRefKind[T]

External Atomic Stream Ref.

External Atomic Stream Ref.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all
case class Workflow[T, U](path: String, consumes: AtomicStreamRefKind[T], stream: AtomicStreamRef[U], tasks: Map[String, GenericTask[_, _, _, _]], source: String, sink: String, connections: List[(String, String)]) extends AST

Workflow.

Workflow.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait AST
class Object
trait Matchable
class Any
Show all

Extensions

Extensions

extension [T](atomicSequencer: AtomicSequencer[T])(atomicSequencer: AtomicSequencer[T])
extension [T](atomicSplitter: AtomicSplitter[T])(atomicSplitter: AtomicSplitter[T])
extension [T](atomicStream: AtomicStream[T])(atomicStream: AtomicStream[T])
Generated with