broker/ru.sydis.broker.interfaces

Package-level declarations

Types

Link copied to clipboard
data class BrokerMsg<KC : Any, VC : Any>(val key: KC, val value: VC, val ts: Long = System.currentTimeMillis())

Дата класс, для передачи сообщений через брокер

Link copied to clipboard
interface ICheckProcessing
Link copied to clipboard
interface MessageBroker<K, V>
Link copied to clipboard
interface Serde<T>
Link copied to clipboard
typealias subscribeCallback<KC, VC> = (String, List<BrokerMsg<KC, VC>>) -> Unit

Алиас для коллбеков подписок