TaskBridgeStreamTransportConfig
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.
Constructors
Link copied to clipboard
constructor(fallbackStrategy: FallbackStrategy = FallbackStrategy.PROGRESSIVE_STICKY, wsMaxAttempts: Int = 3, sseMaxAttempts: Int = 3, pollWaitTimeoutMs: Int = DEFAULT_POLL_WAIT_TIMEOUT_MS, pollMaxEvents: Int = DEFAULT_POLL_MAX_EVENTS, pollEmptyBackoffMs: Long = DEFAULT_POLL_EMPTY_BACKOFF_MS, transportOpenTimeoutMs: Long = DEFAULT_TRANSPORT_OPEN_TIMEOUT_MS, livenessTimeoutMs: Long = DEFAULT_LIVENESS_TIMEOUT_MS, wsIncomingChannelCapacity: Int = DEFAULT_WS_INCOMING_CHANNEL_CAPACITY, sseIncomingChannelCapacity: Int = DEFAULT_SSE_INCOMING_CHANNEL_CAPACITY, maxMalformedPayloadsBeforeFailure: Int = DEFAULT_MAX_MALFORMED_PAYLOADS)
Properties
Link copied to clipboard
Strategy for falling back between WebSocket, SSE, and Polling.
Link copied to clipboard
Max time of inactivity on an open connection before assuming it's dead.
Link copied to clipboard
Max allowed invalid payloads in a session before failing.
Link copied to clipboard
Delay after an empty poll batch to avoid tight loops.
Link copied to clipboard
Maximum number of events to fetch in a single poll request.
Link copied to clipboard
Time in ms for the server to wait for new events during long-polling.
Link copied to clipboard
Buffer capacity for incoming SSE events.
Link copied to clipboard
Maximum connection attempts for SSE before falling back.
Link copied to clipboard
Max time to wait for a transport (WS/SSE) to become open.
Link copied to clipboard
Buffer capacity for incoming WebSocket messages.
Link copied to clipboard
Maximum connection attempts for WebSocket before falling back.