datasourcex-reactive-api/com.caplin.integration.datasourcex.reactive.api

Package-level declarations

Types

sealed class ActiveConfig

ActiveContainerConfig

sealed class ActiveContainerConfig

interface BindContext

annotation class BindMarker

BroadcastConfig

sealed class BroadcastConfig

class BroadcastEvent<out T : Any>(val path: String, val value: T)

sealed class ChannelConfig

class ChannelRequest<R>(val pathParameters: List<String>, val pathVariables: LinkedHashMap<String, String>, val queryParameters: SortedMap<String, String>, val receive: R) : Subject

A decomposed subject request passed to a supplier for a channel bind.

ChannelRequestSupplier

fun interface ChannelRequestSupplier<R, T>

ChannelSupplier

fun interface ChannelSupplier<R, T>

enum ChannelType : Enum<ChannelType>

fun interface ConfigBlock<T : Any>

sealed interface ContainerEvent<out T : Any>

DataSourceSettings

object DataSourceSettings

Process-wide settings for the reactive DataSource bindings.

enum InsertAt : Enum<InsertAt>

fun interface PathSupplier<T>

PathVariablesChannelSupplier

fun interface ~~PathVariablesChannelSupplier~~<R, T>

PathVariablesSupplier

fun interface ~~PathVariablesSupplier~~<T>

enum RecordType : Enum<RecordType>

class Request(val pathParameters: List<String>, val pathVariables: LinkedHashMap<String, String>, val queryParameters: SortedMap<String, String>) : Subject

A decomposed subject request passed to a supplier for an active or container bind.

RequestSupplier

fun interface RequestSupplier<T>

class ServiceConfig(val name: String)