bunqueue

(★ 536)

⚡ High-performance job queue for Bun. SQLite persistence, DLQ, cron jobs, S3 backups. Built for AI agents and automation

파일 탐색기

최종 버전 다운로드 (.zip)

- - skeptic.md
- plugin.json
- - skeptic.toml
- - bug_report.yml
  - config.yml
  - feature_request.yml
  - question.yml
- - ci.yml
  - sdk-mutation.yml
  - sdk-release.yml
  - sdk-security.yml
  - sdk.yml
- banner.svg
- bunqueue-demo.mp4
- icon.png
- icon.svg
- logo.png
- logo.svg
- mcp-flow.svg
- SUPPORT.md
- terminal.png
- x-header.png
- x-header.svg
- x-profile.svg
- pre-commit
- bunqueue-assistant.md
- - bullmq.ts
  - bunqueue.ts
  - config.ts
  - harness.ts
  - report.ts
  - run.ts
- - harness.ts
  - query.ts
  - recovery.ts
  - scheduling-stats.ts
  - temporal-waiter.ts
  - types.ts
- - connection.ts
  - sample.ts
  - scale.ts
- comprehensive-report.ts
- comprehensive.ts
- fix-impact.ts
- job-list-perf.ts
- local-autobatch.ts
- native-benchmark-integrity.ts
- pushbulk-delta.ts
- tcp-bench.ts
- tcp-process-sweep.ts
- workflow-engine.ts
- - fix-impact-2026-07-16.md
  - native-engineering-2026-07-30.md
  - native-engineering-2026-08-02.md
  - native-engineering-2026-08-03.md
- - background-tasks.md
  - backup-s3.md
  - benchmarks.md
  - cli.md
  - client-queue-sdk.md
  - client-transport.md
  - client-worker-sdk.md
  - cloud-integration.md
  - concurrency-and-locking.md
  - configuration.md
  - core-public-api-e2e.md
  - core-queue-engine.md
  - data-structures.md
  - dead-letter-queue.md
  - deduplication-and-unique.md
  - documentation-tooling.md
  - documented-feature-verification.md
  - documented-guide-audit.md
  - elixir-sdk.md
  - flow-producer.md
  - http-api.md
  - job-lifecycle.md
  - job-queries-and-control.md
  - mcp-server.md
  - model-based-testing.md
  - persistence.md
  - polyglot-sdks.md
  - production-readiness-testing.md
  - public-api-completeness.md
  - rate-limiting-and-concurrency.md
  - rust-sdk.md
  - scheduler-and-cron.md
  - security-tls-auth.md
  - simple-mode.md
  - stats-and-monitoring.md
  - store-and-forward.md
  - tcp-protocol.md
  - tcp-server-handlers.md
  - webhooks-and-events.md
  - workers-management.md
  - workflow-engine.md
- - 338321b685f29b67ae11f935d45ef1e7.txt
  - apple-touch-icon.png
  - bq-changelog.js
  - bq-compat.js
  - bq-copy.js
  - bq-inter.js
  - bq-sim.js
  - favicon-32x32.png
  - favicon.svg
  - llms.txt
  - manifest.webmanifest
  - og-image.png
  - robots.txt
- - generate-og.ts
  - og-covers.ts
- - content.config.ts
- .gitignore
- architecture.md
- astro.config.mjs
- CLOUD_CONTRACT.md
- CLOUD_PAYLOAD_EXAMPLE.json
- data-model.md
- generated-api-reference.md
- package.json
- protocol.md
- README.md
- testing.md
- tsconfig.json
- typedoc-theme.css
- vercel.json
- - index.ts
  - README.md
- alert_rules.test.yml
- alert_rules.yml
- alertmanager.yml
- prometheus.yml
- - claude-agent-live.ts
- - saga-live-e2e.ts
  - saga-live.ts
- - processor.ts
  - run-all-tests.ts
  - test-advanced-dlq.ts
  - test-advanced-job-options.ts
  - test-authentication.ts
  - test-backoff-strategies.ts
  - test-basic-operations.ts
  - test-batch-operations.ts
  - test-bullmq-job-options.ts
  - test-bullmq-queue-methods.ts
  - test-concurrency.ts
  - test-cron-event-driven.ts
  - test-cron-jobs.ts
  - test-cron-server.ts
  - test-dlq.ts
  - test-flow-producer.ts
  - test-issue-72-job-state-race.ts
  - test-job-advanced-methods.ts
  - test-job-dependencies.ts
  - test-job-management.ts
  - test-job-move-methods.ts
  - test-job-progress.ts
  - test-mcp-cron-serialization.ts
  - test-monitoring.ts
  - test-parent-failure-options.ts
  - test-prefix-key-parity.ts
  - test-query-operations.ts
  - test-queue-control.ts
  - test-queue-events.ts
  - test-queue-group.ts
  - test-queue-name-consistency.ts
  - test-rate-limit-window-parity.ts
  - test-rate-limiting.ts
  - test-retry-backoff.ts
  - test-runtime-results.ts
  - test-sandboxed-workers.ts
  - test-stall-detection.ts
  - test-timeout.ts
  - test-unique-jobs.ts
  - test-webhooks.ts
  - test-worker-advanced.ts
  - test-worker-lifecycle-parity.ts
  - test-worker-management.ts
  - test-workflow-engine.ts
- - advanced-dlq-contract.ts
  - mcp-cron-serialization-contract.ts
  - prefix-key-contract.ts
  - queue-events-contract.ts
  - queue-group-contract.ts
  - rate-limit-window-contract.ts
  - runtime-results-contract.ts
  - stall-detection-contract.ts
  - timeout-contract.ts
  - worker-lifecycle-contract.ts
