Struct TailedEvent 

pub struct TailedEvent {
    pub node_id: u32,
    pub file_name: String,
    pub byte_offset: u64,
    pub event: LogEvent,
}

An event together with where it came from — everything the sink needs to build a stable _id.

Fields

node_id: u32

file_name: String

Bare log filename, e.g. ant-node.2026-08-19.log.

byte_offset: u64

Byte position of the event’s first line within that file.

event: LogEvent

Implementations

impl TailedEvent

pub fn document_id(&self, installation_id: &str) -> String

The document _id this event will be written under.

Deterministic in the four things that identify the event uniquely — which installation, which node, which file, which byte — so that replaying a batch after a transport failure lands on the same _id and is rejected as a duplicate instead of writing a second copy.

installation_id is not optional padding. Node id, filename and byte offset are all local values: every participant has a node 1, writing the same daily filename, whose first line starts at offset 0. Since all of them write into one shared daily index and a 409 counts as delivered, omitting the installation namespace would make the first event of each day from each node collide across the whole cohort, and every loser would be silently discarded.

Trait Implementations

impl Clone for TailedEvent

fn clone(&self) -> TailedEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TailedEvent

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

Formats the value using the given formatter.

impl Eq for TailedEvent

impl PartialEq for TailedEvent

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TailedEvent