Struct Call 

pub struct Call {
    pub method: &'static str,
    pub path: String,
    pub query: Vec<(String, String)>,
    pub body: Vec<u8>,
    pub headers: Vec<(String, String)>,
    pub content_type: Option<String>,
    pub request_id: Option<String>,
    pub traceparent: Option<String>,
    pub timeout: Option<Duration>,
    pub retry_gateway: bool,
    pub recover: Vec<(u16, &'static str)>,
}

A call to the API, before it becomes HTTP.

Fields

method: &'static str

path: String

Path with the segments already encoded (/topics/orders).

query: Vec<(String, String)>

body: Vec<u8>

headers: Vec<(String, String)>

Only applies with a body; default application/json. Extra headers (an Accept of its own replaces the default application/json).

content_type: Option<String>

request_id: Option<String>

traceparent: Option<String>

timeout: Option<Duration>

Overrides the total time of the call (consume uses waitTime + 10 s).

retry_gateway: bool

Retries 502 and 504: only publishing to a FIFO queue, where the primary deduplicates.

recover: Vec<(u16, &'static str)>

After a 503, these responses count as success (the operation had already been applied): creating a topic (409 topic.already-exists) and deleting (404).

Implementations

impl Call

pub fn new(method: &'static str, path: impl Into<String>) -> Call

pub fn query(self, key: &str, value: impl ToString) -> Call

pub fn json_body(self, body: String) -> Call

Trait Implementations

impl Clone for Call

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Call

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

Formats the value using the given formatter.