Functions — github.com/TimelyDataflow/diagnostics

CodeHub MCPcopy Create free account

hub / github.com/TimelyDataflow/diagnostics / functions

Functions11 in github.com/TimelyDataflow/diagnostics

⨍ Functions 11 ◇ Types & classes 5

↓ 2 callersMethodread

(&mut self, buf: &mut [u8])

connect/src/receive/connect.rs:40

↓ 2 callersMethodreplay_with_shutdown_into

(self, scope: &mut S, is_running: Arc<AtomicBool>)

connect/src/receive/replaywithshutdown.rs:45

↓ 1 callersFunctionexpect_write

(e: Result<(), std::io::Error>)

tdiag/src/commands/graph.rs:217

↓ 1 callersFunctionlisten_and_profile

Prints aggregate time spent in each scope/operator. 1. Listens to incoming connections from a timely-dataflow program with logging enabled; 2. runs a

tdiag/src/commands/profile.rs:26

↓ 1 callersFunctionlisten_and_render

Creates an html file that renders a timely dataflow graph. 1. Listens to incoming connection from a timely-dataflow program with logging enabled; 2.

tdiag/src/commands/graph.rs:28

↓ 1 callersFunctionopen_sockets

Listens on 127.0.0.1:8000 and opens `source_peers` sockets from the computations we're examining (one socket for every worker on the examined computat

connect/src/receive/connect.rs:18

↓ 1 callersFunctionrun

tdiag/src/main.rs:8

(error: std::io::Error)

tdiag/src/lib.rs:11

(e: std::io::Error)

connect/src/lib.rs:11

tdiag/src/main.rs:93

Functionmake_readers

Construct EventReaders that read data from sockets or file and can stream it into timely dataflow.

connect/src/receive/connect.rs:57