Skip to content

SyncTransport

Class: warmhub.SyncTransport

Issues tRPC calls over an httpx.Client.

trpc_url(path: str)

Documentation is not yet available.

request(path: str, payload: object, *, timeout: httpx.Timeout | Unset = UNSET, headers: Mapping[str, str] | Unset = UNSET, extra_query: Mapping[str, str] | Unset = UNSET)

POST one tRPC call and return the decoded result.data.

assert_compatible(*, headers: Mapping[str, str] | Unset = UNSET, extra_query: Mapping[str, str] | Unset = UNSET)

Documentation is not yet available.

assert_write_compatible()

Documentation is not yet available.

request_json(method: str, path: str, body: object = None, *, timeout: httpx.Timeout | Unset = UNSET, headers: Mapping[str, str] | Unset = UNSET, extra_query: Mapping[str, str] | Unset = UNSET)

Issue one REST call and return its decoded JSON body.

See AsyncTransport.request_json.

request_health(*, timeout: httpx.Timeout | Unset = UNSET, headers: Mapping[str, str] | Unset = UNSET, extra_query: Mapping[str, str] | Unset = UNSET)

GET /health. See AsyncTransport.request_health.

send(plan: RequestPlan, *, timeout: httpx.Timeout | Unset = UNSET, headers: Mapping[str, str] | Unset = UNSET, stream: bool = False)

Mirrors fetchWithAuth: stamp auth + identity, retry once on 401.

See AsyncTransport.send for the stream=True contract.

close()

Close the pool if we opened it. An injected transport is left alone.

warn_if_leaked()

Documentation is not yet available.

api_url

Documentation is not yet available.

http

Documentation is not yet available.

owns_http

False when the caller injected the transport.

client_flags

Normalized client_flags, stamped on every request.

is_closed

Documentation is not yet available.