Skip to main content

Crate thread_flow

Crate thread_flow 

Source
Expand description

§Thread CocoIndex Integration

This crate implements the bridge between Thread’s imperative library and CocoIndex’s declarative dataflow engine.

It follows the Service-Library architecture using the following patterns:

  • Adapter: Wraps Thread logic in CocoIndex operators
  • Bridge: Implements thread-services traits using CocoIndex
  • Builder: Constructs analysis flows
  • Strategy: Handles runtime differences (CLI vs Edge)

Re-exports§

pub use flows::builder::ThreadFlowBuilder;
pub use registry::ThreadOperators;
pub use runtime::EdgeStrategy;
pub use runtime::LocalStrategy;
pub use runtime::RuntimeStrategy;

Modules§

batch
Batch file processing with optional parallel execution
bridge
cache
Query result caching for Thread pipeline
conversion
flows
functions
incremental
Incremental Update System
monitoring
Thread Flow Monitoring
registry
Operator registry for Thread’s ReCoco integration.
runtime
sources
targets

Macros§

timed_operation
Macro for structured logging with performance tracking