Crate ddshow_sink

Source

Structs§

BatchLogger
Logs events from a timely stream, including progress information and logging messages
EventWriter
A wrapper for a writer that serializes rkyv encoded types that are FFI compatible

Constants§

DIFFERENTIAL_ARRANGEMENT_LOGGER_NAME
The name of the timely log stream for differential arrangement events
DIFFERENTIAL_ARRANGEMENT_LOG_FILE
The file that all differential arrangement events will be stored in
TIMELY_LOGGER_NAME
The name of the timely log stream for timely events
TIMELY_LOG_FILE
The file that all timely events will be stored in
TIMELY_PROGRESS_LOGGER_NAME
The name of the timely log stream for timely progress events
TIMELY_PROGRESS_LOG_FILE
The file that all timely progress events will be stored in

Functions§

enable_differential_logging
Writes all differential dataflow event logs to the given writer
enable_timely_logging
Writes all timely event logs to the given writer
enable_timely_progress_logging
log_file_path
Constructs the path to a logging file for the given worker
save_differential_logs_to_disk
save_timely_logs_to_disk
save_timely_progress_to_disk

Type Aliases§

EventSerializer