data class TaskBridgeStreamTransportConfig(val fallbackStrategy: FallbackStrategy = FallbackStrategy.PROGRESSIVE_STICKY, val wsMaxAttempts: Int = 3, val sseMaxAttempts: Int = 3, val pollWaitTimeoutMs: Int = DEFAULT_POLL_WAIT_TIMEOUT_MS, val pollMaxEvents: Int = DEFAULT_POLL_MAX_EVENTS, val pollEmptyBackoffMs: Long = DEFAULT_POLL_EMPTY_BACKOFF_MS, val transportOpenTimeoutMs: Long = DEFAULT_TRANSPORT_OPEN_TIMEOUT_MS, val livenessTimeoutMs: Long = DEFAULT_LIVENESS_TIMEOUT_MS, val wsIncomingChannelCapacity: Int = DEFAULT_WS_INCOMING_CHANNEL_CAPACITY, val sseIncomingChannelCapacity: Int = DEFAULT_SSE_INCOMING_CHANNEL_CAPACITY, val maxMalformedPayloadsBeforeFailure: Int = DEFAULT_MAX_MALFORMED_PAYLOADS)

Configuration options for the event streaming transport.

TaskBridgeStreamTransportDeps

data class TaskBridgeStreamTransportDeps<Ctx>(val pollEventsClient: TaskBridgePollEventsClient<Ctx>, val webSocketFactory: WebSocketSessionFactory<Ctx>, val sseSessionFactory: SseSessionFactory<Ctx>, val routeResolver: TaskBridgeRouteResolver<Ctx>, val failureClassifier: TaskBridgeFailureClassifier, val retryPolicy: TaskBridgeRetryPolicy, val retryGate: TransportRetryGate = NoOpTransportRetryGate)

Network and resilience dependencies for TaskBridgeStreamTransport.

TaskBridgeStreamTransportOptions

data class TaskBridgeStreamTransportOptions<Ctx>(val streamConfig: TaskBridgeStreamTransportConfig = TaskBridgeStreamTransportConfig(), val eventListener: TaskBridgeTransportEventListener<Ctx>? = null, val json: Json = taskBridgeJson(), val dispatcher: CoroutineDispatcher = Dispatchers.IO)

Encapsulates runtime options for TaskBridgeStreamTransport.

TaskBridgeTransportBundle

data class TaskBridgeTransportBundle<Ctx>(val http: TaskBridgeHttpApi<Ctx>, val webSocketFactory: WebSocketSessionFactory<Ctx>, val sseSessionFactory: SseSessionFactory<Ctx>)

A bundle of transport components returned by TaskBridgeTransportFactory.

TaskBridgeTransportEventListener

interface TaskBridgeTransportEventListener<Ctx>

Listener for internal transport lifecycle events and diagnostics.

TaskBridgeTransportFactory

fun interface TaskBridgeTransportFactory<Ctx>

Factory for creating transport components.

TaskBridgeTransportFactoryConfig

data class TaskBridgeTransportFactoryConfig<Ctx>(val baseUrl: String, val authHeaderProvider: suspend (context: Ctx, forceRefresh: Boolean) -> String?? = null, val streamTransport: TaskBridgeStreamTransportConfig = TaskBridgeStreamTransportConfig(), val json: Json = taskBridgeJson())

Configuration passed to TaskBridgeTransportFactory.

TaskBridgeTransportSource

@JvmInline

value class TaskBridgeTransportSource(val value: Int)

Identifies the transport mechanism that delivered a task event.

TaskBridgeWebSocketListener

interface TaskBridgeWebSocketListener

Listener for WebSocket lifecycle and message events.