databricks-zerobus-ingest-sdk 1.2.0

A high-performance Rust client for streaming data ingestion into Databricks Delta tables using the Zerobus service
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! Shared configuration options for stream creation and operation.
//!
//! This module provides common configuration constants shared between gRPC and Arrow Flight streams.

/// Default values for stream configuration options.
/// These are shared between gRPC and Arrow Flight streams.
pub mod defaults {
    /// Default: enable automatic stream recovery
    pub const RECOVERY: bool = true;
    /// Default: 15 seconds per recovery attempt
    pub const RECOVERY_TIMEOUT_MS: u64 = 15_000;
    /// Default: 2 seconds backoff between retries
    pub const RECOVERY_BACKOFF_MS: u64 = 2_000;
    /// Default: 4 retry attempts
    pub const RECOVERY_RETRIES: u32 = 4;
    /// Default: 60 seconds lack of ack timeout
    pub const SERVER_LACK_OF_ACK_TIMEOUT_MS: u64 = 60_000;
    /// Default: 5 minutes flush timeout
    pub const FLUSH_TIMEOUT_MS: u64 = 300_000;
    /// Default: 30 seconds connection timeout
    #[cfg(feature = "arrow-flight")]
    pub const CONNECTION_TIMEOUT_MS: u64 = 30_000;
    /// Default: 5 seconds callback timeout
    pub const CALLBACK_MAX_WAIT_TIME_MS: u64 = 5_000;
}