HTTP.HTTP2.Pool (http_fetch v0.14.0)

View Source

Bounded profile-aware HTTP/2 connection pool.

Summary

Types

key()
reservation()

Functions

cancel(pool, reservation)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

claim_connect(pool, key)

Claims the per-key connection slot for an out-of-band connector.

fail_connect(pool, key, reason)

Fails an out-of-band connection attempt and wakes queued reservations.

mark_draining(pool, key, owner)

Stops new reservations on an owner that received GOAWAY.

register(pool, key, owner, opts \\ [])
release(pool, key, reservation)
reserve(pool, key, opts \\ [])

Atomically reserves one stream slot for key.

start_link(opts \\ [])
stats(pool)
try_reserve(pool, key)

Reserves an available stream without queueing or starting a connection.

Types

key()

@type key() :: term()

reservation()

@type reservation() :: reference()

Functions

cancel(pool, reservation)

@spec cancel(pid(), reservation()) :: :ok | {:error, :unknown_reservation}

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

claim_connect(pool, key)

@spec claim_connect(pid(), key()) :: :start | :wait

Claims the per-key connection slot for an out-of-band connector.

fail_connect(pool, key, reason)

@spec fail_connect(pid(), key(), term()) :: :ok

Fails an out-of-band connection attempt and wakes queued reservations.

mark_draining(pool, key, owner)

@spec mark_draining(pid(), key(), pid()) :: :ok

Stops new reservations on an owner that received GOAWAY.

register(pool, key, owner, opts \\ [])

@spec register(pid(), key(), pid(), keyword()) :: :ok

release(pool, key, reservation)

@spec release(pid(), key(), reservation()) :: :ok

reserve(pool, key, opts \\ [])

@spec reserve(pid(), key(), keyword()) ::
  {:ok, pid(), reservation()} | {:queued, reservation()} | {:error, term()}

Atomically reserves one stream slot for key.

start_link(opts \\ [])

@spec start_link(keyword()) :: GenServer.on_start()

stats(pool)

@spec stats(pid()) :: map()

try_reserve(pool, key)

@spec try_reserve(pid(), key()) :: {:ok, pid(), reservation()} | :none

Reserves an available stream without queueing or starting a connection.