Skip to main content

Module transport

Module transport 

Source
Expand description

Provider-neutral blocking and asynchronous transport contracts.

Structs§

AcknowledgedCustomEndpoint
Custom endpoint paired with an explicit operator acknowledgement.
AsyncResponseStaging
Non-committing response view supplied to an asynchronous transport.
CanonicalQuery
Validated RFC 3986-style query with %20 space encoding.
ContentType
Borrowed, validated HTTP content type.
CustomEndpointAcknowledgement
Explicit acknowledgement that a custom endpoint is a credential destination.
EndpointIdentity
Borrowed normalized identity of a credential-bound transport endpoint.
FormQuery
Explicit provider dialect that admits + for encoded spaces.
HeaderName
Borrowed, validated HTTP header name.
HeaderValue
Borrowed, validated request header value.
InformationalResponseTracker
Small state machine for bounded informational-response handling.
MediaType
Borrowed media-type essence used by response policies.
ProviderLinkQuery
Raw query state admitted only through a validated provider pagination link.
QueryPair
One encoded query pair, preserving missing versus empty values.
QueryPairs
Exact-order iterator over encoded query pairs.
RawResponsePolicy
Complete provider-neutral admission policy for one final HTTP response.
RegionEndpoint
Provider-derived endpoint paired with its canonical region identifier.
RequestHeader
One validated borrowed request header.
RequestHeaders
Validated ordered request-header block.
RequestPath
Validated canonical origin-form path.
RequestTarget
Validated complete origin-form HTTP request target.
ResponseAttempt
Cleanup-owning transaction around one response write attempt.
ResponseBuffer
Cleanup-owning admission guard around one sealed ResponseWriter.
ResponseCompletion
Completion metadata returned by an asynchronous transport.
ResponseContentType
Borrowed, validated content type captured in stable response-header storage.
ResponseDecodeWorkspace
Complete fixed response workspace cleared with its checked guard.
ResponseHeader
Borrowed view into one retained response header.
ResponseHeaders
Caller-storage-backed fixed-capacity response-header metadata.
ResponseMetadata
Non-sensitive interpreted response metadata captured by a transport.
ResponseWriter
Exclusive transport access to one admitted caller-owned response prefix.
RetainedResponseMetadata
Request identifier deliberately retained beyond a checked response guard.
StatusCode
Valid HTTP response status code.
StreamAttempt
SDK-owned accounting attempt over caller-owned outcome state.
StreamCompletion
Successful accounting completion.
StreamLimits
Hard byte, chunk, observation, and zero-progress limits.
StreamOutcome
Attempt outcome stored in caller-owned state.
StreamPolicy
Complete stream behavior fixed before the first observation.
StreamProgress
Public nonsensitive streaming counters.
StreamSourceId
Exact source version supplied by the source owner.
TransportFailure
Payload-redacting transport failure with an explicit delivery phase.
TransportRequest
Provider-neutral request passed to a blocking transport.
TransportResponse
Borrowed view committed from an admitted writer.

Enums§

AsyncExecutionError
Failure while SDK-owned asynchronous response staging is driven to completion.
ContentTypeError
Content-type validation error.
DeliveryPhase
Furthest delivery point known for one failed HTTP attempt.
EndpointIdentityError
Endpoint identity validation error.
EndpointPolicy
Allocation-free provider-owned endpoint admission policy.
EndpointPolicyError
Endpoint trust policy validation or matching error.
EndpointPolicyKind
Trust provenance represented by an EndpointPolicy.
EndpointScheme
Network scheme in an immutable endpoint identity.
HeaderError
Bounded HTTP header validation or capacity failure.
HeaderSensitivity
Whether a header value must be treated as sensitive.
InformationalResponseError
Informational or final-response selection failure.
RawResponsePolicyError
Invalid raw response-wire policy.
RequestPathError
Canonical path validation error.
RequestQuery
Explicit request query state.
RequestTargetError
Request-target validation or assembly error.
ResponseMediaPolicy
Response media-type requirement for one status class.
ResponseWriterError
Response-writer state violation.
RetainedMetadataError
Request-identifier admission or transfer failure.
StreamExecutionError
One bounded stream execution failure.
StreamFraming
Wire framing responsibility.
StreamKind
Streaming operation shape.
StreamLimitsError
Invalid hard streaming limits.
StreamPartialState
Visibility and cleanup requirement after incomplete transfer.
StreamPolicyError
Incoherent stream policy.
StreamProgressError
Stream accounting or lifecycle failure.
StreamRead
One source observation.
StreamReplayError
Streaming replay rejection.
StreamReplayability
Whether a streaming body can be reproduced for another attempt.
StreamSinkMode
Visibility of accepted bytes before successful completion.
StreamSourceIdError
Invalid source identity.
StreamState
Final lifecycle state recorded even when an asynchronous attempt is dropped.
StructuredQueryError
Structured query validation error.
TrailerPolicy
Response trailer handling.

