Enum HttpQueueSendResponse 

pub enum HttpQueueSendResponse {
    V3(HttpQueueSendResponse),
    V4(HttpQueueSendResponse),
}

Variants

V3(HttpQueueSendResponse)

V4(HttpQueueSendResponse)

Trait Implementations

impl Versioned for HttpQueueSendResponse

const LATEST: u16 = 4

The newest version, which Latest encodes.

const UPGRADES: &'static [Converter<Self>]

UPGRADES[i] converts version i + 1 to version i + 2.

const DOWNGRADES: &'static [Converter<Self>]

DOWNGRADES[i] converts version LATEST - i to version LATEST - i - 1.

type Latest = HttpQueueSendResponse

fn wrap_latest(latest: Self::Latest) -> Self

fn unwrap_latest(self) -> Result<Self::Latest>

fn decode_version(version: u16, payload: Bytes) -> Result<Self, DecodeError>

Decodes a body written at version, which is never LATEST.

fn encode_version<S: Sink>( &self, version: u16, out: &mut S, ) -> Result<(), EncodeError>

Encodes the variant this value holds. version is the version being written.

fn decode_body(body: Bytes, version: u16) -> Result<Self::Latest, DecodeError>

Decodes a body without a header, written at version.

fn open_body( body: Bytes, version: u16, ) -> Result<View<<Self::Latest as Message>::Wire>, DecodeError>

where Self::Latest: Message,

Views a body without a header, written at version. Latest-version bodies are viewed in place; older bodies are converted and re-encoded first.

fn encode_body<S>( value: &Self::Latest, version: u16, out: &mut S, ) -> Result<(), EncodeError>

where S: Sink,

Encodes value at version without a header, converting it down if needed.

fn decode(bytes: Bytes) -> Result<Self::Latest, DecodeError>

Decodes a payload with a version header to the latest version.

fn open( bytes: Bytes, ) -> Result<View<<Self::Latest as Message>::Wire>, DecodeError>

where Self::Latest: Message,

Views a payload with a version header. A latest-version payload is viewed without copying.

fn seal<S>( value: &Self::Latest, version: u16, out: &mut S, ) -> Result<(), EncodeError>

where S: Sink,

Writes the version header and value encoded at version into out.

fn sealed_len(value: &Self::Latest) -> usize

The exact number of bytes seal writes for value at the latest version: the header plus the body. An older version converts the value first, so its length is only known once it is encoded.

fn seal_to_vec( value: &Self::Latest, version: u16, ) -> Result<Vec<u8>, EncodeError>

seal into a new Vec.

fn seal_to_bytes( value: &Self::Latest, version: u16, ) -> Result<Bytes, EncodeError>

seal into a new Bytes, allocated once at the exact length for the latest version.

fn seal_to_slice( value: &Self::Latest, version: u16, out: &mut [u8], ) -> Result<usize, EncodeError>

Seals value at version into the front of out and returns the number of bytes written. Fails with EncodeError::BufferTooSmall instead of panicking when out is too short, and then writes nothing.

fn deserialize_with_embedded_version( payload: &[u8], ) -> Result<Self::Latest, Error>

decode from a slice, under vbare 0.1’s name. Copies payload once; callers that hold Bytes should call decode instead.

fn serialize_with_embedded_version( value: &Self::Latest, version: u16, ) -> Result<Vec<u8>, Error>

seal_to_vec under vbare 0.1’s name. Takes the value by reference, so callers no longer clone it into wrap_latest.

fn deserialize(payload: &[u8], version: u16) -> Result<Self::Latest, Error>

decode_body from a slice, under vbare 0.1’s name. Copies payload once.

fn serialize(value: &Self::Latest, version: u16) -> Result<Vec<u8>, Error>

encode_body into a new Vec, under vbare 0.1’s name.