{"_id":"@boringos/pipeline","_rev":"8-583a506a079411d22d365ace9b0e4af7","name":"@boringos/pipeline","dist-tags":{"latest":"0.1.10"},"versions":{"0.1.0":{"name":"@boringos/pipeline","version":"0.1.0","keywords":["boringos","agentic","ai-agents","framework"],"author":{"name":"BoringOS Contributors"},"license":"MIT","_id":"@boringos/pipeline@0.1.0","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"homepage":"https://boringos.dev","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"dist":{"shasum":"5e744ca53baf0fb37290d1783842ff95c5b9109a","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.0.tgz","fileCount":18,"integrity":"sha512-W5m3NDODczDNftKJtvdJm4pyZcQ+qqvxjFPr/SM5d5qhDUhHnCqwwSguoYJoh2F2VCmMnpsTMcAii1m28PRHzw==","signatures":[{"sig":"MEUCIFLypWfMsC/LydHs5aqKvCvPT2MCOWDPaNLSERcHnwhBAiEA7CbrvbVNEudKQk1DhlWhyOuOfz52NQHVOxRF28gBpqA=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":9085},"main":"dist/index.js","type":"module","_from":"file:boringos-pipeline-0.1.0.tgz","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"_resolved":"/private/var/folders/0n/sxl7t1x95h7_47y142xfgkxc0000gn/T/7655d48fb9b27c649762d5dcec3e5782/boringos-pipeline-0.1.0.tgz","_integrity":"sha512-W5m3NDODczDNftKJtvdJm4pyZcQ+qqvxjFPr/SM5d5qhDUhHnCqwwSguoYJoh2F2VCmMnpsTMcAii1m28PRHzw==","repository":{"url":"git+https://github.com/BoringOS-dev/boringos.git","type":"git"},"_npmVersion":"10.9.2","description":"Pluggable job queue — in-process or BullMQ","directories":{},"_nodeVersion":"22.16.0","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"0.1.0"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.7.3","@types/node":"^22.0.0"},"_npmOperationalInternal":{"tmp":"tmp/pipeline_0.1.0_1775710372505_0.42628309970452083","host":"s3://npm-registry-packages-npm-production"}},"0.1.1":{"name":"@boringos/pipeline","version":"0.1.1","keywords":["boringos","agentic","ai-agents","framework"],"author":{"name":"BoringOS Contributors"},"license":"MIT","_id":"@boringos/pipeline@0.1.1","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"homepage":"https://boringos.dev","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"dist":{"shasum":"776ef5416e7d6f74c46752ed52ce09fd33f466a1","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.1.tgz","fileCount":18,"integrity":"sha512-9AlvJaBcin+u0eZ9nbB9FbhGmcOf5IMaSJkn1PJD1R6H6JuIuXNM/vQTgIx662yRUAvoDGGsqZyQoAJ4lrYigg==","signatures":[{"sig":"MEUCIQCMf1g8lMftQMolC0s068poiPWNzSk2LR2aB/qhTWxasQIgI6NVjJrjwoRU2+VH6Lo965/ivXhERXhdBuQcuUfC3uM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":9085},"main":"dist/index.js","type":"module","_from":"file:boringos-pipeline-0.1.1.tgz","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"_resolved":"/private/var/folders/0n/sxl7t1x95h7_47y142xfgkxc0000gn/T/385f5666d8849af7cb89eef525819bc9/boringos-pipeline-0.1.1.tgz","_integrity":"sha512-9AlvJaBcin+u0eZ9nbB9FbhGmcOf5IMaSJkn1PJD1R6H6JuIuXNM/vQTgIx662yRUAvoDGGsqZyQoAJ4lrYigg==","repository":{"url":"git+https://github.com/BoringOS-dev/boringos.git","type":"git"},"_npmVersion":"10.9.2","description":"Pluggable job queue — in-process or BullMQ","directories":{},"_nodeVersion":"22.16.0","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"0.1.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.7.3","@types/node":"^22.0.0"},"_npmOperationalInternal":{"tmp":"tmp/pipeline_0.1.1_1775762536709_0.19519049844882663","host":"s3://npm-registry-packages-npm-production"}},"0.1.2":{"name":"@boringos/pipeline","version":"0.1.2","keywords":["boringos","agentic","ai-agents","framework"],"author":{"name":"BoringOS Contributors"},"license":"MIT","_id":"@boringos/pipeline@0.1.2","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"homepage":"https://boringos.dev","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"dist":{"shasum":"b093ea1d4e96516e0e9940507681f0fe63008f71","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.2.tgz","fileCount":17,"integrity":"sha512-GQcV0Bw9zzHeErw3/LZ/O4Zj9TzPnKE60MV0xf/phGyYHHO1TSuTdyvm0h78uhy2wB+4a7wn/FzjXeqFBZxDNQ==","signatures":[{"sig":"MEUCIENqxGR264f7BTDK9OHUMofFR/fhkFRl63nGyyrYNC1/AiEA24gqbc4rdV4k6XCXgmDfjz7tpeRee1hj+K2BjCAHaQ4=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":8014},"main":"dist/index.js","type":"module","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"gitHead":"5613b0e9130aebf2d4a652dbe7aa3d9da5703edf","scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"repository":{"url":"git+https://github.com/BoringOS-dev/boringos.git","type":"git"},"_npmVersion":"10.9.2","description":"Pluggable job queue — in-process or BullMQ","directories":{},"_nodeVersion":"22.16.0","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"workspace:*"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.7.3","@types/node":"^22.0.0"},"_npmOperationalInternal":{"tmp":"tmp/pipeline_0.1.2_1775865884758_0.17502676682984886","host":"s3://npm-registry-packages-npm-production"}},"0.1.6":{"name":"@boringos/pipeline","version":"0.1.6","keywords":["boringos","agentic","ai-agents","framework"],"author":{"name":"BoringOS Contributors"},"license":"MIT","_id":"@boringos/pipeline@0.1.6","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"homepage":"https://boringos.dev","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"dist":{"shasum":"f3b6002f2050394b85f05bd15f8a0a5a90238d7b","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.6.tgz","fileCount":19,"integrity":"sha512-cmJEg+2AHmgxmmPzAKWF1P86SRiHC5gC7oKoHYpaVxHLtSa5AI2i+NpDu9Z8tYg8f7kHW9sAME5TNDprIKxl3g==","signatures":[{"sig":"MEYCIQDPkHpv9I5nePcw1KmlTqw8oMhKdrycbZ/jBpFSz81RHgIhAIrbfkgGuSvg9F2BAsH6lqQt1BCpx0MfME9/pQhwnmwr","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":10841},"main":"dist/index.js","type":"module","_from":"file:boringos-pipeline-0.1.6.tgz","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"_resolved":"/tmp/e49e4b4595b693216672cde139ea7bba/boringos-pipeline-0.1.6.tgz","_integrity":"sha512-cmJEg+2AHmgxmmPzAKWF1P86SRiHC5gC7oKoHYpaVxHLtSa5AI2i+NpDu9Z8tYg8f7kHW9sAME5TNDprIKxl3g==","repository":{"url":"git+https://github.com/BoringOS-dev/boringos.git","type":"git"},"_npmVersion":"10.9.4","description":"Pluggable job queue — in-process or BullMQ","directories":{},"_nodeVersion":"22.22.1","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"0.1.6"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.7.3","@types/node":"^22.0.0"},"_npmOperationalInternal":{"tmp":"tmp/pipeline_0.1.6_1776406971327_0.12089788163697834","host":"s3://npm-registry-packages-npm-production"}},"0.1.7":{"name":"@boringos/pipeline","version":"0.1.7","keywords":["boringos","agentic","ai-agents","framework"],"author":{"name":"BoringOS Contributors"},"license":"MIT","_id":"@boringos/pipeline@0.1.7","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"homepage":"https://boringos.dev","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"dist":{"shasum":"25b75e8c0fdc1ee64f98a876ff47dfb9d9372dcd","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.7.tgz","fileCount":18,"integrity":"sha512-3zVOg/rpVMD5Ugxb834o6D2yGGi6gvlOwbzr+l3F8Hx+1FCzVp/ch0fjlK0Ahgp4FuLxscqSr+3oimZh2quQoA==","signatures":[{"sig":"MEQCIE58kJ7BsTvtXCgja0ZMgWRZ8Oeas5utv4Tzep+7aWHIAiAduI+pxVllB9XCDbsM87RgDbod5QmYTCLIinLEPVoIYQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":11981},"main":"dist/index.js","type":"module","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"gitHead":"5aa5e304f9e2742216029068bd0afb185d8630ae","scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"repository":{"url":"git+https://github.com/BoringOS-dev/boringos.git","type":"git"},"_npmVersion":"10.9.4","description":"Pluggable job queue — in-process or BullMQ","directories":{},"_nodeVersion":"22.22.1","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"workspace:*"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.7.3","@types/node":"^22.0.0"},"_npmOperationalInternal":{"tmp":"tmp/pipeline_0.1.7_1776621675420_0.4504474974752992","host":"s3://npm-registry-packages-npm-production"}},"0.1.8":{"name":"@boringos/pipeline","version":"0.1.8","keywords":["boringos","agentic","ai-agents","framework"],"author":{"name":"BoringOS Contributors"},"license":"MIT","_id":"@boringos/pipeline@0.1.8","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"homepage":"https://boringos.dev","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"dist":{"shasum":"ce6c63744a2d723304dcef00ea0e02a69dda537a","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.8.tgz","fileCount":18,"integrity":"sha512-fWwwt4qzCm1aqYbFr0QlPVfEHN7GTd+DzLHHgAoM/rc/z18rj7CzRMWjKtpdrrE/n70UYuFug0hyDRqopvVAAw==","signatures":[{"sig":"MEUCIG9ejXVevDTfWWXdFOZzUu3/yVyDgj7UxUYPXORFQ5FGAiEAuSmyTFEWsott3pHscvR8alfynTyuA3pJlsc/77a/gKE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":11981},"main":"dist/index.js","type":"module","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"gitHead":"bde96e88a0a74fe6dfe6c7b96ca776d7b1b03ffb","scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"repository":{"url":"git+https://github.com/BoringOS-dev/boringos.git","type":"git"},"_npmVersion":"10.9.4","description":"Pluggable job queue — in-process or BullMQ","directories":{},"_nodeVersion":"22.22.1","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"workspace:*"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.7.3","@types/node":"^22.0.0"},"_npmOperationalInternal":{"tmp":"tmp/pipeline_0.1.8_1776829859728_0.5714917327624902","host":"s3://npm-registry-packages-npm-production"}},"0.1.9":{"name":"@boringos/pipeline","version":"0.1.9","keywords":["boringos","agentic","ai-agents","framework"],"author":{"name":"BoringOS Contributors"},"license":"AGPL-3.0-or-later","_id":"@boringos/pipeline@0.1.9","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"homepage":"https://boringos.dev","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"dist":{"shasum":"6d969d8af502697dc7bfb5d6c0c33fab41b27a38","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.9.tgz","fileCount":20,"integrity":"sha512-zM1xpFo3YQYwiyvaEWyQp17AB7skb3tNY4EciboeVo7KcKqOltsB80YEezmNGIejbnHNM8FDkfxnaKif2YjKHQ==","signatures":[{"sig":"MEUCIQDfKSA/PBHPuUyJ7bHBpioEuzVCMOdQEFoA5z8cQKxAPQIgQgYaHa2KsBjDByG4u06a5dwXsfYo7aOOKU5hmPWW1hw=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":48798},"main":"dist/index.js","type":"module","_from":"file:boringos-pipeline-0.1.9.tgz","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"_resolved":"/private/var/folders/0n/sxl7t1x95h7_47y142xfgkxc0000gn/T/a1bcb829d5ad0146b7cdb30cdb452a97/boringos-pipeline-0.1.9.tgz","_integrity":"sha512-zM1xpFo3YQYwiyvaEWyQp17AB7skb3tNY4EciboeVo7KcKqOltsB80YEezmNGIejbnHNM8FDkfxnaKif2YjKHQ==","repository":{"url":"git+https://github.com/BoringOS-dev/boringos.git","type":"git"},"_npmVersion":"10.9.2","description":"Pluggable job queue — in-process or BullMQ","directories":{},"_nodeVersion":"22.16.0","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"0.1.8"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.7.3","@types/node":"^22.0.0"},"_npmOperationalInternal":{"tmp":"tmp/pipeline_0.1.9_1779999511731_0.23554117697031818","host":"s3://npm-registry-packages-npm-production"}},"0.1.10":{"name":"@boringos/pipeline","version":"0.1.10","type":"module","main":"dist/index.js","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"license":"AGPL-3.0-or-later","dependencies":{"bullmq":"^5.0.0","ioredis":"^5.3.0","@boringos/shared":"1.0.0"},"devDependencies":{"@types/node":"^22.0.0","typescript":"^5.7.3"},"description":"Pluggable job queue — in-process or BullMQ","repository":{"type":"git","url":"git+https://github.com/BoringOS-dev/boringos.git"},"homepage":"https://boringos.dev","author":{"name":"BoringOS Contributors"},"keywords":["boringos","agentic","ai-agents","framework"],"scripts":{"build":"tsc","typecheck":"tsc --noEmit"},"_id":"@boringos/pipeline@0.1.10","bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"_integrity":"sha512-z392yE8I1xhMmJSQ1uEdGQ1pGajq2XhZKNoldnnXK4NMuU7+epld8WRu7OAHcKsyREQ7POK3jMUuGL4f6esluQ==","_resolved":"/tmp/5094d6efe11a6640a074a2c855fa8bc4/boringos-pipeline-0.1.10.tgz","_from":"file:boringos-pipeline-0.1.10.tgz","_nodeVersion":"22.22.3","_npmVersion":"10.9.8","dist":{"integrity":"sha512-z392yE8I1xhMmJSQ1uEdGQ1pGajq2XhZKNoldnnXK4NMuU7+epld8WRu7OAHcKsyREQ7POK3jMUuGL4f6esluQ==","shasum":"3a761629c3380487e7331b9d54502ca14d504992","tarball":"https://registry.npmjs.org/@boringos/pipeline/-/pipeline-0.1.10.tgz","fileCount":20,"unpackedSize":48799,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEQCIA1fO0SX8n7qPtoWJGqljtFeQCVAfExpQL1RG0U1OQuIAiA8pADLJeKdrKphfnFIABAvxf47sS7JCpRKxl2RgFhMBg=="}]},"_npmUser":{"name":"paragarora_github","email":"parag.arora@gmail.com"},"directories":{},"maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/pipeline_0.1.10_1780220440441_0.5932300173695606"},"_hasShrinkwrap":false}},"time":{"created":"2026-04-09T04:52:52.383Z","modified":"2026-05-31T09:40:40.689Z","0.1.0":"2026-04-09T04:52:52.658Z","0.1.1":"2026-04-09T19:22:16.844Z","0.1.2":"2026-04-11T00:04:44.876Z","0.1.6":"2026-04-17T06:22:51.463Z","0.1.7":"2026-04-19T18:01:15.553Z","0.1.8":"2026-04-22T03:50:59.867Z","0.1.9":"2026-05-28T20:18:31.896Z","0.1.10":"2026-05-31T09:40:40.571Z"},"bugs":{"url":"https://github.com/BoringOS-dev/boringos/issues"},"author":{"name":"BoringOS Contributors"},"license":"AGPL-3.0-or-later","homepage":"https://boringos.dev","keywords":["boringos","agentic","ai-agents","framework"],"repository":{"type":"git","url":"git+https://github.com/BoringOS-dev/boringos.git"},"description":"Pluggable job queue — in-process or BullMQ","maintainers":[{"name":"paragarora_github","email":"parag.arora@gmail.com"}],"readme":"# @boringos/pipeline\n\nPluggable job queue for BoringOS agent execution. In-process by default, BullMQ for production.\n\n## Install\n\n```bash\nnpm install @boringos/pipeline\n```\n\n## Usage\n\n```typescript\nimport { createInProcessQueue, createBullMQQueue } from \"@boringos/pipeline\";\nimport type { QueueAdapter } from \"@boringos/pipeline\";\n\n// Development: in-process queue (no Redis, zero config)\nconst devQueue = createInProcessQueue<{ taskId: string }>();\n\n// Or with parallelism — up to N jobs processed simultaneously.\n// Each slot runs an independent drain loop, so concurrent agent subprocesses.\n// Pick based on machine size + API rate limits; unbounded is a foot-gun.\nconst parallelQueue = createInProcessQueue<{ taskId: string }>({ concurrency: 4 });\n\n// Production: BullMQ with Redis\nconst prodQueue = createBullMQQueue<{ taskId: string }>({\n  redis: \"redis://localhost:6379\",\n  queueName: \"agent-jobs\",\n  concurrency: 5,\n});\n\n// Enqueue a job\nawait queue.enqueue({ taskId: \"task_123\" });\n\n// Process jobs\nqueue.process(async (job) => {\n  console.log(\"Processing:\", job.taskId);\n});\n\n// Shutdown\nawait queue.close();\n```\n\n### With BoringOS\n\n```typescript\nimport { BoringOS } from \"@boringos/core\";\nimport { createBullMQQueue } from \"@boringos/pipeline\";\n\n// Default: in-process, serial (concurrency 1).\n// Bump parallelism via BoringOS config — no need to construct a queue yourself:\nconst app = new BoringOS({\n  queue: { concurrency: 4 },\n});\n\n// Or, for production: opt into BullMQ explicitly.\n// (Overrides `config.queue` — when you pass your own adapter, BoringOS stops\n// creating the default in-process one.)\napp.queue(createBullMQQueue({ redis: \"redis://localhost:6379\" }));\n```\n\n## API Reference\n\n### Queue Factories\n\n| Export | Description |\n|---|---|\n| `createInProcessQueue<T>(options?)` | Zero-config queue. Default is sequential (`concurrency: 1`); pass `{ concurrency: N }` to process up to N jobs in parallel. No persistence or retries. |\n| `createBullMQQueue<T>(config)` | Redis-backed queue with persistent jobs, automatic retries, configurable concurrency. |\n\n### `QueueAdapter<T>` Interface\n\n| Method | Description |\n|---|---|\n| `enqueue(job: T)` | Add a job to the queue |\n| `process(handler)` | Register a job handler |\n| `close()` | Shut down the queue |\n\n### Types\n\n`QueueAdapter<T>`, `InProcessQueueOptions`, `BullMQConfig`\n\n## Part of [BoringOS](https://github.com/BoringOS-dev/boringos)\n","readmeFilename":"README.md"}