Struct LarkBitableLoader 

pub struct LarkBitableLoader { /* private fields */ }

Load Feishu/Lark Bitable records into Synaptic Documents for RAG pipelines.

Each Bitable record becomes one Document. The content field is populated from the field named by [with_content_field], or the first string-typed field when no explicit field is given. All other fields are stored in metadata.

Example

use synaptic_lark::{LarkConfig, LarkBitableLoader};
use synaptic_core::Loader;

let config = LarkConfig::new("cli_xxx", "secret_xxx");
let loader = LarkBitableLoader::new(config)
    .with_app("bascnAbcXxx")
    .with_table("tblXxx")
    .with_content_field("Description");

let docs = loader.load().await?;
for doc in &docs {
    println!("Record: {}", doc.id);
    println!("Content: {}", doc.content);
}

Implementations

impl LarkBitableLoader

pub fn new(config: LarkConfig) -> Self

Create a new loader using the given config.

pub fn with_app(self, app_token: impl Into<String>) -> Self

Set the Bitable app token (e.g. "bascnAbcXxx").

pub fn with_table(self, table_id: impl Into<String>) -> Self

Set the table ID within the Bitable app (e.g. "tblXxx").

pub fn with_view(self, view_id: impl Into<String>) -> Self

Optionally filter records by a specific view (e.g. "vewXxx").

pub fn with_content_field(self, field: impl Into<String>) -> Self

Specify which field’s value becomes the Document.content.

When not set, the first string-typed field is used automatically.

pub fn app_token(&self) -> &str

Returns the configured app token, or "" if not set.

pub fn table_id(&self) -> &str

Returns the configured table ID, or "" if not set.

pub fn view_id(&self) -> Option<&str>

Returns the configured view ID if any.

pub fn content_field(&self) -> Option<&str>

Returns the configured content field name if any.

Trait Implementations

impl Loader for LarkBitableLoader

fn load<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Document>, SynapticError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Load all documents from this source.

fn lazy_load( &self, ) -> Pin<Box<dyn Stream<Item = Result<Document, SynapticError>> + Send + '_>>

Stream documents lazily. Default implementation wraps load().