Packages

package assets

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. trait Asset[T] extends AnyRef

    Parent Asset interface

    Parent Asset interface

    T

    Model/Schema/Stream/Sensor

  2. trait Bag[Meta, Value] extends Iterable[Meta with Asset[Value]]

    Parent Bag interface

    Parent Bag interface

    Meta

    Metadata object

    Value

    Value object

  3. case class EngineConfigMessage(src: String, timestamp: OffsetDateTime, messageType: PneumoMessageType.Value, item: EngineConfigItem.Value, ref: Either[Int, String]) extends PneumoMessage with Product with Serializable

    Pneumo Engine Config Message

  4. case class EngineStateMessage(src: String, timestamp: OffsetDateTime, messageType: PneumoMessageType.Value, state: EngineState.Value) extends PneumoMessage with Product with Serializable

    Pneumo Engine State Message

  5. case class HealthMessage(src: String, timestamp: OffsetDateTime, messageType: PneumoMessageType.Value, instance: String, health: String) extends PneumoMessage with Product with Serializable

    Pneumo Health Message

  6. case class InputBatch(slot: Int, seqno: Int, data: List[String], batchLen: Int, encoding: StreamEncoding.Value) extends Product with Serializable

    Pneumo Input Batch Message

  7. case class LogMessage(src: String, timestamp: OffsetDateTime, messageType: PneumoMessageType.Value, level: Int, text: String) extends PneumoMessage with Product with Serializable

    Pneumo Engine Log Message

  8. case class Model(format: String, source: String, schema: Map[Int, String]) extends ModelSerializer with Product with Serializable

    Model

    Model

    format

    model format

    source

    model source

    schema

    extracted model schema

  9. class ModelBag extends Bag[ModelMetadata, Model]

    A live collection of models in ModelManage

  10. case class ModelConsoleMessage(src: String, timestamp: OffsetDateTime, messageType: PneumoMessageType.Value, text: String) extends PneumoMessage with Product with Serializable

    Pneumo Model Console Message

  11. case class ModelErrorMessage(src: String, timestamp: OffsetDateTime, messageType: PneumoMessageType.Value, input: Option[InputBatch], console: String) extends PneumoMessage with Product with Serializable

    Pneumo Model Error Message

  12. sealed trait ModelMetaOps extends AnyRef

    ModelMetadata companion trait

  13. case class ModelMetadata(name: String, format: String, modelmanage: ModelManage) extends ModelMetaOps with Asset[Model] with Product with Serializable

    ModelMetadata

    ModelMetadata

    name

    model name

    format

    model format

    modelmanage

    modelmanage instance hosting the model

  14. sealed trait ModelSerializer extends AnyRef

    Model Serialization companion trait

  15. sealed trait PneumoMessage extends AnyRef

    Pneumo Message parent trait

  16. case class Schema(source: String) extends SchemaSerializer with Product with Serializable

    Schema object

    Schema object

    source

    schema source

  17. class SchemaBag extends Bag[SchemaMetadata, Schema]

    A live collection of schemas in ModelManage

  18. sealed trait SchemaMetaOps extends AnyRef

    SchemaMetadata companion trait

  19. case class SchemaMetadata(name: String, modelmanage: ModelManage) extends SchemaMetaOps with Asset[Schema] with Product with Serializable

    SchemaMetadata

    SchemaMetadata

    name

    name of the schema in ModelManage

    modelmanage

    ModelManage instance

  20. sealed trait SchemaSerializer extends AnyRef

    Schema serializer companion trait

  21. case class Sensor(tap: SensorTap, description: Option[String] = None, activate: SensorActivate, filter: Option[SensorFilter] = None, aggregate: Option[SensorAggregate] = None, sink: SensorSink = SensorSinkPneumo, report: Option[SensorReport] = None) extends SensorJSONSerializer with Product with Serializable

    Sensor object

  22. case class SensorActivate(_type: SensorActivateType.Value, intensityOrInterval: Option[SensorActivateIntensityOrInterval] = None, duration: Option[Double] = None, maxReads: Option[Int] = Some(1)) extends Product with Serializable

    Sensor Activate parameter

  23. case class SensorActivateIntensity(value: Double) extends SensorActivateIntensityOrInterval with Product with Serializable

    Sensor Activate Intensity parameter

    Sensor Activate Intensity parameter

    value

    intensity

  24. sealed trait SensorActivateIntensityOrInterval extends AnyRef

    Sensor Activate Intensity/Interval parent trait

  25. case class SensorActivateInterval(value: Double) extends SensorActivateIntensityOrInterval with Product with Serializable

    Sensor Activate Interval parameter

    Sensor Activate Interval parameter

    value

    interval

  26. case class SensorAggregate(_type: SensorAggregateType.Value = SensorAggregateType.accumulate, sampleSize: Option[Int] = None) extends Product with Serializable

    Sensor Aggregate parameter

  27. class SensorBag extends Bag[SensorMetadata, Sensor]

    A live collection of sensors in ModelManage

  28. case class SensorFilter(_type: SensorFilterType.Value, threshold: Either[Int, Double], minValue: Option[Either[Int, Double]] = None, maxValue: Option[Either[Int, Double]] = None) extends Product with Serializable

    Sensor Filter parameter

  29. trait SensorJSONSerializer extends AnyRef

    Sensor serializer helper trait

  30. sealed trait SensorMetaOps extends AnyRef

    SensorMetadata helper trait

  31. case class SensorMetadata(name: String, modelmanage: ModelManage) extends SensorMetaOps with Asset[Sensor] with Product with Serializable

    SensorMetadata

    SensorMetadata

    name

    name of the sensor in ModelManage

    modelmanage

    ModelManage instance hosting the sensor

  32. case class SensorReport(interval: Double = 0.0) extends Product with Serializable

    Sensor Report parameter

    Sensor Report parameter

    interval

    report interval

  33. case class SensorReportMessage(src: String, timestamp: OffsetDateTime, messageType: PneumoMessageType.Value, id: Int, tap: SensorTapInstance, data: Int, deltaTime: Option[Double]) extends PneumoMessage with Product with Serializable

    Pneumo Sensor Report Message

  34. sealed trait SensorSink extends AnyRef

    Sensor Sink parameter parent trait

  35. case class SensorSinkKafka(topic: String, partition: Option[Int] = Some(0)) extends SensorSink with Product with Serializable

    Sensor Sink Kafka

    Sensor Sink Kafka

    topic

    kafka topic

    partition

    kafka partition

  36. case class SensorTap(prefix: SensorTapPrefix.Value, suffix: SensorTapSuffix.Value) extends SensorTapSerializer with Product with Serializable

    Sensor Tap parameter

    Sensor Tap parameter

    prefix

    sensor tap prefix

    suffix

    sensor tap suffix

  37. case class SensorTapInstance(prefix: SensorTapPrefix.Value, slot: Int, suffix: SensorTapSuffix.Value) extends SensorTapInstanceSerializer with Product with Serializable

    SensorTapInstance

    SensorTapInstance

    Sensor Tap + Slot it's attached to

    prefix

    Sensor Tap prefix

    slot

    Sensor Slot

    suffix

    Sensor Tap suffix

  38. trait SensorTapInstanceSerializer extends AnyRef

    SensorTapInstance serializer helper trait

  39. trait SensorTapSerializer extends AnyRef

    Sensor Tap serializer

  40. case class Stream(version: String = "1.2", description: Option[String] = None, transport: StreamTransport, loop: Boolean = false, skipTo: Option[Int] = None, skipToRecord: Option[Either[Int, KafkaSkipToRecord.Value]] = None, envelope: Option[StreamEnvelope] = None, encoding: Option[StreamEncoding.Value] = None, schema: Option[Either[String, StreamSchemaRef]] = None, batching: Either[StreamBatchingMode.Value, StreamBatching] = Left(StreamBatchingMode.normal), lingerTime: Int = 3000) extends StreamJSONSerializer with Product with Serializable

    Stream object

  41. class StreamBag extends Bag[StreamMetadata, Stream]

    A live collection of streams in ModelManage

  42. case class StreamBatching(watermark: Int, nagleTime: Int) extends Product with Serializable

    Stream Batching

  43. sealed trait StreamEnvelope extends AnyRef

    Stream Envelope Parent Trait

  44. case class StreamEnvelopeDelimited(separator: String) extends StreamEnvelope with Product with Serializable

    Delimited Stream Envelope

  45. case class StreamEnvelopeFixed(size: Int) extends StreamEnvelope with Product with Serializable

    Fixed Stream Envelope

  46. case class StreamEnvelopeOcfBlock(syncMarker: Option[String] = None, skipHeader: Boolean = false) extends StreamEnvelope with Product with Serializable

    OCF-Block Stream Envelope

  47. trait StreamJSONSerializer extends AnyRef

    Stream Serializer helper trait

  48. sealed trait StreamMetaOps extends AnyRef

    StreamMetadata helper trait

  49. case class StreamMetadata(name: String, modelmanage: ModelManage) extends StreamMetaOps with Asset[Stream] with Product with Serializable

    StreamMetadata

    StreamMetadata

    name

    name of stream in ModelManage

    modelmanage

    ModelManage instance hosting the stream

  50. case class StreamSchemaRef(ref: String) extends Product with Serializable

    Stream Schema name reference

  51. sealed trait StreamTransport extends AnyRef

    Stream transport parameter parent trait

  52. case class StreamTransportExec(run: String) extends StreamTransport with Product with Serializable

    Exec Stream Transport

  53. case class StreamTransportFile(path: String) extends StreamTransport with Product with Serializable

    File Stream Transport

  54. case class StreamTransportHTTP(url: String) extends StreamTransport with Product with Serializable

    HTTP Stream transport

    HTTP Stream transport

    url

    target URL

  55. case class StreamTransportInline(data: Option[Either[String, List[String]]] = None, dataBinary: Option[Either[String, List[String]]] = None) extends StreamTransport with Product with Serializable

    Inline Stream Transport

    Inline Stream Transport

    data

    Base64 encoded data

    dataBinary

    Binary data

  56. case class StreamTransportKafka(bootstrapServers: List[String], topic: String, partition: Option[Int] = Some(0), maxWaitTime: Option[Int] = Some(0x7fffff)) extends StreamTransport with Product with Serializable

    Kafka Stream transport

    Kafka Stream transport

    bootstrapServers

    Kafka BootStrap servers

    topic

    Kafka topic

    partition

    Kafka partition

  57. case class StreamTransportODBC(connectionString: String, selectQuery: String, insertIntoTable: String, outputFields: Option[List[String]], timeout: Option[Int] = None) extends StreamTransport with Product with Serializable

    ODBC Stream Transport

  58. case class StreamTransportREST(mode: StreamTransportRESTMode.Value = StreamTransportRESTMode.simple) extends StreamTransport with Product with Serializable

    REST Stream Transport Mode parameter

  59. case class StreamTransportTCP(host: String, port: Int) extends StreamTransport with Product with Serializable

    TCP Stream Transport

  60. case class StreamTransportUDP(bindTo: String = "0.0.0.0", port: Int) extends StreamTransport with Product with Serializable

    UDP Stream Transport

