Struct ThreadOperators 

pub struct ThreadOperators;

Thread operators available for ReCoco flows.

These operators integrate Thread’s semantic code analysis capabilities into ReCoco’s dataflow engine for incremental, cached code parsing.

Available Operators

Functions (Transforms)

thread_parse

Parse source code into AST with semantic extraction.

Inputs:

• content (String): Source code content
• language (String): Language identifier (extension or name)
• file_path (String, optional): File path for context

Output: Struct with fields:

• symbols (LTable): Symbol definitions
• imports (LTable): Import statements
• calls (LTable): Function calls

extract_symbols

Extract symbol table from parsed document.

Inputs:

• parsed_document (Struct): Output from thread_parse

Output: LTable with fields:

• name (String): Symbol name
• kind (String): Symbol kind (function, class, etc.)
• scope (String): Scope identifier

extract_imports

Extract import statements from parsed document.

Inputs:

• parsed_document (Struct): Output from thread_parse

Output: LTable with fields:

• symbol_name (String): Imported symbol name
• source_path (String): Import source path
• kind (String): Import kind

extract_calls

Extract function calls from parsed document.

Inputs:

• parsed_document (Struct): Output from thread_parse

Output: LTable with fields:

• function_name (String): Called function name
• arguments_count (Int64): Number of arguments

Targets (Export Destinations)

d1

Export data to Cloudflare D1 edge database.

Configuration:

• account_id (String): Cloudflare account ID
• database_id (String): D1 database ID
• api_token (String): Cloudflare API token
• table_name (String): Target table name

Features:

• Content-addressed deduplication via primary key
• UPSERT pattern (INSERT … ON CONFLICT DO UPDATE)
• Batch operations for efficiency
• Edge-distributed caching

Implementations

impl ThreadOperators

pub const OPERATORS: &'static [&'static str]

List of all available Thread operator names (functions).

pub const TARGETS: &'static [&'static str]

List of all available Thread target names (export destinations).

pub fn is_thread_operator(name: &str) -> bool

Check if an operator name is a Thread operator.

pub fn is_thread_target(name: &str) -> bool

Check if a target name is a Thread target.

pub fn register_all( registry: &mut ExecutorFactoryRegistry, ) -> Result<(), RecocoError>

Register all Thread operators with the provided registry.

This function creates instances of all Thread operator factories and registers them using the SimpleFunctionFactoryBase::register() and TargetFactoryBase::register() methods.

Example

use recoco::ops::sdk::ExecutorFactoryRegistry;
use thread_flow::ThreadOperators;

let mut registry = ExecutorFactoryRegistry::new();
ThreadOperators::register_all(&mut registry)?;