Function mz_compute::logging::timely::construct
source ยท pub(super) fn construct<A: Allocate>(
worker: &mut Worker<A>,
config: &LoggingConfig,
event_queue: EventQueue<Vec<(Duration, WorkerIdentifier, TimelyEvent)>>,
shared_state: Rc<RefCell<SharedLoggingState>>,
) -> BTreeMap<LogVariant, LogCollection>
Expand description
Constructs the logging dataflow for timely logs.
Params
worker
: The Timely worker hosting the log analysis dataflow.config
: Logging configurationevent_queue
: The source to read log events from.