pub struct ThreadFlowBuilder { /* private fields */ }Expand description
Builder for constructing standard Thread analysis pipelines.
This implements the Builder pattern to simplify the complexity of constructing CocoIndex flows with multiple operators.
Implementations§
Source§impl ThreadFlowBuilder
impl ThreadFlowBuilder
pub fn new(name: impl Into<String>) -> ThreadFlowBuilder
pub fn source_local( self, path: impl Into<String>, included: &[&str], excluded: &[&str], ) -> ThreadFlowBuilder
pub fn parse(self) -> ThreadFlowBuilder
pub fn extract_symbols(self) -> ThreadFlowBuilder
pub fn extract_imports(self) -> ThreadFlowBuilder
pub fn extract_calls(self) -> ThreadFlowBuilder
pub fn target_postgres( self, table: impl Into<String>, primary_key: &[&str], ) -> ThreadFlowBuilder
Sourcepub 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],
) -> ThreadFlowBuilder
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], ) -> ThreadFlowBuilder
Configure D1 as the export target
§Arguments
account_id- Cloudflare account IDdatabase_id- D1 database IDapi_token- Cloudflare API tokentable- Table name to export toprimary_key- Primary key field names for content-addressed deduplication
pub async fn build( self, ) -> Result<FlowInstanceSpec, Box<dyn Error + Send + Sync>>
Auto Trait Implementations§
impl Freeze for ThreadFlowBuilder
impl RefUnwindSafe for ThreadFlowBuilder
impl Send for ThreadFlowBuilder
impl Sync for ThreadFlowBuilder
impl Unpin for ThreadFlowBuilder
impl UnsafeUnpin for ThreadFlowBuilder
impl UnwindSafe for ThreadFlowBuilder
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more