embedded

Overview ¶

Command embedded shows packtrail running as a single microservice: the engine and the task workers live in one process, importing only the public github.com/henomis/packtrail package.

Run a NATS server (2.12+, JetStream enabled) and, from the repo root (the flow is loaded from examples/embedded/flows):

go run ./examples/embedded --nats nats://127.0.0.1:4222

It starts one execution of the research pipeline, prints progress, and dumps the assembled results when the flow settles. Workers are plain queue-group subscribers, so ./examples/worker can be run alongside (same --namespace) to load-balance the very same task subjects from a separate process.