Constants§

ASYNC_CANCELLATION_DELIVERY_PHASE
Conservative delivery classification after an asynchronous future is cancelled by being dropped.
MAX_CONSECUTIVE_ZERO_PROGRESS
Global ceiling for consecutive observations that transfer no bytes.
MAX_CONTENT_TYPE_BYTES
Maximum content-type header value length admitted by the core contract.
MAX_ENDPOINT_BASE_PATH_BYTES
Maximum normalized endpoint base-path length admitted by the core contract.
MAX_ENDPOINT_HOST_BYTES
Maximum normalized endpoint host length admitted by the core contract.
MAX_ENDPOINT_REGION_BYTES
Maximum provider region identifier length.
MAX_HEADER_NAME_BYTES
Maximum header-name length admitted by the transport contract.
MAX_HEADER_VALUE_BYTES
Maximum single header-value length admitted by the transport contract.
MAX_INFORMATIONAL_RESPONSES
Maximum informational response heads accepted before a final response.
MAX_OFFICIAL_ENDPOINTS
Maximum identities in one finite official endpoint set.
MAX_RAW_RESPONSE_BODY_BYTES
Maximum per-class body limit represented by the raw buffered contract.
MAX_REQUEST_HEADERS
Maximum number of request headers.
MAX_REQUEST_HEADER_BYTES
Maximum encoded request-header bytes, excluding the final empty line.
MAX_REQUEST_ID_BYTES
Maximum opaque provider request-identifier length.
MAX_REQUEST_TARGET_BYTES
Maximum origin-form request-target length admitted by the core contract.
MAX_RESPONSE_CHUNKS
Maximum chunks admitted by one buffered raw response.
MAX_RESPONSE_HEADERS
Maximum number of retained response headers.
MAX_RESPONSE_HEADER_BYTES
Maximum encoded response-header bytes, excluding the final empty line.
MAX_STREAM_BYTES
Global ceiling for one stream’s actual transferred bytes.
MAX_STREAM_CHUNKS
Global ceiling for chunks observed in one stream attempt.
MAX_STREAM_CHUNK_BYTES
Global ceiling for one source chunk.
MAX_STREAM_OBSERVATIONS
Global ceiling for source, sink, and waiting observations in one attempt.
MAX_STREAM_SOURCE_ID_BYTES
Maximum exact source-version identity length.
RESPONSE_CURSOR_SCRATCH_BYTES
Cursor staging bytes available to checked pagination decoders.
RESPONSE_DECODER_SCRATCH_BYTES
Decoder scratch bytes available to checked provider decoders.
RESPONSE_PROVIDER_LINK_SCRATCH_BYTES
Provider-link staging bytes available to checked pagination decoders.

Traits§

AsyncRawHttpExecutor
Runtime-neutral Send asynchronous raw HTTP execution.
AsyncStreamSink
Cross-thread asynchronous sink.
AsyncStreamSource
Cross-thread asynchronous source.
AsyncTransport
Cross-thread asynchronous transport over caller-owned buffers.
BlockingRawHttpExecutor
Blocking execution of one already validated raw HTTP request.
BlockingStreamSink
Blocking sink with explicit commit and infallible abort cleanup.
BlockingStreamSource
Blocking source that initializes caller-owned scratch storage.
BlockingTransport
Synchronous transport over caller-owned request and response buffers.
BoundTransport
Transport whose credentials are permanently bound to one endpoint.
LocalAsyncRawHttpExecutor
Runtime-neutral raw HTTP execution for !Send local futures.
LocalAsyncStreamSink
Local asynchronous sink whose futures may be !Send.
LocalAsyncStreamSource
Local asynchronous source whose future may be !Send.
LocalAsyncTransport
Local asynchronous transport for !Send futures and executors.
ResponseStorageSanitizer
Optional additive cleanup hook for caller-owned response storage.

Functions§

drive_async
Drives one cross-thread async attempt and commits only after Ready(Ok).
drive_async_raw
Drives one raw cross-thread async attempt and commits after Ready(Ok).
drive_async_stream
Drives one cross-thread asynchronous transfer without owning an executor.
drive_blocking_stream
Drives one finite blocking transfer with caller-owned scratch storage.
drive_local
Drives one local transport attempt and commits only after Ready(Ok).
drive_local_raw
Drives one raw local attempt and commits only after Ready(Ok).
drive_local_stream
Drives one local asynchronous transfer without owning an executor.
validate_stream_replay
Validates that a later attempt uses the same explicit replayable source.