Struct ThreadFlowBuilder 

pub struct ThreadFlowBuilder { /* private fields */ }

Builder for constructing standard Thread analysis pipelines.

This implements the Builder pattern to simplify the complexity of constructing CocoIndex flows with multiple operators.

Implementations

impl ThreadFlowBuilder

pub fn new(name: impl Into<String>) -> Self

pub fn source_local( self, path: impl Into<String>, included: &[&str], excluded: &[&str], ) -> Self

pub fn parse(self) -> Self

pub fn extract_symbols(self) -> Self

pub fn extract_imports(self) -> Self

pub fn extract_calls(self) -> Self

pub fn target_postgres( self, table: impl Into<String>, primary_key: &[&str], ) -> Self

pub fn target_d1( self, account_id: impl Into<String>, database_id: impl Into<String>, api_token: impl Into<String>, table: impl Into<String>, primary_key: &[&str], ) -> Self

Configure D1 as the export target

Arguments

• account_id - Cloudflare account ID
• database_id - D1 database ID
• api_token - Cloudflare API token
• table - Table name to export to
• primary_key - Primary key field names for content-addressed deduplication

pub async fn build(self) -> ServiceResult<FlowInstanceSpec>