Struct Encoder 

pub struct Encoder { /* private fields */ }

Writer for AMQP method arguments and property lists.

Implementations

impl Encoder

pub fn new() -> Self

pub fn u8(&mut self, v: u8)

pub fn u16(&mut self, v: u16)

pub fn u32(&mut self, v: u32)

pub fn u64(&mut self, v: u64)

pub fn short_string(&mut self, s: &str) -> Result<()>

shortstr: one length octet then that many bytes. Refuses anything longer than MAX_SHORT_STRING_LEN, leaving the buffer untouched.

This used to truncate at a UTF-8 char boundary, which is the encode_apn shape: a name shortened to fit is not an error the caller can see, it is a well-formed name for something else. shortstr carries queue names, exchange names, routing keys, consumer tags and every field-table key, so the cost is a queue declared under one name and bound under another — measured, not theorised: two table keys differing only past octet 255 collapsed into one entry and a value was lost.

Not reachable from the wire — Decoder::short_string reads a one-octet length and so cannot produce more than 255 bytes — which means the source is the model or NetGet itself, and both want to be told.

pub fn reply_text(&mut self, text: &str)

shortstr for the one AMQP field that carries free-form prose rather than an identifier: reply-text, in connection.close and channel.close.

Shortened at a UTF-8 char boundary instead of refused, and the distinction is deliberate. A shortened name is a believable different name; a shortened diagnostic is the same diagnostic with less of it, and nothing keys off it. The alternative — refusing — means not sending the close frame at all, so a peer that provoked a long error message would be left waiting on a connection NetGet has already given up on. Never reach for this for a queue, exchange, routing key, consumer tag or table key: those go through Encoder::short_string and are meant to fail loudly.

pub fn long_string(&mut self, bytes: &[u8])

pub fn bits(&mut self, bits: &[bool])

pub fn field_table(&mut self, value: &Value) -> Result<()>

Encode a JSON object as a field table. Non-object input encodes as an empty table.

Refuses a key longer than a shortstr and a table nested past MAX_FIELD_TABLE_DEPTH. Either refusal leaves this encoder’s buffer exactly as it was: a half-written table is worse than none, because the length prefix in front of it would then describe bytes that are not there and desynchronise every argument after it in the same method frame.

pub fn into_vec(self) -> Vec<u8>

pub fn as_slice(&self) -> &[u8]

Trait Implementations

impl Default for Encoder

fn default() -> Self

Returns the “default value” for a type.