runtime/me.ahoo.wow.runtime.sink/PublishedSinks/Companion

Companion

object Companion

Properties

const val TRANSPORT_SINK: String

The processor name of the transport sink's subscriptions: wow.transport-sink.<aggregate>.

Functions

fun publishedOf(manifest: Manifest): Map<String, List<PublishedManifest>>

The streams manifest's contexts publish, by context; a context that publishes none is left out.

fun topics(manifest: Manifest, producer: TopicProducer, topicPrefix: String = "", processor: String = TRANSPORT_SINK): PublishedSinks

The transport sink: every stream manifest publishes, written to its topic (PublishedManifest.topic, after topicPrefix) through producer.