spi/me.ahoo.wow.spi.transport/TopicTransportOptions

TopicTransportOptions

object TopicTransportOptions

The settings every topic transport has, whatever its type (wow.<type>.*): how the node names and uses its topics, not how a client reaches its brokers. The host reads them for the node's topics; a transport's options add them to its own (TransportProvider.options), so no transport declares them again or forgets one.

Properties

val ALL: List<ProviderOption<*>>

Every setting a topic transport has.

val COMMAND_INTAKE: ProviderOption.Defaulted<Boolean>

Whether the node takes commands from its contexts' command topics.

val DDL: ProviderOption<Ddl>

How the transport manages the node's topics, over wow.ddl.

PARTITION_REFRESH

val PARTITION_REFRESH: ProviderOption.Defaulted<Duration>

How often the node reads the partitions of its topics again.

val TOPIC_PREFIX: ProviderOption.Defaulted<String>

A prefix of every topic name, for a cluster several services or environments share.

Functions

fun of(provider: TransportProvider): List<ProviderOption<*>>

The options of provider: these settings, then its own.