Struct InMemoryLogSink 

pub struct InMemoryLogSink { /* private fields */ }

Implementations

impl InMemoryLogSink

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryLogSink

fn default() -> Self

Returns the “default value” for a type.

impl LogSink for InMemoryLogSink

async fn append(&self, chunk: LogChunk) -> Result<(), LogError>

Append a log chunk from a worker.

async fn get_all( &self, workflow_id: &str, job_id: &str, ) -> Result<Vec<LogChunk>, LogError>

Get all log chunks for a job (for catch-up on SSE connect).

fn subscribe(&self, workflow_id: &str, job_id: &str) -> Receiver<LogChunk>

Subscribe to live log chunks for a specific job.