Module pipeline

Structs

• Pipeline
  An eventual, at-least-once(-ish) event pipeline, backed by a write-ahead log on the local disk.

Enums

• PipelineError

Functions

• append_event 🔒
  Appends the event to the active session_file.
• flush_events 🔒
  Sends all events currently buffered in the session_file down the sink.
• flush_pending_events 🔒
• realtime_pipeline 🔒
• try_send_event 🔒