Skip to content

feat(streams): WASM plugin support for Rust Arroyo adapter#327

Draft
fpacifici wants to merge 2 commits into
mainfrom
fpacifici/wasm_support
Draft

feat(streams): WASM plugin support for Rust Arroyo adapter#327
fpacifici wants to merge 2 commits into
mainfrom
fpacifici/wasm_support

Conversation

@fpacifici
Copy link
Copy Markdown
Collaborator

@fpacifici fpacifici commented May 22, 2026

Summary

  • Add a WasmProcessor pipeline step (bytesbytes) that loads a WASM component from module_path and wires it into the Rust Arroyo adapter.
  • Define the guest contract in WIT (sentry_streams/wit/processor.wit): submit, submit_watermark, and poll returning messages or watermarks. Host provides a log import; WASI Preview 2 is linked at runtime (not in the WIT file).
  • Implement a single-threaded WasmProcessor Arroyo strategy using wasmtime (one Store + guest instance per step).
  • Add a componentize-py example guest under examples/wasm_guest/ and a minimal Rust passthrough guest for unit tests (tests/fixtures/wasm_passthrough.wasm).

Made with Cursor

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant