pub struct CloudSinkConfig {
pub endpoint: String,
pub token: String,
pub server: Option<String>,
pub batch_size: usize,
pub flush_interval: Duration,
pub on_flush: Option<SyncCallback>,
}Expand description
Configuration for the cloud sink.
Fields§
§endpoint: StringFull ingest URL, e.g. “https://api.mcpr.app/api/ingest-events”
token: StringProject token, e.g. “mcpr_xxxxxxxx”
server: Option<String>Server slug — identifies which server in the cloud project
batch_size: usizeFlush when buffer reaches this size (default: 100)
flush_interval: DurationFlush on this interval even if buffer isn’t full (default: 5s)
on_flush: Option<SyncCallback>Optional callback for reporting sync status
Auto Trait Implementations§
impl Freeze for CloudSinkConfig
impl !RefUnwindSafe for CloudSinkConfig
impl Send for CloudSinkConfig
impl Sync for CloudSinkConfig
impl Unpin for CloudSinkConfig
impl UnsafeUnpin for CloudSinkConfig
impl !UnwindSafe for CloudSinkConfig
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