Struct StreamingState 

pub struct StreamingState {
    region: String,
    _access_key: String,
    _secret_key: String,
    ts: DateTime<Utc>,
    prior_sig: String,
    signing_key: Vec<u8>,
}

Maximum chunk payload we read from the client before signing. (4 MiB is what the Java/AWS SDKs use, but any size works.) Runtime state for an in-progress streaming upload.

Stored in MyCtx::stream_state and consumed by MyProxy::request_body_filter to sign each body chunk as it flows through the proxy.

Fields

region: String

_access_key: String

_secret_key: String

ts: DateTime<Utc>

prior_sig: String

signing_key: Vec<u8>

Implementations

impl StreamingState

pub fn new( region: String, access_key: String, secret_key: String, ts: DateTime<Utc>, seed_signature: String, ) -> Self

Create a new StreamingState from the seed values produced by resign_streaming_request.

pub fn sign_chunk(&mut self, payload: &[u8]) -> Result<Bytes>

Sign a body chunk and return the framed AWS-chunked bytes.

pub fn final_chunk(&mut self) -> Result<Bytes>

Produce the terminal zero-length chunk that signals end-of-stream.

Trait Implementations

impl Debug for StreamingState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.