From a63fe19e7d92da7bec0a04f8cc6d6501b83832c8 Mon Sep 17 00:00:00 2001 From: Alberto Ricart Date: Fri, 8 Nov 2024 11:06:36 -0500 Subject: [PATCH] added priority group version feature (#120) Signed-off-by: Alberto Ricart --- core/deno.json | 2 +- core/package.json | 2 +- core/src/semver.ts | 2 ++ core/src/version.ts | 2 +- jetstream/deno.json | 4 ++-- jetstream/import_map.json | 4 ++-- jetstream/package.json | 4 ++-- kv/deno.json | 6 +++--- kv/import_map.json | 8 ++++---- kv/package.json | 6 +++--- obj/deno.json | 6 +++--- obj/import_map.json | 8 ++++---- obj/package.json | 6 +++--- services/deno.json | 4 ++-- services/import_map.json | 4 ++-- services/package.json | 4 ++-- transport-deno/deno.json | 4 ++-- transport-deno/src/version.ts | 2 +- transport-node/package.json | 10 +++++----- transport-node/src/version.ts | 2 +- 20 files changed, 46 insertions(+), 44 deletions(-) diff --git a/core/deno.json b/core/deno.json index b2bf9f59..0f77f453 100644 --- a/core/deno.json +++ b/core/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-35", + "version": "3.0.0-36", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" diff --git a/core/package.json b/core/package.json index c98422c8..b2dc09ec 100644 --- a/core/package.json +++ b/core/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-35", + "version": "3.0.0-36", "files": [ "lib/", "LICENSE", diff --git a/core/src/semver.ts b/core/src/semver.ts index 8bb95280..99ebc56c 100644 --- a/core/src/semver.ts +++ b/core/src/semver.ts @@ -53,6 +53,7 @@ export enum Feature { JS_STREAM_COMPRESSION = "js_stream_compression", JS_DEFAULT_CONSUMER_LIMITS = "js_default_consumer_limits", JS_BATCH_DIRECT_GET = "js_batch_direct_get", + JS_PRIORITY_GROUPS = "js_priority_groups", } type FeatureVersion = { @@ -111,6 +112,7 @@ export class Features { this.set(Feature.JS_STREAM_COMPRESSION, "2.10.0"); this.set(Feature.JS_DEFAULT_CONSUMER_LIMITS, "2.10.0"); this.set(Feature.JS_BATCH_DIRECT_GET, "2.11.0"); + this.set(Feature.JS_PRIORITY_GROUPS, "2.12.0"); this.disabled.forEach((f) => { this.features.delete(f); diff --git a/core/src/version.ts b/core/src/version.ts index dd48dd97..66c637ea 100644 --- a/core/src/version.ts +++ b/core/src/version.ts @@ -1,2 +1,2 @@ // This file is generated - do not edit -export const version = "3.0.0-35"; +export const version = "3.0.0-36"; diff --git a/jetstream/deno.json b/jetstream/deno.json index 6c677a8b..743c2a31 100644 --- a/jetstream/deno.json +++ b/jetstream/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/jetstream", - "version": "3.0.0-23", + "version": "3.0.0-24", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" @@ -33,6 +33,6 @@ "test": "deno test -A --parallel --reload --trace-leaks --quiet tests/ --import-map=import_map.json" }, "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36" } } diff --git a/jetstream/import_map.json b/jetstream/import_map.json index 33ac3f28..43df1d00 100644 --- a/jetstream/import_map.json +++ b/jetstream/import_map.json @@ -2,8 +2,8 @@ "imports": { "@nats-io/nkeys": "jsr:@nats-io/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-35/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal", "test_helpers": "../test_helpers/mod.ts", "@std/io": "jsr:@std/io@0.224.0" } diff --git a/jetstream/package.json b/jetstream/package.json index ede82a3f..56c46f6e 100644 --- a/jetstream/package.json +++ b/jetstream/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/jetstream", - "version": "3.0.0-23", + "version": "3.0.0-24", "files": [ "lib/", "LICENSE", @@ -34,7 +34,7 @@ }, "description": "jetstream library - this library implements all the base functionality for NATS JetStream for javascript clients", "dependencies": { - "@nats-io/nats-core": "3.0.0-35" + "@nats-io/nats-core": "3.0.0-36" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/kv/deno.json b/kv/deno.json index 716599cd..ce9b60a0 100644 --- a/kv/deno.json +++ b/kv/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/kv", - "version": "3.0.0-17", + "version": "3.0.0-18", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" @@ -33,7 +33,7 @@ "test": "deno test -A --parallel --reload --quiet tests/ --import-map=import_map.json" }, "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-23" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-24" } } diff --git a/kv/import_map.json b/kv/import_map.json index a74f64ac..c4887e17 100644 --- a/kv/import_map.json +++ b/kv/import_map.json @@ -1,9 +1,9 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-35/internal", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-23", - "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-23/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-24", + "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-24/internal", "test_helpers": "../test_helpers/mod.ts", "@nats-io/nkeys": "jsr:@nats-io/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", diff --git a/kv/package.json b/kv/package.json index a40c7116..be68df2e 100644 --- a/kv/package.json +++ b/kv/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/kv", - "version": "3.0.0-17", + "version": "3.0.0-18", "files": [ "lib/", "LICENSE", @@ -34,8 +34,8 @@ }, "description": "kv library - this library implements all the base functionality for NATS KV javascript clients", "dependencies": { - "@nats-io/jetstream": "3.0.0-23", - "@nats-io/nats-core": "3.0.0-35" + "@nats-io/jetstream": "3.0.0-24", + "@nats-io/nats-core": "3.0.0-36" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/obj/deno.json b/obj/deno.json index 8613a5ca..3fe9cbc7 100644 --- a/obj/deno.json +++ b/obj/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/obj", - "version": "3.0.0-18", + "version": "3.0.0-19", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" @@ -33,7 +33,7 @@ "test": "deno test -A --parallel --reload --quiet tests/ --import-map=import_map.json" }, "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-23" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-24" } } diff --git a/obj/import_map.json b/obj/import_map.json index a74f64ac..c4887e17 100644 --- a/obj/import_map.json +++ b/obj/import_map.json @@ -1,9 +1,9 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-35/internal", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-23", - "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-23/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-24", + "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-24/internal", "test_helpers": "../test_helpers/mod.ts", "@nats-io/nkeys": "jsr:@nats-io/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", diff --git a/obj/package.json b/obj/package.json index 9d990f95..f8c6e522 100644 --- a/obj/package.json +++ b/obj/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/obj", - "version": "3.0.0-18", + "version": "3.0.0-19", "files": [ "lib/", "LICENSE", @@ -34,8 +34,8 @@ }, "description": "obj library - this library implements all the base functionality for NATS objectstore for javascript clients", "dependencies": { - "@nats-io/jetstream": "3.0.0-23", - "@nats-io/nats-core": "3.0.0-35" + "@nats-io/jetstream": "3.0.0-24", + "@nats-io/nats-core": "3.0.0-36" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/services/deno.json b/services/deno.json index 6ae63eba..2249c8b9 100644 --- a/services/deno.json +++ b/services/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/services", - "version": "3.0.0-13", + "version": "3.0.0-14", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" @@ -33,6 +33,6 @@ "test": "deno test -A --parallel --reload --quiet tests/ --import-map=import_map.json" }, "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36" } } diff --git a/services/import_map.json b/services/import_map.json index 6228967f..1b429bf9 100644 --- a/services/import_map.json +++ b/services/import_map.json @@ -1,7 +1,7 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-35/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal", "test_helpers": "../test_helpers/mod.ts", "@nats-io/nkeys": "jsr:@nats-io/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", diff --git a/services/package.json b/services/package.json index 1c43c744..2980122e 100644 --- a/services/package.json +++ b/services/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/services", - "version": "3.0.0-13", + "version": "3.0.0-14", "files": [ "lib/", "LICENSE", @@ -34,7 +34,7 @@ }, "description": "services library - this library implements all the base functionality for NATS services for javascript clients", "dependencies": { - "@nats-io/nats-core": "3.0.0-35" + "@nats-io/nats-core": "3.0.0-36" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/transport-deno/deno.json b/transport-deno/deno.json index 10907b61..612e3e33 100644 --- a/transport-deno/deno.json +++ b/transport-deno/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/transport-deno", - "version": "3.0.0-10", + "version": "3.0.0-11", "exports": { ".": "./src/mod.ts" }, @@ -20,7 +20,7 @@ }, "imports": { "@std/io": "jsr:@std/io@0.225.0", - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-35", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-36", "@nats-io/nkeys": "jsr:@nats-io/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2" } diff --git a/transport-deno/src/version.ts b/transport-deno/src/version.ts index 0cc26851..1bf965b2 100644 --- a/transport-deno/src/version.ts +++ b/transport-deno/src/version.ts @@ -1,2 +1,2 @@ // This file is generated - do not edit -export const version = "3.0.0-10"; +export const version = "3.0.0-11"; diff --git a/transport-node/package.json b/transport-node/package.json index dfec3ea5..83aed669 100644 --- a/transport-node/package.json +++ b/transport-node/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/transport-node", - "version": "3.0.0-21", + "version": "3.0.0-22", "description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system", "keywords": [ "nats", @@ -54,7 +54,7 @@ "node": ">= 18.0.0" }, "dependencies": { - "@nats-io/nats-core": "3.0.0-35", + "@nats-io/nats-core": "3.0.0-36", "@nats-io/nkeys": "1.2.0-7", "@nats-io/nuid": "2.0.1-2" }, @@ -64,8 +64,8 @@ "nats-jwt": "^0.0.9", "shx": "^0.3.3", "typescript": "5.6.3", - "@nats-io/jetstream": "3.0.0-23", - "@nats-io/kv": "3.0.0-17", - "@nats-io/obj": "3.0.0-18" + "@nats-io/jetstream": "3.0.0-24", + "@nats-io/kv": "3.0.0-18", + "@nats-io/obj": "3.0.0-19" } } diff --git a/transport-node/src/version.ts b/transport-node/src/version.ts index e7c5dc48..9d9e5a40 100644 --- a/transport-node/src/version.ts +++ b/transport-node/src/version.ts @@ -1,2 +1,2 @@ // This file is generated - do not edit -export const version = "3.0.0-21"; +export const version = "3.0.0-22";