Struct samsa::prelude::protocol::FindCoordinatorRequest

pub struct FindCoordinatorRequest<'a> {
    pub header: HeaderRequest<'a>,
    pub key: &'a str,
}

The base Find Coordinator request object.

Example

let find_coordinator_request =
    protocol::FindCoordinatorRequest::new(CORRELATION_ID, CLIENT_ID, group_id);
conn.send_request(&find_coordinator_request).await?;

Fields

header: HeaderRequest<'a>

key: &'a str

The coordinator key.

Implementations

impl<'a> FindCoordinatorRequest<'a>

pub fn new(correlation_id: i32, client_id: &'a str, key: &'a str) -> Self

Trait Implementations

impl<'a> Debug for FindCoordinatorRequest<'a>

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

Formats the value using the given formatter.

impl<'a> ToByte for FindCoordinatorRequest<'a>

fn encode<T: BufMut>(&self, buffer: &mut T) -> Result<()>