Skip to content

Commit

Permalink
change(core): requestMany() JitterTimer and its associated jitter p…
Browse files Browse the repository at this point in the history 
…roperty is now called "stall"

change(core): requestMany() `RequestStrategy` is now a simple string "timer" | "count" | "stall" | "sentinel"

Signed-off-by: Alberto Ricart <[email protected]>
  • Loading branch information
@aricart
aricart committed Nov 21, 2024
1 parent f8f29e2 commit 426e5d8
Show file tree
Hide file tree
Showing 22 changed files with 62 additions and 73 deletions.
4 changes: 2 additions & 2 deletions core/deno.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/nats-core",
"version": "3.0.0-44",
"version": "3.0.0-45",
"exports": {
".": "./src/mod.ts",
"./internal": "./src/internal_mod.ts"
Expand Down Expand Up @@ -38,4 +38,4 @@
"@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2",
"@nats-io/nuid": "jsr:@nats-io/[email protected]"
}
}
}
4 changes: 2 additions & 2 deletions core/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/nats-core",
"version": "3.0.0-44",
"version": "3.0.0-45",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -43,4 +43,4 @@
"typedoc": "^0.26.10",
"typescript": "^5.5.4"
}
}
}
2 changes: 1 addition & 1 deletion core/src/version.ts
View file
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
// This file is generated - do not edit
export const version = "3.0.0-44";
export const version = "3.0.0-45";
3 changes: 1 addition & 2 deletions deno.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,5 @@
"./kv",
"./obj",
"./services"
],
"nodeModulesDir": "auto"
]
}
6 changes: 3 additions & 3 deletions jetstream/deno.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/jetstream",
"version": "3.0.0-31",
"version": "3.0.0-32",
"exports": {
".": "./src/mod.ts",
"./internal": "./src/internal_mod.ts"
Expand Down Expand Up @@ -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-44"
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45"
}
}
}
6 changes: 3 additions & 3 deletions jetstream/import_map.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@
"imports": {
"@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2",
"@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2",
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal",
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/internal",
"test_helpers": "../test_helpers/mod.ts",
"@std/io": "jsr:@std/[email protected]"
}
}
}
6 changes: 3 additions & 3 deletions jetstream/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/jetstream",
"version": "3.0.0-31",
"version": "3.0.0-32",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -34,12 +34,12 @@
},
"description": "jetstream library - this library implements all the base functionality for NATS JetStream for javascript clients",
"dependencies": {
"@nats-io/nats-core": "3.0.0-44"
"@nats-io/nats-core": "3.0.0-45"
},
"devDependencies": {
"@types/node": "^22.7.6",
"shx": "^0.3.4",
"typedoc": "^0.26.10",
"typescript": "^5.6.3"
}
}
}
8 changes: 4 additions & 4 deletions kv/deno.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/kv",
"version": "3.0.0-25",
"version": "3.0.0-26",
"exports": {
".": "./src/mod.ts",
"./internal": "./src/internal_mod.ts"
Expand Down Expand Up @@ -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-44",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31"
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32"
}
}
}
10 changes: 5 additions & 5 deletions kv/import_map.json
View file
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
{
"imports": {
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31",
"@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-31/internal",
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/internal",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32",
"@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-32/internal",
"test_helpers": "../test_helpers/mod.ts",
"@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2",
"@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2",
"@std/io": "jsr:@std/[email protected]"
}
}
}
8 changes: 4 additions & 4 deletions kv/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/kv",
"version": "3.0.0-25",
"version": "3.0.0-26",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -34,13 +34,13 @@
},
"description": "kv library - this library implements all the base functionality for NATS KV javascript clients",
"dependencies": {
"@nats-io/jetstream": "3.0.0-31",
"@nats-io/nats-core": "3.0.0-44"
"@nats-io/jetstream": "3.0.0-32",
"@nats-io/nats-core": "3.0.0-45"
},
"devDependencies": {
"@types/node": "^22.7.6",
"shx": "^0.3.4",
"typedoc": "^0.26.10",
"typescript": "^5.6.3"
}
}
}
8 changes: 4 additions & 4 deletions obj/deno.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/obj",
"version": "3.0.0-26",
"version": "3.0.0-27",
"exports": {
".": "./src/mod.ts",
"./internal": "./src/internal_mod.ts"
Expand Down Expand Up @@ -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-44",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31"
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32"
}
}
}
10 changes: 5 additions & 5 deletions obj/import_map.json
View file
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
{
"imports": {
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31",
"@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-31/internal",
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/internal",
"@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32",
"@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-32/internal",
"test_helpers": "../test_helpers/mod.ts",
"@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2",
"@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2",
"@std/io": "jsr:@std/[email protected]"
}
}
}
8 changes: 4 additions & 4 deletions obj/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/obj",
"version": "3.0.0-26",
"version": "3.0.0-27",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -34,13 +34,13 @@
},
"description": "obj library - this library implements all the base functionality for NATS objectstore for javascript clients",
"dependencies": {
"@nats-io/jetstream": "3.0.0-31",
"@nats-io/nats-core": "3.0.0-44"
"@nats-io/jetstream": "3.0.0-32",
"@nats-io/nats-core": "3.0.0-45"
},
"devDependencies": {
"@types/node": "^22.7.6",
"shx": "^0.3.4",
"typedoc": "^0.26.10",
"typescript": "^5.6.3"
}
}
}
10 changes: 0 additions & 10 deletions package.json
View file

