Struct LogLine 

pub struct LogLine {
    pub stream: LogStreamKind,
    pub timestamp: Option<DateTime<Utc>>,
    pub data: Option<String>,
    pub data_b64: Option<String>,
}

One framed log record on the canonical NDJSON wire.

Exactly one of data / data_b64 is populated for records produced by from_bytes.

Fields

stream: LogStreamKind

Which stream this record came from.

timestamp: Option<DateTime<Utc>>

Optional RFC3339 timestamp. Omitted from the wire when None.

data: Option<String>

UTF-8 payload, present when the raw bytes were valid UTF-8.

data_b64: Option<String>

STANDARD-base64 payload, present when the raw bytes were not valid UTF-8.

Implementations

impl LogLine

pub fn from_bytes( stream: LogStreamKind, timestamp: Option<DateTime<Utc>>, bytes: &[u8], ) -> Self

Build a LogLine from raw payload bytes, choosing data (valid UTF-8) vs data_b64 (STANDARD base64) exactly like the existing zlayer-api ndjson_line_for_chunk.

pub fn into_payload_bytes(&self) -> Vec<u8>

Recover the decoded payload bytes.

Returns the UTF-8 bytes of data when present; otherwise the base64-decoded bytes of data_b64 (an empty Vec on decode error); otherwise an empty Vec.

pub fn to_json_bytes(&self) -> Vec<u8>

Serialize to the canonical JSON object bytes (no trailing newline).

Field presence matches the existing api shape: stream always, plus timestamp and exactly one of data/data_b64 when populated.

pub fn to_ndjson_line(&self) -> Vec<u8>

Serialize to a single NDJSON line: to_json_bytes followed by a trailing \n.

pub fn to_sse_frame(&self) -> Vec<u8>

Serialize to a Server-Sent Events data: frame: data: <json>\n\n. Used by the upcoming format=sse log mode.

pub fn parse_ndjson_line(line: &[u8]) -> Option<LogLine>

Parse a single NDJSON line back into a LogLine.

A trailing \n/\r is trimmed before parsing. Returns None on a parse failure or on a line that is empty/whitespace-only.

pub fn to_docker_frame(&self) -> Result<Vec<u8>, DockerFrameTooLarge>

Encode this record as a Docker multiplexed-stream frame using its stream and decoded payload bytes. See encode_docker_frame.

Errors

Returns DockerFrameTooLarge if the decoded payload exceeds the Docker frame u32 length limit.

Trait Implementations

impl Clone for LogLine

fn clone(&self) -> LogLine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LogLine

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LogLine

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for LogLine

impl PartialEq for LogLine

fn eq(&self, other: &LogLine) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for LogLine

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for LogLine