AgentConnectionContext

internal class AgentConnectionContext(val backlogCapacity: Int = 128)(source)

Bidirectional channel pair for a single agent-to-proxy connection.

Holds two coroutine channels: one for inbound scrape request actions (bounded by backlogCapacity) and one for outbound scrape results (unbounded). Manages the connection's disconnected state and provides a close method that drains pending requests and closes both channels so waiting coroutines are notified.

Parameters

backlogCapacity

maximum number of buffered scrape request actions

See also

Constructors

Link copied to clipboard
constructor(backlogCapacity: Int = 128)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun close(): Int
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun sendScrapeRequestAction(scrapeRequestAction: ScrapeRequestAction)
Link copied to clipboard
fun sendScrapeResults(scrapeResults: ScrapeResults)