Module service 

Structs

AwsChunkedDecoder

Incremental decoder for the aws-chunked content-encoding that modern AWS S3 clients (aws-cli, boto3 >= 1.36, aws-crt) apply by default to PutObject / UploadPart bodies when they send x-amz-content-sha256: STREAMING-AWS4-HMAC-SHA256-PAYLOAD (or STREAMING-UNSIGNED-PAYLOAD-TRAILER).

AwsRequest

A parsed AWS request.

AwsResponse

A response from a service handler.

MalformedChunk

A malformed aws-chunked chunk-size line (non-hex length).

SpooledBody

Outcome of spooling a streaming request body to disk: the path of the freshly created tempfile, the total byte count, and the MD5 hash of the bytes (lowercase hex, the form S3 uses for ETag).

Enums

AwsServiceError

Error returned by service handlers.

ResponseBody

A response body. Most handlers return ResponseBody::Bytes built from an in-memory Bytes buffer; the File variant exists so large disk-backed objects can be streamed straight from the filesystem to the HTTP body without being materialized into RAM. The file handle is opened by the service handler while it still holds the per-bucket read guard, so the reader sees a consistent inode even if a concurrent PUT/DELETE renames or unlinks the path before dispatch streams the body.

Traits

AwsService

Trait that every AWS service implements.

Functions

drain_request_stream

Drain a streaming request body into a single Bytes buffer with no upper bound. Used by handlers that legitimately need the whole payload in memory (small JSON-shaped requests that happened to land on a streaming route, e.g. ECR mount PUT with no body). Heavy uploads (S3 PutObject / UploadPart, ECR blob PATCH/PUT) take the streaming spool path via spool_request_stream instead. The dispatch-level cap (FAKECLOUD_MAX_REQUEST_BODY_BYTES) does not apply to streaming routes; this helper exists so a service handler that knows the payload is small can buffer without dragging in axum itself.

is_aws_chunked

Whether a request body carries the aws-chunked content-encoding (so the spool path must decode the framing). True when Content-Encoding lists aws-chunked, or x-amz-content-sha256 is a STREAMING-… marker — both of which default modern S3 clients (aws-cli, boto3 >= 1.36, aws-crt) set.

spool_request_stream

Stream a request body to a tempfile on disk while computing its MD5 and length on the fly. The body is never materialized into a single Bytes buffer; chunks flow from hyper -> Tokio file in constant memory. A 1 GiB PutObject moves through this function with peak resident memory bounded by hyper’s per-frame buffer.

strip_aws_chunked_encoding

Strip the aws-chunked token from a client Content-Encoding so the stored object metadata reflects what AWS keeps (it consumes aws-chunked as a transfer detail; any remaining real encoding such as gzip is preserved). Returns None when nothing meaningful remains.

Type Aliases

RequestBodyStream

Streaming request body kept alongside the buffered body: Bytes. Set by dispatch only for routes that opt into streaming (S3 PutObject / UploadPart, ECR OCI blob upload PATCH/PUT). Service handlers call AwsRequest::take_body_stream to consume the raw stream without buffering the entire payload into memory; non-streaming services keep using req.body (which is empty Bytes for streaming routes).