def get()

in app/agent/collector.scala [148:165]


  def get(collector: Collector[T]): Datum[T]

  def get(): Iterable[Datum[T]]

  def getTuples: Iterable[(Label, T)]

  def getLabels: Seq[Label]

  def size: Int

  def update(collector: Collector[T], previous: Datum[T]): Datum[T]

  def init(): Unit

  def shutdown(): Unit
}

case class SourceStatus(state: Label, error: Option[Label] = None) {