QuicSessionHandler

class QuicSessionHandler(router: Router, sessionManager: SessionManager, tokenService: TokenService, transferTokenValidator: TransferTokenValidator, rateLimitService: RateLimitService, certs: CertificateUtil.CertPair, playerManager: PlayerManagerImpl, eventBus: EventBus, transferService: PlayerTransferService, certificatePolicyStore: BackendCertificatePolicyStore, backendAvailabilityTracker: BackendAvailabilityTracker, defaultBackendId: String, backendIds: List<String>, referralConfig: ReferralConfig, protocolLimits: ProtocolLimitsConfig, metrics: ProxyMetricsRegistry? = null) : ChannelInboundHandlerAdapter

Handles a single QUIC session, intercepting the connect handshake and bridging streams.

Constructors

constructor(router: Router, sessionManager: SessionManager, tokenService: TokenService, transferTokenValidator: TransferTokenValidator, rateLimitService: RateLimitService, certs: CertificateUtil.CertPair, playerManager: PlayerManagerImpl, eventBus: EventBus, transferService: PlayerTransferService, certificatePolicyStore: BackendCertificatePolicyStore, backendAvailabilityTracker: BackendAvailabilityTracker, defaultBackendId: String, backendIds: List<String>, referralConfig: ReferralConfig, protocolLimits: ProtocolLimitsConfig, metrics: ProxyMetricsRegistry? = null)

open override fun channelActive(ctx: ChannelHandlerContext)

open override fun channelInactive(ctx: ChannelHandlerContext)

open fun channelRead(ctx: ChannelHandlerContext?, msg: Any?)

open fun channelReadComplete(ctx: ChannelHandlerContext?)

open fun channelRegistered(ctx: ChannelHandlerContext?)

open fun channelUnregistered(ctx: ChannelHandlerContext?)

open fun channelWritabilityChanged(ctx: ChannelHandlerContext?)

open fun exceptionCaught(ctx: ChannelHandlerContext?, cause: Throwable?)

fun handleIncomingStream(ch: QuicStreamChannel)

Handles a newly opened QUIC stream from the client.

open fun handlerAdded(ctx: ChannelHandlerContext?)

open fun handlerRemoved(ctx: ChannelHandlerContext?)

open fun userEventTriggered(ctx: ChannelHandlerContext?, evt: Any?)