object ObservationTypeEvents
Declares public types for the types of observation handled by the system, regardless of how the observation has been sourced. Each class or type of observation has its own name and relevant topic, i.e. water sensors are distinct from soil sensors and thus have distinct types.
- Alphabetic
- By Inheritance
- ObservationTypeEvents
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- sealed abstract class Event extends AnyRef
Events that can be appended representing observation type state
- final case class ObservationTypeRemoved(topic: String) extends Event with Product with Serializable
Represents the removal of an ObservationType given a topic
- final case class ObservationTypeUpdated(name: String, topic: String, secretPath: String, view: String) extends Event with Product with Serializable
Represents an ObservationType, i.e.
Represents an ObservationType, i.e. a type of device that can be provisioned and the topic its data is pushed to. We also associate a path to an encryption/ decryption secret, and finally, JavaScript code to render how a type is viewed.
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
- val EventTopic: Topic
Where observation type events are appended to
- def appender(): Flow[Event, CommandRequest[Nothing], NotUsed]
A convenience function for encoding an observation type event and then publishing it to a queue.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- 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 tailer(): Flow[Received, (Event, Long), NotUsed]
Conveniently tail and decode observation type events.
Conveniently tail and decode observation type events. Yields the event and its offset.
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- object EventJsonProtocol extends DefaultJsonProtocol
A JSON codec for Event