@spec config(atom(), any()) :: any()

Read config settings scoped for GSS client.

@spec dispatcher_hash(event()) :: {event(), partition()}

Divide request into to partitions :read and :write

@spec request(atom(), binary(), binary() | iodata(), headers(), Keyword.t()) ::
  {:ok, Finch.Response.t()} | {:error, Exception.t()}

Issues an HTTP request with the given method to the given URL using Finch.

This function is usually used indirectly by helper functions such as get/3, post/4, put/4, etc.

Arguments

• method: HTTP method as an atom (e.g., :get, :head, :post, :put, :delete, etc.).
• url: Target URL as a binary string.
• body: Request body as a binary() or iodata().
• headers: HTTP headers as a list of two-element tuples (e.g., [{"Accept", "application/json"}]).
• options: A keyword list of options.
  • :result_timeout – timeout (in milliseconds) for the underlying GenStage.call/3. This key is consumed by the library and is not forwarded to Finch. When omitted it falls back to the :result_timeout client config. May be an integer or :infinity.
  • :pool_timeout, :receive_timeout, :request_timeout – forwarded to Finch.request/3 (see the Finch documentation for their semantics). Any other keys are ignored by the request worker.

Returns

• On success, returns {:ok, %Finch.Response{}}.
• On failure, returns {:error, reason} where reason is an exception.

Examples

request(:post, "https://my.website.com", "{"foo": 3}", [{"Accept", "application/json"}])

@spec request_async(atom(), binary(), binary() | iodata(), headers(), Keyword.t()) ::
  Task.t()

Starts a task with request that must be awaited on.