- - bench-flow-parallel.ts
  - run-all-tests.ts
  - test-additional-commands.ts
  - test-advanced-dlq.ts
  - test-advanced-job-options.ts
  - test-async-api-variants.ts
  - test-authentication.ts
  - test-backoff-strategies.ts
  - test-backpressure.ts
  - test-basic-operations.ts
  - test-batch-operations.ts
  - test-bulk-operations-advanced.ts
  - test-bullmq-queue-methods.ts
  - test-concurrency.ts
  - test-cron-advanced.ts
  - test-cron-jobs.ts
  - test-cron-server.ts
  - test-data-integrity.ts
  - test-dedup-tcp.ts
  - test-dlq-patterns.ts
  - test-dlq.ts
  - test-etl-pipeline.ts
  - test-flow-advanced.ts
  - test-flow-children.ts
  - test-flow-patterns-advanced.ts
  - test-frameparser-pipelining-e2e.ts
  - test-graceful-shutdown.ts
  - test-idempotency-dedup.ts
  - test-issue-72-job-state-race.ts
  - test-job-cancellation.ts
  - test-job-dependencies.ts
  - test-job-lifecycle-events.ts
  - test-job-management.ts
  - test-job-move-methods.ts
  - test-job-progress.ts
  - test-job-removal-cleanup.ts
  - test-long-running-timeout.ts
  - test-mcp-cron-serialization.ts
  - test-missing-commands.ts
  - test-monitoring.ts
  - test-parent-failure-options.ts
  - test-pause-resume-patterns.ts
  - test-prefix-key-parity.ts
  - test-prefix-key.ts
  - test-priority-delayed.ts
  - test-query-operations.ts
  - test-queue-control.ts
  - test-queue-events.ts
  - test-queue-group-advanced.ts
  - test-queue-group.ts
  - test-queue-name-consistency.ts
  - test-rate-limit-window-parity.ts
  - test-rate-limit-window-ttl.ts
  - test-rate-limiting.ts
  - test-retry-backoff.ts
  - test-retry-resilience.ts
  - test-runtime-results.ts
  - test-sandboxed-worker-advanced.ts
  - test-sandboxed-worker.ts
  - test-sandboxed-workers.ts
  - test-stall-detection.ts
  - test-timeout.ts
  - test-unique-jobs.ts
  - test-webhooks.ts
  - test-websocket.ts
  - test-worker-advanced.ts
  - test-worker-lifecycle-parity.ts
  - test-worker-management.ts
  - test-worker-scaling.ts
  - test-workflow-engine.ts
- - run-all-tests.ts
  - test-sse-stream.ts
  - test-ws-connection.ts
  - test-ws-edge-cases.ts
  - test-ws-job-events.ts
  - test-ws-pubsub.ts
  - test-ws-queue-dlq-cron.ts
  - test-ws-system-periodic.ts
  - test-ws-workers-rate-webhooks.ts
- bench-tcp-batch-notify-report.ts
- bench-tcp-batch-notify.ts
- build-api-reference.ts
- check-docs-data.ts
- cloud-dashboard-sim.ts
- demo-batch-notify-extreme.ts
- demo-batch-notify-stress.ts
- demo-batch-notify.ts
- simulate-dashboard.ts
- stress-cpu-intensive.ts
- test-mcp-all.ts
- test-recovery-logic.ts
- test-sandbox-log-parser.ts
- test-sandbox-report.ts
- test-sandbox-telemetry.ts
- test-sandbox.ts
- test-sdk-sandbox.ts
- - .gitignore
  - check-support.ts
  - checks-operations.ts
  - checks-protocol.ts
  - harness.ts
  - README.md
  - runner.ts
  - wire.ts
- - .formatter.exs
  - .gitignore
  - AGENTS.md
  - CHANGELOG.md
  - CLAUDE.md
  - INVARIANTS.md
  - LICENSE
  - mix.exs
  - mix.lock
  - README.md
- - .gitignore
  - .gremlins.yaml
  - AGENTS.md
  - CHANGELOG.md
  - CLAUDE.md
  - connection.go
  - connection_wire.go
  - core_test.go
  - edge_test.go
  - errors.go
  - flow.go
  - flow_commit.go
  - flow_id.go
  - flow_id_test.go
  - flow_planner.go
  - flow_property_test.go
  - flow_snapshots.go
  - flow_test.go
  - flow_validation_test.go
  - go.mod
  - go.sum
  - hardening_test.go
  - harness_test.go
  - INVARIANTS.md
  - job.go
  - name_data_test.go
  - options.go
  - production_regression_test.go
  - queue.go
  - queue_admin.go
  - queue_control.go
  - queue_query.go
  - README.md
  - realistic_e2e_test.go
  - soak_test.go
  - spec_test.go
  - telemetry.go
  - telemetry_test.go
  - wire.go
  - wire_safety.go
  - wire_safety_test.go
  - worker.go
  - worker_outcome.go
  - worker_outcome_test.go
  - worker_process.go
  - worker_test.go
- - .gitignore
  - AGENTS.md
  - CHANGELOG.md
  - CLAUDE.md
  - composer.json
  - composer.lock
  - infection.json5
  - INVARIANTS.md
  - LICENSE
  - phpunit.xml.dist
  - README.md
- - .gitignore
  - AGENTS.md
  - CHANGELOG.md
  - CLAUDE.md
  - INVARIANTS.md
  - LICENSE
  - pyproject.toml
  - README.md
- - .gitignore
  - AGENTS.md
  - Cargo.lock
  - Cargo.toml
  - CHANGELOG.md
  - CLAUDE.md
  - INVARIANTS.md
  - LICENSE
  - README.md