Value Members

  1. object Constants

    Constants

  2. object EngineConfigItem extends Enumeration

    Pneumo EngineConfigItem values

  3. object EngineState extends Enumeration

    EngineState parameter values

  4. object KafkaSkipToRecord extends Enumeration with Product with Serializable

    Kafka SkipToRecord parameter

  5. object Model extends Serializable

    Model factory

  6. object ModelParseOps

    Model Parsing helper functions

  7. object PneumoMessageType extends Enumeration

    Pneumo message types

  8. object Schema extends Serializable

    Schema factory

  9. object Sensor extends Serializable

    Sensor factory

  10. object SensorActivateType extends Enumeration

    Sensor Activate parameter

  11. object SensorAggregateType extends Enumeration

    Sensor Aggregate Type parameter

  12. object SensorFilterType extends Enumeration

    Sensor Activate Filter parameter type

  13. object SensorSinkPneumo extends SensorSink with Product with Serializable

    Sensor Sink Pneumo

  14. object SensorSinkType extends Enumeration

    Sensor Sink parameter type

  15. object SensorTapPrefix extends Enumeration

    Sensor tap prefix

  16. object SensorTapSuffix extends Enumeration

    Sensor tap suffix

  17. object Stream extends Serializable

    Stream factory

  18. object StreamBatchingMode extends Enumeration with Product with Serializable

    Stream Batching Mode parameter

  19. object StreamEncoding extends Enumeration with Product with Serializable

    Stream Encoding Parameter

  20. object StreamEnvelopeType extends Enumeration with Product with Serializable

    Stream Envelope Type

  21. object StreamTransportDiscard extends StreamTransport with Product with Serializable

    Discard Stream Transport

  22. object StreamTransportRESTMode extends Enumeration with Product with Serializable

    REST Stream Transport

  23. object StreamTransportType extends Enumeration with Product with Serializable

    Stream Transport parameter Type

Ungrouped