databricks-zerobus-ingest-sdk 2.0.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
26
27
28
29
30
31
32
33
34
35
36

//! Builder API for creating Zerobus SDK instances and ingestion streams.
//!
//! This module provides fluent builder patterns for configuring and creating
//! SDK instances and streams.
//!
//! # Examples
//!
//! ## SDK Builder
//!
//! ```no_run
//! use databricks_zerobus_ingest_sdk::ZerobusSdkBuilder;
//!
//! let sdk = ZerobusSdkBuilder::new()
//!     .endpoint("https://workspace.zerobus.databricks.com")
//!     .unity_catalog_url("https://workspace.cloud.databricks.com")
//!     .build()?;
//! # Ok::<(), databricks_zerobus_ingest_sdk::ZerobusError>(())
//! ```
//!
//! ## Stream Builder
//!
//! ```rust,ignore
//! let stream = sdk
//!     .stream_builder()
//!     .table("catalog.schema.table")
//!     .oauth("client-id", "client-secret")
//!     .json()
//!     .build()
//!     .await?;
//! ```

mod sdk_builder;
mod stream_builder;

pub use sdk_builder::ZerobusSdkBuilder;
pub use stream_builder::StreamBuilder;