@fluojs/queue - npm Package Compare versions

Comparing version

1.0.0

1.0.1

+1

-1

dist/decorators.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"decorators.d.ts","sourceRoot":"","sources":["../src/decorators.ts"],"names":[],"mappings":"AAGA,OAAO,KAAK,EAAE,YAAY,EAAuB,kBAAkB,EAAE,MAAM,YAAY,CAAC;AAExF,KAAK,kBAAkB,GAAG,CAAC,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,qBAAqB,KAAK,IAAI,CAAC;AAiBpF;;;;;;;;;;;;;;;;;;;;;;GAsBG;AACH,wBAAgB,WAAW,CAAC,OAAO,EAAE,YAAY,EAAE,OAAO,GAAE,kBAAuB,GAAG,kBAAkB,CAWvG"}
		{"version":3,"file":"decorators.d.ts","sourceRoot":"","sources":["../src/decorators.ts"],"names":[],"mappings":"AAGA,OAAO,KAAK,EAAE,YAAY,EAAuB,kBAAkB,EAAE,MAAM,YAAY,CAAC;AAExF,KAAK,kBAAkB,GAAG,CAAC,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,qBAAqB,KAAK,IAAI,CAAC;AAepF;;;;;;;;;;;;;;;;;;;;;;GAsBG;AACH,wBAAgB,WAAW,CAAC,OAAO,EAAE,YAAY,EAAE,OAAO,GAAE,kBAAuB,GAAG,kBAAkB,CAavG"}

+1

-1

dist/decorators.js

		import { ensureMetadataSymbol } from '@fluojs/core/internal';
		import { queueWorkerMetadataSymbol } from './metadata.js';
		ensureMetadataSymbol();
		function getStandardMetadataBag(metadata) {
		@@ -42,2 +41,3 @@ return metadata;
		const decorator = (_value, context) => {
		ensureMetadataSymbol();
		const metadata = {
		@@ -44,0 +44,0 @@ jobType,

+5

-5

package.json

		@@ -13,3 +13,3 @@ {
		],
		"version": "1.0.0",
		"version": "1.0.1",
		"private": false,
		@@ -42,6 +42,6 @@ "license": "MIT",
		"bullmq": "^5.58.0",
		"@fluojs/core": "^1.0.0",
		"@fluojs/redis": "^1.0.0",
		"@fluojs/runtime": "^1.0.0",
		"@fluojs/di": "^1.0.0"
		"@fluojs/core": "^1.0.3",
		"@fluojs/di": "^1.0.3",
		"@fluojs/redis": "^1.0.1",
		"@fluojs/runtime": "^1.1.2"
		},
		@@ -48,0 +48,0 @@ "devDependencies": {

+9

-1

README.ko.md

		@@ -132,5 +132,12 @@ # @fluojs/queue
		### 타입
		- `QueueModuleOptions`: 전역 큐 설정(clientName, 기본 시도 횟수, `defaultBackoff`, 동시성, 전송률 제한, dead-letter retention 등)을 위한 타입입니다.
		- `Queue`: 애플리케이션 코드와 `QUEUE` 토큰에서 사용하는 `enqueue(job)` 호환성 facade입니다.
		- `QueueJobType`: job payload class를 식별하고 rehydrate하는 데 사용하는 constructor 타입입니다.
		- `QueueModuleOptions`: 전역 큐 설정(`global`, clientName, 기본 시도 횟수, `defaultBackoff`, 동시성, 전송률 제한, dead-letter retention 등)을 위한 타입입니다.
		- `QueueWorkerOptions`: 개별 작업 설정(시도 횟수, 백오프, 동시성, jobName, 전송률 제한 등)을 위한 타입입니다.
		- `QueueBackoffType`: 지원되는 retry backoff strategy 이름(`fixed`, `exponential`)입니다.
		- `QueueBackoffOptions`: 재시도 백오프 설정(`type`, `delayMs`)을 위한 타입입니다.
		- `QueueRateLimiterOptions`: worker 수준 distributed rate limiter 설정(`max`, `duration`)을 위한 타입입니다.
		- `QueueLifecycleState`: Queue status adapter가 보고하는 lifecycle state(`idle`, `starting`, `started`, `stopping`, `stopped`)입니다.
		- `QueueStatusAdapterInput`: `createQueuePlatformStatusSnapshot(...)`에 전달하는 normalized queue metrics 타입입니다.
		- `QueuePlatformStatusSnapshot`: status helper가 반환하는 Queue 전용 readiness, health, ownership, detail snapshot 타입입니다.

		@@ -141,2 +148,3 @@ `QueueModuleOptions`에는 `workerShutdownTimeoutMs`, `defaultDeadLetterMaxEntries` 같은 lifecycle 및 dead-letter retention 설정도 포함됩니다.

		- `global`: queue module 등록을 global로 만들지 여부입니다. 기본값은 `true`이며, queue provider를 importing module graph 안에만 scope하고 싶으면 `false`를 지정합니다.
		- `workerShutdownTimeoutMs`: 종료 중 active worker processor를 기다리는 최대 시간입니다. 시간이 지나면 BullMQ worker를 force-close합니다. 기본값은 `30_000`입니다.
		@@ -143,0 +151,0 @@ - `defaultDeadLetterMaxEntries`: job별로 유지할 dead-letter record의 최대 개수이며, trimming을 끄려면 `false`를 지정합니다. 기본값은 `1_000`입니다.

+9

-1

README.md

		@@ -132,5 +132,12 @@ # @fluojs/queue
		### Types
		- `QueueModuleOptions`: Global queue settings (clientName, default attempts, `defaultBackoff`, concurrency, rate limiting, dead-letter retention).
		- `Queue`: Compatibility facade with `enqueue(job)` for application code and the `QUEUE` token.
		- `QueueJobType`: Constructor type used to identify and rehydrate a job payload class.
		- `QueueModuleOptions`: Global queue settings (`global`, clientName, default attempts, `defaultBackoff`, concurrency, rate limiting, dead-letter retention).
		- `QueueWorkerOptions`: Per-job settings (attempts, backoff, concurrency, jobName, rate limiting).
		- `QueueBackoffType`: Supported retry backoff strategy names (`fixed`, `exponential`).
		- `QueueBackoffOptions`: Retry backoff settings (`type`, `delayMs`).
		- `QueueRateLimiterOptions`: Worker-level distributed rate limiter settings (`max`, `duration`).
		- `QueueLifecycleState`: Lifecycle states reported by Queue status adapters (`idle`, `starting`, `started`, `stopping`, `stopped`).
		- `QueueStatusAdapterInput`: Normalized queue metrics passed to `createQueuePlatformStatusSnapshot(...)`.
		- `QueuePlatformStatusSnapshot`: Queue-specific readiness, health, ownership, and detail snapshot returned by the status helper.

		@@ -141,2 +148,3 @@ `QueueModuleOptions` also includes lifecycle and dead-letter retention controls such as `workerShutdownTimeoutMs` and `defaultDeadLetterMaxEntries`.

		- `global`: whether the queue module registration is global. Defaults to `true`; set `false` when queue providers should stay scoped to the importing module graph.
		- `workerShutdownTimeoutMs`: maximum time to wait for active worker processors during shutdown before force-closing the BullMQ worker. Defaults to `30_000`.
		@@ -143,0 +151,0 @@ - `defaultDeadLetterMaxEntries`: maximum retained dead-letter records per job, or `false` to disable trimming. Defaults to `1_000`.

@fluojs/queue - npm Package Compare versions

Improved metrics

Dependency changes