- - .gitignore
  - AGENTS.md
  - biome.json
  - bun.lock
  - CHANGELOG.md
  - CLAUDE.md
  - INVARIANTS.md
  - LICENSE
  - package.json
  - README.md
  - tsconfig.json
- CLAUDE.md
- - examples.md
  - mcp.md
  - reference.md
  - SKILL.md
- - backgroundTasks.ts
  - cleanupTasks.ts
  - clientTracking.ts
  - contextFactory.ts
  - dependencyCompletions.ts
  - dependencyProcessor.ts
  - dependencyResultTracker.ts
  - dlqManager.ts
  - dlqRetry.ts
  - eventsManager.ts
  - flowFailureRecovery.ts
  - flowParentBackpatch.ts
  - jobLogsManager.ts
  - latencyTracker.ts
  - lockManager.ts
  - lockOperations.ts
  - metricsExporter.ts
  - monitoringChecks.ts
  - prometheusOperationalMetrics.ts
  - queueManager.ts
  - queueStatsAggregator.ts
  - queueTelemetryJournal.ts
  - repeatJobs.ts
  - stallDetection.ts
  - statsManager.ts
  - taskErrorTracking.ts
  - throughputTracker.ts
  - webhookManager.ts
  - workerManager.ts
- - algorithm-optimizations.bench.ts
  - completed-events.bench.ts
  - dependency-latency.bench.ts
  - event-payload-test.ts
  - full-client-test.ts
  - full-features-test.ts
  - million-jobs.bench.ts
  - stress.bench.ts
  - throughput.bench.ts
  - ultimate-test.ts
  - worker.bench.ts
- - client.ts
  - commandRegistry.ts
  - commandRouter.ts
  - globalOptions.ts
  - help.ts
  - index.ts
  - localOutput.ts
  - output.ts
- - bunqueue.ts
  - dlqConversion.ts
  - errors.ts
  - events.ts
  - flow.ts
  - flowAtomic.ts
  - flowJobCoreMethods.ts
  - flowJobDependencies.ts
  - flowJobFactory.ts
  - flowJobMoveMethods.ts
  - flowJobTypes.ts
  - flowLegacyPlan.ts
  - flowOptions.ts
  - flowPlan.ts
  - flowPush.ts
  - flowReader.ts
  - flowResults.ts
  - flowTypes.ts
  - forwarder.ts
  - index.ts
  - jobConversion.ts
  - jobConversionHelpers.ts
  - jobConversionTypes.ts
  - jobDeduplication.ts
  - jobHelpers.ts
  - manager.ts
  - queue.ts
  - queueGroup.ts
  - resolveToken.ts
  - sandboxedWorker.ts
  - tcpClient.ts
  - tcpPool.ts
  - types.ts
  - worker.ts
- - index.ts
  - loader.ts
  - resolve.ts
  - types.ts
- - adapter.ts
  - httpHandler.ts
  - index.ts
  - prompts.ts
  - resources.ts
  - server.ts
- - asyncLock.ts
  - boundedMap.ts
  - boundedSet.ts
  - hash.ts
  - histogram.ts
  - index.ts
  - lock.ts
  - lockError.ts
  - lockTimeout.ts
  - logger.ts
  - lru.ts
  - lruMap.ts
  - lruSet.ts
  - minHeap.ts
  - msgpack.ts
  - pausedView.ts
  - rwLock.ts
  - semaphore.ts
  - serialization.ts
  - skipList.ts
  - skipListNodes.ts
  - ttlMap.ts
  - version.ts
  - webhookValidation.ts
- bun-only.ts
- main.ts
- require-bun.ts
- - commandCases.ts
  - runtimeHarness.ts
- - core-public-api.e2e.test.ts
- - overview.test.ts
  - recipes.test.ts
  - reference.test.ts
  - repeat-pattern-chain.test.ts
  - repeat-pattern-runaway.test.ts
- - auto-retry.test.ts
  - configuration.test.ts
  - operations.test.ts
  - overview.test.ts
  - queue-api.test.ts
  - reference.test.ts
- - failures.test.ts
  - overview.test.ts
  - patterns.test.ts
  - reference.test.ts
- - adding-jobs.test.ts
  - advanced-batching.test.ts
  - advanced-prefix.test.ts
  - control.test.ts
  - deduplication.test.ts
  - limits.test.ts
  - metrics.test.ts
  - options.test.ts
  - overview.test.ts
  - progress.test.ts
  - querying.test.ts
  - queue-group.test.ts
  - rate-limiting.test.ts
- - concurrency.test.ts
  - cpu-intensive.test.ts
  - errors.test.ts
  - events.test.ts
  - job-object.test.ts
  - lifecycle.test.ts
  - options.test.ts
  - overview.test.ts
  - retention.test.ts
  - sandboxed.test.ts
  - stall-detection.test.ts
  - stalls.test.ts
- - issue113-worker-poll-timer-probe.ts
  - sqlite-migration-failure.ts
  - tcp-server-rate-limiter-lifecycle.ts
  - timer-lifecycle-idempotency-probe.ts
  - worker-pause-resume-lifecycle.ts
- - backup-model.test.ts
  - batch-commands.ts
  - cross-queue-invariants.ts
  - enterprise-telemetry-model.test.ts
  - flow-commands.ts
  - flow-producer-model.test.ts
  - invalid-commands.ts
  - job-management-command-leases.test.ts
  - job-management-commands.ts
  - model-ids.ts
  - monitoring-model.test.ts
  - queue-command.ts
  - queue-commands.ts
  - queue-control-commands.ts
  - queue-model-broker.ts
  - queue-model-harness.ts
  - queue-model-observability.ts
  - queue-model.test.ts
  - scheduling-contract-commands.ts
  - workflow-build.ts
  - workflow-child-invariants.ts
  - workflow-commands.ts
  - workflow-invariants.ts
  - workflow-model-harness.ts
  - workflow-model-listing.ts
  - workflow-model.test.ts
  - workflow-rollback-invariants.ts
  - workflow-spec-analysis.ts
  - workflow-spec.ts