This file was deleted.

6 changes: 3 additions & 3 deletions services/deno.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/services",
"version": "3.0.0-19",
"version": "3.0.0-20",
"exports": {
".": "./src/mod.ts",
"./internal": "./src/internal_mod.ts"
Expand Down Expand Up @@ -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-44"
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45"
}
}
}
6 changes: 3 additions & 3 deletions services/import_map.json
View file
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
{
"imports": {
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal",
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45",
"@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/internal",
"test_helpers": "../test_helpers/mod.ts",
"@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2",
"@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2",
"@std/io": "jsr:@std/[email protected]"
}
}
}
6 changes: 3 additions & 3 deletions services/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/services",
"version": "3.0.0-19",
"version": "3.0.0-20",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -34,12 +34,12 @@
},
"description": "services library - this library implements all the base functionality for NATS services for javascript clients",
"dependencies": {
"@nats-io/nats-core": "3.0.0-44"
"@nats-io/nats-core": "3.0.0-45"
},
"devDependencies": {
"@types/node": "^22.7.6",
"shx": "^0.3.4",
"typedoc": "^0.26.10",
"typescript": "^5.6.3"
}
}
}
4 changes: 2 additions & 2 deletions transport-deno/deno.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/transport-deno",
"version": "3.0.0-17",
"version": "3.0.0-18",
"exports": {
".": "./src/mod.ts"
},
Expand All @@ -20,7 +20,7 @@
},
"imports": {
"@std/io": "jsr:@std/[email protected]",
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44",
"@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45",
"@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2",
"@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2"
}
Expand Down
2 changes: 1 addition & 1 deletion transport-deno/src/version.ts
View file
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
// This file is generated - do not edit
export const version = "3.0.0-17";
export const version = "3.0.0-18";
4 changes: 2 additions & 2 deletions transport-node/package-lock.json
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

12 changes: 6 additions & 6 deletions transport-node/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/transport-node",
"version": "3.0.0-28",
"version": "3.0.0-30",
"description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system",
"keywords": [
"nats",
Expand Down Expand Up @@ -54,7 +54,7 @@
"node": ">= 18.0.0"
},
"dependencies": {
"@nats-io/nats-core": "3.0.0-44",
"@nats-io/nats-core": "3.0.0-45",
"@nats-io/nkeys": "2.0.0-2",
"@nats-io/nuid": "2.0.1-2"
},
Expand All @@ -64,8 +64,8 @@
"nats-jwt": "^0.0.9",
"shx": "^0.3.3",
"typescript": "5.6.3",
"@nats-io/jetstream": "3.0.0-31",
"@nats-io/kv": "3.0.0-25",
"@nats-io/obj": "3.0.0-26"
"@nats-io/jetstream": "3.0.0-32",
"@nats-io/kv": "3.0.0-26",
"@nats-io/obj": "3.0.0-27"
}
}
}
2 changes: 1 addition & 1 deletion transport-node/src/version.ts
View file
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
// This file is generated - do not edit
export const version = "3.0.0-28";
export const version = "3.0.0-30";

0 comments on commit 426e5d8

Please sign in to comment.