A large expansion of the workflow node catalog — 44 new node types
(136 → 180) — covering the gaps against comparable workflow/automation
tools and deepening the AI-native and Chinese-enterprise coverage. Each node
is full-stack (engine + config UI) and backward compatible. Most are plain
HTTP; the few that aren't were deliberately implemented in pure Rust (or via a
runtime CLI) so the default cargo build needs no extra system library.
Added
LLM providers
azure_openai(deployment-based,api-keyheader),vertex(Google Vertex
AI / GeminigenerateContentwith a caller-supplied OAuth2 token),bedrock
(AWS BedrockInvokeModel, model-native body),grok(xAI), andollama
(self-hosted, OpenAI-compatible).
AI-native building blocks (OpenAI-/Cohere-compatible, configurable base URL)
embedding,reranker,text_splitter(pure-compute, UTF-8-safe chunking),
structured_output(LLM JSON mode),classifier,image_gen,
speech_to_text(Whisper, multipart upload), andtts.
Vector stores
weaviate(REST + GraphQL),chroma(REST data API), andmilvus/ Zilliz
(REST API v2).
Databases & data warehouses
mongodb(Atlas Data API),clickhouse(HTTP),mysql(sqlx),snowflake
(SQL API v2, bearer token),bigquery(jobs.query REST), andsqlserver
(Microsoft SQL Server over the pure-Rust tiberius TDS driver — no native
client needed).
Object storage
gcs(Google Cloud Storage JSON API) andazure_blob(REST + SAS token),
both using caller-supplied credentials.
AWS (a from-scratch Signature V4 signer — no AWS SDK — validated against
AWS's published get-vanilla test vector)
sqs,sns, andbedrock.
Message brokers
kafka(Confluent REST Proxy) andrabbitmq(Management HTTP API).
Chinese enterprise collaboration
feishu/ Lark (custom-bot webhook or app message API),dingtalk(custom
robot with optional HMAC sign), andwecom(WeChat Work group robot).
Network file / shell / mail (pure-Rust clients — no libssh2/system library)
ftp/ FTPS (suppaftp),sftpandssh(russh / russh-sftp, password or
private-key auth), andimap(TLS mailbox reads).
Utilities & core primitives
hash(SHA-256/384/512 + HMAC),jwt(HS256/384/512 sign & verify),
zip(create/extract),image(resize/convert/metadata),pdf_extract
(text extraction),ocr(via thetesseractCLI),html_extract(CSS
selectors),rss(RSS/Atom/JSON feeds), andwait(pause for a duration /
until a timestamp, or suspend until externally resumed via the existing
approve/resume endpoint).
Notes
- The
ocrnode needs thetesseractCLI on the executor host; all other
nodes have no extra runtime dependency. - The
wait(resume mode) andsnowflake/bigquery/vertex/gcs/azure_blob
nodes take a caller-supplied token rather than performing their own
credential exchange.