- - core-queue-stubs.test.ts
  - dlq-job-contract.test.ts
  - dlq-job-e2e-helpers.ts
  - dlq-job-e2e-lifecycle.test.ts
  - dlq-job-e2e-state.test.ts
  - move-waiting-children-persistence.test.ts
  - paginated-query-partials.test.ts
  - queue-group-tcp-stubs.test.ts
  - retry-jobs-partial.test.ts
  - tcp-core-stubs.test.ts
  - tcp-dlq-stubs.test.ts
  - tcp-harness.ts
  - tcp-sync-query-stubs.test.ts
  - worker-dependency-stubs.test.ts
- ack-helpers.test.ts
- ack-operations.test.ts
- addBatcher.test.ts
- audit-ackbatcher-overflow.test.ts
- audit-autobatch-auth-rejection.test.ts
- audit-backup-restore.test.ts
- audit-bugs.test.ts
- audit-cloud-redaction.test.ts
- audit-cron-fixes.test.ts
- audit-dlq-recovery-bound.test.ts
- audit-drain-sqlite.test.ts
- audit-flow-maps-leak.test.ts
- audit-persistence-fixes.test.ts
- audit-tcp-client-malformed.test.ts
- audit-tcp-protocol.test.ts
- audit-unwired-processor-methods.test.ts
- audit-workflow-fixes.test.ts
- audit-workflow-waitfor-double-compensate.test.ts
- autoBatching.test.ts
- backgroundTasks.test.ts
- backpressure.test.ts
- backward-compat.test.ts
- batchOperations.test.ts
- boundedCollections.test.ts
- bug-15-worker-event-types.test.ts
- bug-16-flow-job-update-data.test.ts
- bug-16-repeat-update-data.test.ts
- bug-22-scheduler-timezone.test.ts
- bug-23-scheduler-job-name.test.ts
- bug-60-scheduler-deduplication.test.ts
- bug-69-active-job-dedup.test.ts
- bug-74-stacktrace-on-failed.test.ts
- bug-75-cron-lock-expiry-requeue.test.ts
- bug-76-worker-ready-event.test.ts
- bug-80-dedup-cleanup-race.test.ts
- bug-asynclock-double-release.test.ts
- bug-auth-state-corruption.test.ts
- bug-backoff-no-jitter.test.ts
- bug-backoff-object-tcp.test.ts
- bug-batch-notify-single-waiter.test.ts
- bug-embedded-heartbeat-token.test.ts
- bug-flow-tcp-parent-id-pending.test.ts
- bug-getjob-completed-no-storage.test.ts
- bug-getjob-failed-no-storage.test.ts
- bug-jobheartbeat-duration.test.ts
- bug-lock-token-race.test.ts
- bug-lost-notification.test.ts
- bug-memory-leak-waiters.test.ts
- bug-pushbatch-no-events.test.ts
- bug-queueevents-listener-leak.test.ts
- bug-requeue-expired-lock.test.ts
- bug-silent-duplicate-discard.test.ts
- bug-state-transition-before-buffer-flush.test.ts
- bug-tcp-orphan-jobs-on-release-failure.test.ts
- bug-unregister-worker-field.test.ts
- bug-update-job-parent-persist.test.ts
- bug-verification-remaining.test.ts
- bug-writebuffer-dataloss.test.ts
- bug-writebuffer-no-critical-callback.test.ts
- bug-writebuffer-swap-dataloss.test.ts
- build-api-reference.test.ts
- bulk-operations-advanced.test.ts
- bullmq-compat-fail-parent.test.ts
- bullmq-compat-flow-atomic.test.ts
- bullmq-compat-flow-emitter.test.ts
- bullmq-compat-move-ops.test.ts
- bullmq-compat-prioritized.test.ts
- bullmq-compat-remove-dependency.test.ts
- bunqueue.test.ts
- check-docs-data.test.ts
- cleanupTasks.test.ts
- cli-bugs.test.ts
- cli-bugs2.test.ts
- cli-client.test.ts
- cli-commands-extended.test.ts
- cli-doctor-logic.test.ts
- cli-e2e.test.ts
- cli-env-token.test.ts
- cli-error-formatting.test.ts
- cli-invariants-boundaries.test.ts
- cli-invariants-concurrency.test.ts
- cli-invariants-core.test.ts
- cli-invariants-e2e.test.ts
- cli-invariants-local-e2e.test.ts
- cli-invariants-protocol-e2e.test.ts
- cli-invariants-runtime.test.ts
- cli-issues.test.ts
- cli-output.test.ts
- cli-server-args.test.ts
- cli.test.ts
- client-dlq-dedup.test.ts
- client-flowpush-compat.test.ts
- client-helpers.test.ts
- client-pipelining.test.ts
- client-queue-features.test.ts
- client-queue-operations.test.ts
- client-tcp.test.ts
- client.test.ts
- clientTracking.test.ts
- cloud-agent.test.ts
- comparison-benchmark-integrity.test.ts
- concurrent.test.ts
- config-validation-audit.test.ts
- contextFactory.test.ts
- core-operations-edge-cases.test.ts
- cron-advanced.test.ts
- cron-timezone-dst.test.ts
- cron-timezone.test.ts
- cron.test.ts
- cronScheduler.test.ts
- data-integrity.test.ts
- deduplication-advanced.test.ts
- deduplicationRecovery.test.ts
- dependency-result-tracker.test.ts
- dependencyTracker.test.ts
- dlq-patterns.test.ts
- dlq-selective-retry.test.ts
- dlq-shard-deps-logs.test.ts
- dlqAdvanced.test.ts
- dlqManager.test.ts
- docs-guide-support.ts
- docs-language-tabs.test.ts
- docs-queue-snippets.test.ts
- docs-quickstart.test.ts
- documented-feature-coverage.test.ts
- domain-types-extended.test.ts
- domain-types.test.ts
- durable-jobs.test.ts
- e2e-edge-cases.test.ts
- etl-pipeline.test.ts
- eventsManager-extended.test.ts
- eventsManager.test.ts
- features.test.ts
- fix-impact-benchmark.test.ts
- flow-advanced.test.ts
- flow-children.test.ts
- flow-deduplication.test.ts
- flow-docs-examples.test.ts
- flow-patterns-advanced.test.ts
- flow-producer-audit.test.ts
- flow-producer-real-e2e.test.ts
- flow-producer.test.ts
- flow-stall-interaction.test.ts
- flowProducer.test.ts
- forwarder.test.ts
- full-client-flow-runner.test.ts
- full-features-runner.test.ts
- get-completed-jobs.test.ts
- get-jobs-pagination.test.ts
- graceful-shutdown.test.ts
- hash.test.ts
- histogram.test.ts
- http-client-tracking-leak.test.ts
- http-dashboard-pagination.test.ts
- http-debug-auth.test.ts
- http-job-actions.test.ts
- http-param-forwarding-audit.test.ts
- http-parse-body.test.ts
- http-queue-actions.test.ts
- idempotency-dedup.test.ts
- issue-102-cancel-waitingdeps.test.ts
- issue-108-109-tls.test.ts
- issue-111-audit-siblings.test.ts
- issue-111-scheduler-limit-tcp.test.ts
- issue-111-scheduler-limit.test.ts
- issue-44-group-concurrency.test.ts
- issue-45-getstate-active.test.ts
- issue-46-config-tcp.test.ts
- issue-46-disable-config.test.ts
- issue-61-cron-missed.test.ts
- issue-63-disable-stall-config.test.ts
- issue-64-job-lost-on-markactive-failure.test.ts
- issue-64-wal-checkpoint.test.ts
- issue-65-skipIfNoWorker.test.ts
- issue-65-skipMissedOnRestart.test.ts
- issue-65-sqlite-restart.test.ts
- issue-65-tcp-mode.test.ts
- issue-67-skipIfNoWorker-restart.test.ts
- issue-73-cron-disconnect-requeue.test.ts
- issue-73-cron-overlap.test.ts
- issue-73-cron-restart-immediate.test.ts
- issue-73-cron-starts-immediately.test.ts
- issue-77-prefix-key.test.ts
- issue-82-moveToFailed.test.ts
- issue-83-jobstate-after-restart.test.ts
- issue-85-config-import-side-effect.test.ts
- issue-86-cron-job-options.test.ts
- issue-88-job-options-reflection.test.ts
- issue-90-option-forwarding.test.ts
- issue-92-counts-lists.test.ts
- issue-93-bun-only.test.ts
- issue-94-halfopen-reconnect.test.ts
- issue-95-http-jobs-list-status-filter.test.ts
- issue-ci-sqlite-pragma-ioerr.test.ts
- issue29-sandboxed-log.test.ts
- issue30-dlq-stall.test.ts
- issue31-parent-result.test.ts
- issue32-worker-stall.test.ts
- issue33-duplicate-execution.test.ts
- issue34-parent-result-missing.test.ts
- issue38-sandboxed-processor-cleanup.test.ts
- issue39-sandboxed-graceful-stop.test.ts
- issue41-sandboxed-idle-ram.test.ts
- issue43-flow-shutdown.test.ts
- issue53-worker-log-event.test.ts
- issue55-get-jobs-multi-state.test.ts
- issue56-job-counts-delayed-paused.test.ts
- issue96-concurrency-race.test.ts
- issue98-overpull-lease-race.test.ts
- job-cancellation.test.ts
- job-lifecycle-events.test.ts
- job-list-benchmark-lifecycle.test.ts
- job-management-operations.test.ts
- job-name-data-separation.test.ts
- job-removal-cleanup.test.ts
- job-timeout-scheduler.test.ts
- jobAdvancedMethods.test.ts
- jobDependencies.test.ts
- jobLogsManager.test.ts
- jobManagement.test.ts
- jobMoveMethods.test.ts
- jobOptionsBullMQv5.test.ts
- jobParser.test.ts
- jobProperties.test.ts
- jobProxy.test.ts
- latencyTracker.test.ts
- legacy-dlq-name-migration.test.ts
- lifo-queue.test.ts
- limiterManager.test.ts
- lock-fairness.test.ts
- lock-race-conditions.test.ts
- lock-token-enforcement.test.ts
- lock.test.ts
- lockExpiration.test.ts
- lockManager.test.ts
- logger.test.ts
- long-running-timeout.test.ts
- lru.test.ts
- mcp-edge-cases.test.ts
- mcp-handler-e2e.ts
- mcp-handlers.test.ts
- mcp-http-handler.test.ts
- mcp-name-data-separation.test.ts
- mcp-tcp-issue87.test.ts
- mcp.test.ts
- metricsExporter.test.ts
- minHeap.test.ts
- missing-tcp-commands.test.ts
- mixed-lifo-order.test.ts
- model-broker-port-isolation.test.ts
- movetowait-semantics.test.ts
- native-benchmark-integrity.test.ts
- obliterate-clears-completed.test.ts
- package-consumer-smoke.test.ts
- parent-option-linking.test.ts
- parent-option-restart.test.ts
- pause-resume-patterns.test.ts
- perf-flow-sequential.test.ts
- perf-rate-limiter.test.ts
- perQueueMetrics.test.ts
- preload.ts
- priority-counts.test.ts
- priority-delayed.test.ts
- priorityQueue.test.ts
- production-backpressure-torture.test.ts
- production-readiness-e2e.test.ts
- protocol-reqid.test.ts
- protocol.test.ts
- pull-abort-invariants.test.ts
- pull-operations.test.ts
- push-operations.test.ts
- queue-counts-bugs.test.ts
- queue-counts-scheduler.test.ts
- queue-group-advanced.test.ts
- queue-group-flow.test.ts
- queue-metrics-journal.test.ts
- queueControl.test.ts
- queueEvents.test.ts
- queueManager.test.ts
- race-conditions.test.ts
- rate-limiting-tcp.test.ts
- ratelimit-window-ttl-edge.test.ts
- rateLimiter.test.ts
- recoveryLogic.test.ts
- repro-audit-critical-dataloss.test.ts
- repro-batch-lock-contention.test.ts
- repro-bunqueue-sync-throw-cancellation.test.ts
- repro-chaos-crash-recovery.test.ts
- repro-chaos-fault-injection.test.ts
- repro-chaos-soak.test.ts
- repro-ci-dynamic-port.test.ts
- repro-ci-workflow-manager-order.test.ts
- repro-cli-audit2.test.ts
- repro-cli-audit3.test.ts
- repro-cli-invariant-help-router.test.ts
- repro-cli-invariant-interrupted-pull.test.ts
- repro-cli-stats-uptime.test.ts
- repro-client-lifecycle-ownership.test.ts
- repro-clock-jump.test.ts
- repro-cloud-s3-backup-command.test.ts
- repro-cron-long-timeout-overflow.test.ts
- repro-cron-skip-consumes-limit.test.ts
- repro-custom-id-false-null.test.ts
- repro-dedup-replace-embedded.test.ts
- repro-dedup-replace-resources.test.ts
- repro-defect-getjobcounts-tcp-zero.test.ts
- repro-defect-late-dependent-gate-rejected.test.ts
- repro-defect-stale-ack-timeout-resurrection.test.ts
- repro-dependency-completion-migration.test.ts
- repro-dependency-completion-pinning.test.ts
- repro-dependency-completion-retention.test.ts
- repro-disk-full.test.ts
- repro-dlq-auto-retry-state.test.ts
- repro-durability-gaps.test.ts
- repro-durable-persistence-rejection.test.ts
- repro-embedded-close-hangs.test.ts
- repro-embedded-manager-leak-order.test.ts
- repro-enterprise-telemetry.test.ts
- repro-flow-producer-api-parity.test.ts
- repro-flow-producer-boundaries.test.ts
- repro-flow-producer-production-safety.test.ts
- repro-flow-producer-recovery.test.ts
- repro-flow-result-cache-pressure.test.ts
- repro-fuzz-protocol.test.ts
- repro-getjob-false-null-during-pull.test.ts
- repro-getjobs-order-pagination.test.ts
- repro-getmetrics-tcp.test.ts
- repro-group-head-of-line.test.ts
- repro-idem-active-readd.test.ts
- repro-issue100-queue-state-persistence.test.ts
- repro-issue101-lost-ack-lock-expiry.test.ts
- repro-issue104-getjobs-finishedon.test.ts
- repro-issue110-lock-expiry-dlq-persist.test.ts
- repro-issue113-worker-poll-timer-leak.test.ts
- repro-issue74-exact-scenario.test.ts
- repro-issue74-movetofailed-stacktrace.test.ts
- repro-issue74-stacktrace-persistence.test.ts
- repro-issue74-stacktrace-regression.test.ts
- repro-issue97-retry-lock-expiry-unique.test.ts
- repro-job-scheduler-upsert-result.test.ts
- repro-longrunning-semantics.test.ts
- repro-mcp-cron-serialization-parity.test.ts
- repro-model-ack-batch-envelope.test.ts
- repro-model-broker-startup-port-race.test.ts
- repro-model-child-recovered-alone.test.ts
- repro-model-crash-attempt-bound.test.ts
- repro-model-flow-batch-parent-persistence.test.ts
- repro-model-job-heartbeat-batch-envelope.test.ts
- repro-model-move-delayed-lock-cleanup.test.ts
- repro-model-move-to-wait-persistence.test.ts
- repro-model-obliterate-dependency-cleanup.test.ts
- repro-model-prioritized-flow-recovery.test.ts
- repro-model-priority-persistence.test.ts
- repro-model-purge-dlq-index-cleanup.test.ts
- repro-model-repeated-crash-stall-bound.test.ts
- repro-model-retry-completed-persistence.test.ts
- repro-model-terminal-id-dlq-replacement.test.ts
- repro-model-ttl-expiry-persistence.test.ts
- repro-model-update-data-persistence.test.ts
- repro-model-workflow-timeout-reason.test.ts
- repro-monitoring-production.test.ts
- repro-movetodelayed-tcp.test.ts
- repro-option-drop-class.test.ts
- repro-persisted-mutation-contracts.test.ts
- repro-protocol-rate-limit-correlation.test.ts
- repro-publish-build-cron-type.test.ts
- repro-pull-batch-single-parking.test.ts
- repro-queues-summary-prioritized.test.ts
- repro-race-concurrency.test.ts
- repro-ratelimit-duration-ttl.test.ts
- repro-release-sdk-gate.test.ts
- repro-removeasync-floating-cancel.test.ts
- repro-retention-boundary-invariants.test.ts
- repro-runtime-mode-parity.test.ts
- repro-s3-backup-config.test.ts
- repro-s3-backup-production.test.ts
- repro-sdk-flow-late-failure-options.test.ts
- repro-sdk-flow-late-parent-link.test.ts
- repro-slot-release-claim-paths.test.ts
- repro-sqlite-migration-failure.test.ts
- repro-sqlite-recovery-offset.test.ts
- repro-sse-broadcast-noclients.test.ts
- repro-stability-addbulk-ignores-durable.test.ts
- repro-stability-concurrency-leak-lock-expiry.test.ts
- repro-stability-movetowaitingchildren-strands.test.ts
- repro-stability-perqueuemetrics-unbounded.test.ts
- repro-stability-pool-pull-ownership-double-exec.test.ts
- repro-stability-removeoncomplete-dependency-orphan.test.ts
- repro-stability-undefined-result-dependency-recovery.test.ts
- repro-stability-worker-close-group-limiter-hang.test.ts
- repro-stability-worker-no-reregister-after-reconnect.test.ts
- repro-stale-dependency-gc.test.ts
- repro-startup-banner-positioning.test.ts
- repro-stress-degradation.test.ts
- repro-tcp-server-shutdown-lifecycle.test.ts
- repro-temporal-onsquared.test.ts
- repro-terminal-lock-stalled-event.test.ts
- repro-timeout-dlq-reason.test.ts
- repro-timeout-late-worker-outcome.test.ts
- repro-timer-lifecycle-idempotency.test.ts
- repro-upgrade-restart.test.ts
- repro-waiter-notification-debt.test.ts
- repro-webhook-ssrf-mapped.test.ts
- repro-worker-pause-resume-lifecycle.test.ts
- repro-workflow-abandon-vanished.test.ts
- repro-workflow-abandoned-child-resurrection.test.ts
- repro-workflow-api-hardening.test.ts
- repro-workflow-archive-boundary.test.ts
- repro-workflow-child-park-inherit.test.ts
- repro-workflow-compensation-close-recover.test.ts
- repro-workflow-durability-gaps.test.ts
- repro-workflow-foreach-non-array.test.ts
- repro-workflow-gate-and-schema.test.ts
- repro-workflow-guide-claims.test.ts
- repro-workflow-loop-failed-iteration.test.ts
- repro-workflow-nested-and-settled.test.ts
- repro-workflow-operator-signal.test.ts
- repro-workflow-orphan-child.test.ts
- repro-workflow-production-safety.test.ts
- repro-workflow-proto-gate-signal.test.ts
- repro-workflow-prototype-gate.test.ts
- repro-workflow-recover-double-compensate.test.ts
- repro-workflow-resume-replay.test.ts
- repro-workflow-retry-zero.test.ts
- repro-workflow-saga-gaps.test.ts
- repro-workflow-signal-double.test.ts
- repro-workflow-signal-lost-update.test.ts
- repro-workflow-signal-no-payload.test.ts
- repro-workflow-skeptic-blockers.test.ts
- repro-workflow-step-error-masking.test.ts
- repro-workflow-step-rename.test.ts
- repro-workflow-timeout-overflow.test.ts
- repro-workflow-unresolved-failure.test.ts
- repro-workflow-unwind-write-failure.test.ts
- retry-completed.test.ts
- retry-contract.test.ts
- retry-resilience.test.ts
- retryBackoff.test.ts
- s3-backup-concurrent.test.ts
- s3Backup-bugs.test.ts
- s3Backup-bugs2.test.ts
- s3Backup-critical.test.ts
- s3Backup.test.ts
- sandboxed-worker-advanced.test.ts
- sandboxed-worker-flow.test.ts
- sandboxedWorker.test.ts
- sandboxedWorkerIssue24.test.ts
- scheduler-generic.test.ts
- sdk-ci-workflow.test.ts
- sdk-env-token.test.ts
- sdk-mutation-workflow.test.ts
- semaphore.test.ts
- serialization.test.ts
- server-handlers-advanced.test.ts
- server-handlers-core.test.ts
- server-handlers-extended.test.ts
- server-pipelining.test.ts
- server-transport.test.ts
- shard.test.ts
- skipList.test.ts
- socket-write-queue.test.ts
- source-architecture.test.ts
- sqlite-cron-job-name-persistence.test.ts
- sqlite-dedup-replacement.test.ts
- sqlite-indexes.test.ts
- sqlite-job-name-persistence.test.ts
- sqlite-serializer.test.ts
- sqlite.test.ts
- stability.test.ts
- stall-count-persistence.test.ts
- stall-embedded-bug.test.ts
- stallDetection-unit.test.ts
- stallDetection.test.ts
- startup-shutdown.test.ts
- statsManager.test.ts
- stress-advanced.test.ts
- stress-benchmark-math.test.ts
- stress.test.ts
- tcp-benchmark-config.test.ts
- tcp-client-closed-error-filter.test.ts
- tcp-client-explicit-close.test.ts
- tcp-contract-audit.test.ts
- tcp-new-commands.test.ts
- tcp-process-sweep-integrity.test.ts
- telemetry-e2e.test.ts
- temporalManager.test.ts
- test-sandbox-telemetry.test.ts
- throughputTracker.test.ts
- timeout-ack-handler-tracking.test.ts
- timeout-failure-authority.test.ts
- timeout-outcome-authority.test.ts
- tls.test.ts
- ttlExpiration.test.ts
- uncaught-exception-handler.test.ts
- uniqueKeyManager.test.ts
- validation.test.ts
- vercel-config.test.ts
- webhook-ssrf.test.ts
- webhookDelivery.test.ts
- webhookManager.test.ts
- wired-job-methods-embedded.test.ts
- worker-active-mutation-token.test.ts
- worker-api-enhancements.test.ts
- worker-manual-lease-token.test.ts
- worker-processing-generation.test.ts
- worker-processor.test.ts
- worker-rate-limiter-admission.test.ts
- worker-registration-bugs.test.ts
- worker-scaling.test.ts
- workerAdvancedMethods.test.ts
- workerEnhancements.test.ts
- workerManager-cleanup.test.ts
- workerManager.test.ts
- workerManualMethods.test.ts
- workflow-agent-sdks.test.ts
- workflow-ai-sdk-agent.test.ts
- workflow-defensive-branches.test.ts
- workflow-docs-examples.test.ts
- workflow-dst.test.ts
- workflow-e2e-crash-recovery.test.ts
- workflow-e2e-production.test.ts
- workflow-e2e-tenant-provisioning.test.ts
- workflow-engine.test.ts
- workflow-issues.test.ts
- workflow-loops.test.ts
- workflow-nested-saga.test.ts
- workflow-new-features.test.ts
- workflow-properties.test.ts
- workflow-realistic.test.ts
- workflow-recovery.test.ts
- workflow-saga-extreme.test.ts
- workflow-saga-invariants.test.ts
- workflow-typesafe.test.ts
- workflowTestUtils.ts
.dockerignore
.env.example
.gitignore
.mcp.json
.npmignore
AGENTS.md
biome.json
bunfig.toml
CHANGELOG.md
CLAUDE.md
docker-compose.yml
Dockerfile
Dockerfile.sdk-test
Dockerfile.sdk-test.dockerignore
Dockerfile.test
Dockerfile.test.dockerignore
LICENSE
MIGRATION_FROM_BULLMQ.md
package.json
README.md
tsconfig.build.json
tsconfig.json
tsconfig.test.json
typedoc.json

