Struct Frame 

pub struct Frame {
    pub header: LwpHeader,
    pub payload: Option<Bytes>,
    pub frame_type: FrameType,
}

Fields

header: LwpHeader

payload: Option<Bytes>

frame_type: FrameType

Implementations

impl Frame

pub fn new_ingest( batch_id: u64, timestamp_ns: u64, record_count: u32, payload: Bytes, ) -> Self

pub fn new_ingest_with_topic( batch_id: u64, timestamp_ns: u64, record_count: u32, payload: Bytes, topic_id: u32, ) -> Self

pub fn new_ack(batch_id: u64) -> Self

pub fn new_keepalive() -> Self

pub fn new_backpressure() -> Self

pub fn new_control(command: ControlCommand, payload: Option<Bytes>) -> Self

pub fn new_create_topic(topic_name: &str) -> Self

pub fn new_list_topics() -> Self

pub fn new_get_topic(topic_id: u32) -> Self

pub fn new_delete_topic(topic_id: u32) -> Self

pub fn new_set_retention( topic_id: u32, max_age_secs: u64, max_bytes: u64, ) -> Self

Create a set retention policy request frame Payload format: topic_id(4) + max_age_secs(8) + max_bytes(8)

pub fn new_create_topic_with_retention( topic_name: &str, max_age_secs: u64, max_bytes: u64, ) -> Self

Create a topic with retention configuration Payload format: name_len(2) + name(var) + max_age_secs(8) + max_bytes(8)

pub fn new_fetch(topic_id: u32, start_offset: u64, max_bytes: u32) -> Self

Create a fetch request frame Payload format: topic_id(4) + start_offset(8) + max_bytes(4)

pub fn new_fetch_response(payload: Bytes) -> Self

pub fn new_catching_up(current_max_offset: u64) -> Self

Create a catching-up response frame indicating the server has not yet replicated to the requested offset. Payload contains the current max offset (8 bytes LE u64) so the client knows the server’s progress.

pub fn new_get_cluster_status() -> Self

Create a get cluster status request frame

pub fn new_cluster_status_response(payload: Bytes) -> Self

Create a cluster status response frame

pub fn new_authenticate(token: &str) -> Self

Create an authenticate request frame Payload format: token (UTF-8 string bytes)

pub fn new_authenticate_response(success: bool, message: Option<&str>) -> Self

Create an authenticate response frame Payload format: success(1) + optional message

pub fn new_subscribe( topic_id: u32, start_offset: u64, max_batch_bytes: u32, consumer_id: u64, ) -> Self

Create a subscribe request frame Payload format: topic_id(4) + start_offset(8) + max_batch_bytes(4) + consumer_id(8)

pub fn new_unsubscribe(topic_id: u32, consumer_id: u64) -> Self

Create an unsubscribe request frame Payload format: topic_id(4) + consumer_id(8)

pub fn new_commit_offset(topic_id: u32, consumer_id: u64, offset: u64) -> Self

Create a commit offset request frame Payload format: topic_id(4) + consumer_id(8) + offset(8)

pub fn new_subscribe_ack(consumer_id: u64, start_offset: u64) -> Self

Create a subscribe acknowledgment frame Payload format: consumer_id(8) + start_offset(8)

pub fn new_commit_ack(consumer_id: u64, committed_offset: u64) -> Self

Create a commit offset acknowledgment frame Payload format: consumer_id(8) + committed_offset(8)

pub fn new_topic_response(payload: Bytes) -> Self

pub fn new_error_response(message: &str) -> Self

pub fn batch_id(&self) -> u64

pub fn payload_length(&self) -> u32

pub fn record_count(&self) -> u32

pub fn topic_id(&self) -> u32