pub struct LwpHeader {
pub magic: [u8; 4],
pub version: u8,
pub flags: u8,
pub reserved: [u8; 2],
pub header_crc: u32,
pub ingest_header: IngestHeader,
}Fields§
§magic: [u8; 4]§version: u8§flags: u8§reserved: [u8; 2]§header_crc: u32§ingest_header: IngestHeaderImplementations§
Source§impl LwpHeader
impl LwpHeader
pub const SIZE: usize = 44
pub fn new(flags: u8, ingest_header: IngestHeader) -> Self
pub fn parse(buf: &[u8]) -> Result<Self>
pub fn encode(&self) -> [u8; 44]
pub fn has_flag(&self, flag: LwpFlags) -> bool
pub fn is_keepalive(&self) -> bool
pub fn is_batch_mode(&self) -> bool
pub fn is_compressed(&self) -> bool
pub fn is_control(&self) -> bool
Trait Implementations§
Auto Trait Implementations§
impl Freeze for LwpHeader
impl RefUnwindSafe for LwpHeader
impl Send for LwpHeader
impl Sync for LwpHeader
impl Unpin for LwpHeader
impl UnwindSafe for LwpHeader
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request