# 설치 가이드

1. 코드 내려받기

git clone https://github.com/egeominotti/bunqueue

깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.

cd bunqueue

방금 내려받은 프로젝트 폴더 안으로 이동합니다.

2. Docker

쉬움 추천

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Docker Desktop 컨테이너를 빌드하고 실행하려면 필요합니다. 설치 후 실행해서 백그라운드에 켜두세요.

docker run -d -p 6789:6789 -p 6790:6790 \

빌드된 이미지를 실제 컨테이너로 실행합니다.

✅ 터미널에 docker compose ps 를 입력해 컨테이너들이 Up 상태인지 확인하세요. README에 포트 번호가 적혀있다면 브라우저에서 http://localhost:포트번호 로 접속해보세요.

이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.

3. Node.js

쉬움

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Node.js npm 명령어를 쓰려면 Node.js가 설치되어 있어야 합니다. LTS(장기지원) 버전을 추천합니다.

npm install bunqueue-client # Node.js ≥ 20, Deno ≥ 2, Bun, Cloudflare Workers

package.json에 명시된 라이브러리들을 내려받아 설치합니다.

✅ 명령어 실행 후 터미널에 나타나는 주소(보통 http://localhost:3000 형태)를 브라우저에서 열어보세요.

이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.

4. Python

쉬움

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Python 3 설치 시 'Add Python to PATH' 옵션을 꼭 체크하세요 (Windows).

⚠️ 이 프로젝트는 규모가 큰 저장소라, 이 방법이 실제 핵심 제품이 아니라 내부 하위 패키지를 가리키는 것일 수 있습니다. README 전체를 함께 확인해보세요.

pip install .

PyPI에 배포된 패키지를 바로 설치합니다. 소스 클론이 필요 없습니다.

python <실행할 파일명>.py # README에서 정확한 실행 파일명을 확인하세요

파이썬 스크립트(또는 모듈)를 실행합니다.

✅ 에러 메시지 없이 실행되고 터미널에 안내 문구가 출력되면 정상입니다.

5. PHP (Composer)

쉬움

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
PHP PHP 실행 환경이 필요합니다.
Composer PHP 라이브러리 설치를 위한 패키지 매니저입니다.

cd sdk/php

이 프로젝트의 관련 파일이 하위 폴더 안에 있어서, 먼저 그 폴더로 이동합니다.

composer install

composer.json에 명시된 PHP 라이브러리를 설치합니다.

✅ php -S localhost:8000 같은 내장 서버로 실행한 뒤 브라우저에서 http://localhost:8000 으로 접속해보세요.

6. Go

보통

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Go Go 언어 컴파일러 및 도구 모음입니다.

cd sdk/conformance/drivers/go

이 프로젝트의 관련 파일이 하위 폴더 안에 있어서, 먼저 그 폴더로 이동합니다.

go build ./...

Go 프로그램을 컴파일해 실행 파일을 만듭니다.

go run .

따로 빌드하지 않고 바로 Go 프로그램을 실행합니다.

✅ 빌드가 에러 없이 끝나면 성공입니다. go run . 을 썼다면 터미널 출력을 확인하세요.

7. Rust

보통

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Rust (rustup) rustup으로 설치하면 cargo도 함께 설치됩니다.

cd sdk/rust

이 프로젝트의 관련 파일이 하위 폴더 안에 있어서, 먼저 그 폴더로 이동합니다.

cargo build --release

Rust 프로젝트를 컴파일합니다.

cargo run

빌드 후 바로 실행까지 진행합니다.

✅ cargo build가 에러 없이 끝나면 성공입니다. target/ 폴더에 실행 파일이 생성됩니다.

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

bunqueue

파일 탐색기

# 설치 가이드

2. Docker

3. Node.js

4. Python

5. PHP (Composer)

6. Go

7. Rust

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

bunqueue

파일 탐색기

# 설치 가이드

2. Docker

3. Node.js

4. Python

5. PHP (Composer)

6. Go

7. Rust

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README