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) {