pub struct FirehoseConfig {
pub relay: String,
pub cursor: Option<i64>,
pub channel_capacity: usize,
}Expand description
Configuration for the firehose consumer.
This mirrors firehose-related fields that might live in atrg-core’s
config but exists in this crate so that atrg-firehose has zero
dependency on atrg-core.
Fields§
§relay: StringRelay WebSocket URL, e.g. "wss://bsky.network".
cursor: Option<i64>Cursor (sequence number) to resume from. None means start from the
relay’s current head.
channel_capacity: usizeBounded back-pressure channel capacity (default: 1024).
Trait Implementations§
Source§impl Clone for FirehoseConfig
impl Clone for FirehoseConfig
Source§fn clone(&self) -> FirehoseConfig
fn clone(&self) -> FirehoseConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for FirehoseConfig
impl Debug for FirehoseConfig
Auto Trait Implementations§
impl Freeze for FirehoseConfig
impl RefUnwindSafe for FirehoseConfig
impl Send for FirehoseConfig
impl Sync for FirehoseConfig
impl Unpin for FirehoseConfig
impl UnsafeUnpin for FirehoseConfig
impl UnwindSafe for FirehoseConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more