ptr.pet
forked from
microcosm.blue/Allegedly
Server tools to backfill, tail, mirror, and verify PLC logs
cleaner doc example code
bad-example.com
+3
-1
examples/poll.rs
+3
-1
examples/poll.rs
-9
src/poll.rs
-9
src/poll.rs
···
175
/// # async fn main() {
176
/// use allegedly::{ExportPage, Op, poll_upstream};
177
///
178
-
/// // set to `None` to replay from the beginning of the PLC history
179
/// let after = Some(chrono::Utc::now());
180
-
///
181
-
/// // the PLC server to poll for new ops
182
/// let upstream = "https://plc.wtf/export".parse().unwrap();
183
-
///
184
-
/// // self-rate-limit (plc.directory's limit interval is 600ms)
185
/// let throttle = std::time::Duration::from_millis(300);
186
///
187
-
/// // pages are sent out of the poller via a tokio mpsc channel
188
/// let (tx, mut rx) = tokio::sync::mpsc::channel(1);
189
-
///
190
-
/// // spawn a tokio task to run the poller
191
/// tokio::task::spawn(poll_upstream(after, upstream, throttle, tx));
192
///
193
-
/// // receive pages of plc ops from the poller
194
/// while let Some(ExportPage { ops }) = rx.recv().await {
195
/// println!("received {} plc ops", ops.len());
196
///
···
175
/// # async fn main() {
176
/// use allegedly::{ExportPage, Op, poll_upstream};
177
///
178
/// let after = Some(chrono::Utc::now());
179
/// let upstream = "https://plc.wtf/export".parse().unwrap();
180
/// let throttle = std::time::Duration::from_millis(300);
181
///
182
/// let (tx, mut rx) = tokio::sync::mpsc::channel(1);
183
/// tokio::task::spawn(poll_upstream(after, upstream, throttle, tx));
184
///
185
/// while let Some(ExportPage { ops }) = rx.recv().await {
186
/// println!("received {} plc ops", ops.len());
187
///