taskbridge-core/io.github.nikkiw.taskbridge.transport/TaskBridgeStreamTransportDeps

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.

Constructors

TaskBridgeStreamTransportDeps

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

Properties

failureClassifier

val failureClassifier: TaskBridgeFailureClassifier

Logic to classify errors as retryable or fatal.

pollEventsClient

val pollEventsClient: TaskBridgePollEventsClient<Ctx>

Client for long-polling.

val retryGate: TransportRetryGate

Gate for suspending retry attempts.

val retryPolicy: TaskBridgeRetryPolicy

Policy for retry backoff.

val routeResolver: TaskBridgeRouteResolver<Ctx>

Resolver for API routes.

sseSessionFactory

val sseSessionFactory: SseSessionFactory<Ctx>

Factory for SSE sessions.

webSocketFactory

val webSocketFactory: WebSocketSessionFactory<Ctx>

Factory for WebSocket sessions.