Skip to main content

construct

Function construct 

Source
pub(super) fn construct(
    scope: Scope<'_, Timestamp>,
    config: &LoggingConfig,
    event_queue: EventQueue<Vec<(Duration, TimelyEvent)>>,
    shared_state: Rc<RefCell<SharedLoggingState>>,
) -> Return
Expand description

Constructs the logging dataflow fragment for timely logs.

Params

  • scope: The Timely scope hosting the log analysis dataflow.
  • config: Logging configuration
  • event_queue: The source to read log events from.