diff --git a/Cargo.lock b/Cargo.lock index 2647a366..b719c791 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -19,7 +19,7 @@ checksum = "f26201604c87b1e01bd3d98f8d5d9a8fcbb815e8cedb41ffccbeb4bf593a35fe" [[package]] name = "agent_client" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-channel", "async-trait", @@ -182,7 +182,7 @@ dependencies = [ [[package]] name = "banking_common" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "deadpool", @@ -199,7 +199,7 @@ dependencies = [ [[package]] name = "banking_replicator" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "banking_common", @@ -374,7 +374,7 @@ dependencies = [ [[package]] name = "certifier_kafka_pg" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "cargo-husky", "env_logger", @@ -484,7 +484,7 @@ checksum = "702fc72eb24e5a1e48ce58027a675bc24edd52096d5397d4aea7c6dd9eca0bd1" [[package]] name = "cohort_banking" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-channel", "async-trait", @@ -515,7 +515,7 @@ dependencies = [ [[package]] name = "cohort_banking_with_sdk" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-channel", "async-trait", @@ -548,7 +548,7 @@ dependencies = [ [[package]] name = "cohort_replicator_kafka_pg" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "banking_common", @@ -573,7 +573,7 @@ dependencies = [ [[package]] name = "cohort_sdk" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "env_logger", @@ -598,7 +598,7 @@ dependencies = [ [[package]] name = "cohort_sdk_js" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "chrono", @@ -920,7 +920,7 @@ checksum = "0206175f82b8d6bf6652ff7d71a1e27fd2e4efde587fd368662814d6ec1d9ce0" [[package]] name = "examples_support" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-channel", "async-trait", @@ -1338,7 +1338,7 @@ dependencies = [ [[package]] name = "messenger_using_kafka" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "ahash 0.8.6", "async-trait", @@ -2474,7 +2474,7 @@ dependencies = [ [[package]] name = "talos_agent" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "env_logger", @@ -2495,7 +2495,7 @@ dependencies = [ [[package]] name = "talos_certifier" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "ahash 0.8.6", "async-trait", @@ -2516,7 +2516,7 @@ dependencies = [ [[package]] name = "talos_certifier_adapters" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "ahash 0.8.6", "async-trait", @@ -2544,7 +2544,7 @@ dependencies = [ [[package]] name = "talos_cohort_replicator" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "ahash 0.8.6", "async-trait", @@ -2566,7 +2566,7 @@ dependencies = [ [[package]] name = "talos_common_utils" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "env_logger", "log", @@ -2575,7 +2575,7 @@ dependencies = [ [[package]] name = "talos_messenger_actions" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "ahash 0.8.6", "async-trait", @@ -2604,7 +2604,7 @@ dependencies = [ [[package]] name = "talos_messenger_core" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "ahash 0.8.6", "async-trait", @@ -2630,7 +2630,7 @@ dependencies = [ [[package]] name = "talos_metrics" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "env_logger", "log", @@ -2646,7 +2646,7 @@ dependencies = [ [[package]] name = "talos_rdkafka_utils" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "criterion 0.5.1", @@ -2663,7 +2663,7 @@ dependencies = [ [[package]] name = "talos_suffix" -version = "0.2.22-dev" +version = "0.2.23-dev" dependencies = [ "async-trait", "criterion 0.4.0", diff --git a/cohort_sdk_client/package-lock.json b/cohort_sdk_client/package-lock.json index 157d179b..2757bac9 100644 --- a/cohort_sdk_client/package-lock.json +++ b/cohort_sdk_client/package-lock.json @@ -1,12 +1,12 @@ { "name": "@kindredgroup/cohort_sdk_client", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "lockfileVersion": 2, "requires": true, "packages": { "": { "name": "@kindredgroup/cohort_sdk_client", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "license": "MIT", "dependencies": { "@kindredgroup/cohort_sdk_js": "^0.2.13", diff --git a/cohort_sdk_client/package.json b/cohort_sdk_client/package.json index 762baa0c..ecd9bc9f 100644 --- a/cohort_sdk_client/package.json +++ b/cohort_sdk_client/package.json @@ -1,6 +1,6 @@ { "name": "@kindredgroup/cohort_sdk_client", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "author": "Kindredgroup", "license": "MIT", "description": "The Cohort SDK library for Talos Certifier clients", diff --git a/examples/agent_client/Cargo.toml b/examples/agent_client/Cargo.toml index 5c85b7a4..f71c854f 100644 --- a/examples/agent_client/Cargo.toml +++ b/examples/agent_client/Cargo.toml @@ -1,13 +1,13 @@ [package] name = "agent_client" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dev-dependencies] -talos_agent = { path = "../../packages/talos_agent", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.22-dev" } -examples_support = { path = "../../packages/examples_support", version = "0.2.22-dev" } +talos_agent = { path = "../../packages/talos_agent", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.23-dev" } +examples_support = { path = "../../packages/examples_support", version = "0.2.23-dev" } async-channel = { version = "1.8.0" } async-trait = { workspace = true } diff --git a/examples/certifier_kafka_pg/Cargo.toml b/examples/certifier_kafka_pg/Cargo.toml index 43128b69..4533190c 100644 --- a/examples/certifier_kafka_pg/Cargo.toml +++ b/examples/certifier_kafka_pg/Cargo.toml @@ -1,7 +1,7 @@ [package] # [package] name = "certifier_kafka_pg" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" keywords = ["talos"] description = "Talos Certifier using Kafka and Pg adapters" @@ -17,11 +17,11 @@ tokio = { workspace = true } refinery = { version = "0.8.7", features = ["tokio-postgres"] } # internal crates -talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.22-dev" } -talos_suffix = { path = "../../packages/talos_suffix", version = "0.2.22-dev" } -talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.22-dev" } -talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.22-dev" } +talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.23-dev" } +talos_suffix = { path = "../../packages/talos_suffix", version = "0.2.23-dev" } +talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.23-dev" } +talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.23-dev" } [dev-dependencies.cargo-husky] version = "1" diff --git a/examples/cohort_banking_with_sdk/Cargo.toml b/examples/cohort_banking_with_sdk/Cargo.toml index dd9f0554..793f474c 100644 --- a/examples/cohort_banking_with_sdk/Cargo.toml +++ b/examples/cohort_banking_with_sdk/Cargo.toml @@ -1,19 +1,19 @@ [package] name = "cohort_banking_with_sdk" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dev-dependencies] -banking_common = { path = "../../packages/banking_common", version = "0.2.22-dev" } -cohort_sdk = { path = "../../packages/cohort_sdk", version = "0.2.22-dev" } -cohort_banking = { path = "../../packages/cohort_banking", version = "0.2.22-dev" } -examples_support = { path = "../../packages/examples_support", version = "0.2.22-dev" } -talos_metrics = { path = "../../packages/talos_metrics", version = "0.2.22-dev" } -talos_agent = { path = "../../packages/talos_agent", version = "0.2.22-dev" } -talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.22-dev" } -talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.22-dev" } +banking_common = { path = "../../packages/banking_common", version = "0.2.23-dev" } +cohort_sdk = { path = "../../packages/cohort_sdk", version = "0.2.23-dev" } +cohort_banking = { path = "../../packages/cohort_banking", version = "0.2.23-dev" } +examples_support = { path = "../../packages/examples_support", version = "0.2.23-dev" } +talos_metrics = { path = "../../packages/talos_metrics", version = "0.2.23-dev" } +talos_agent = { path = "../../packages/talos_agent", version = "0.2.23-dev" } +talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.23-dev" } +talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.23-dev" } async-trait = { workspace = true } env_logger = { workspace = true } diff --git a/examples/cohort_replicator_kafka_pg/Cargo.toml b/examples/cohort_replicator_kafka_pg/Cargo.toml index 5fce5a9c..97590ed3 100644 --- a/examples/cohort_replicator_kafka_pg/Cargo.toml +++ b/examples/cohort_replicator_kafka_pg/Cargo.toml @@ -1,17 +1,17 @@ [package] name = "cohort_replicator_kafka_pg" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dev-dependencies] -banking_common = { path = "../../packages/banking_common", version = "0.2.22-dev" } -banking_replicator = { path = "../../packages/banking_replicator", version = "0.2.22-dev" } -cohort_banking = { path = "../../packages/cohort_banking", version = "0.2.22-dev" } -talos_cohort_replicator = { path = "../../packages/talos_cohort_replicator", version = "0.2.22-dev" } -talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.22-dev" } -talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.22-dev" } -talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.22-dev" } +banking_common = { path = "../../packages/banking_common", version = "0.2.23-dev" } +banking_replicator = { path = "../../packages/banking_replicator", version = "0.2.23-dev" } +cohort_banking = { path = "../../packages/cohort_banking", version = "0.2.23-dev" } +talos_cohort_replicator = { path = "../../packages/talos_cohort_replicator", version = "0.2.23-dev" } +talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.23-dev" } +talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.23-dev" } +talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.23-dev" } async-trait = { workspace = true } env_logger = { workspace = true } diff --git a/examples/messenger_using_kafka/Cargo.toml b/examples/messenger_using_kafka/Cargo.toml index 43d6dfd3..c7fac7ce 100644 --- a/examples/messenger_using_kafka/Cargo.toml +++ b/examples/messenger_using_kafka/Cargo.toml @@ -1,7 +1,7 @@ [package] # [package] name = "messenger_using_kafka" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" keywords = ["talos"] description = "Example on consuming `talos_messenger`" @@ -24,10 +24,10 @@ rdkafka = { version = "0.34.0", features = ["sasl"] } ahash = "0.8.3" # internal crates -talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.22-dev" } -talos_suffix = { path = "../../packages/talos_suffix", version = "0.2.22-dev" } -talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.22-dev" } -talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.22-dev" } -talos_messenger_core = { path = "../../packages/talos_messenger_core", version = "0.2.22-dev" } -talos_messenger_actions = { path = "../../packages/talos_messenger_actions", version = "0.2.22-dev" } +talos_certifier = { path = "../../packages/talos_certifier", version = "0.2.23-dev" } +talos_suffix = { path = "../../packages/talos_suffix", version = "0.2.23-dev" } +talos_certifier_adapters = { path = "../../packages/talos_certifier_adapters", version = "0.2.23-dev" } +talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../../packages/talos_rdkafka_utils", version = "0.2.23-dev" } +talos_messenger_core = { path = "../../packages/talos_messenger_core", version = "0.2.23-dev" } +talos_messenger_actions = { path = "../../packages/talos_messenger_actions", version = "0.2.23-dev" } diff --git a/packages/banking_common/Cargo.toml b/packages/banking_common/Cargo.toml index 265adbe1..c33299ca 100644 --- a/packages/banking_common/Cargo.toml +++ b/packages/banking_common/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "banking_common" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dependencies] @@ -19,4 +19,4 @@ tokio-postgres = { version = "0.7", features = [ "with-uuid-1", "with-serde_j deadpool = { version = "0.10.0" } deadpool-postgres = { version = "0.11.0" } -talos_common_utils = { path = "../talos_common_utils", version = "0.2.22-dev" } +talos_common_utils = { path = "../talos_common_utils", version = "0.2.23-dev" } diff --git a/packages/banking_replicator/Cargo.toml b/packages/banking_replicator/Cargo.toml index dede9333..54691207 100644 --- a/packages/banking_replicator/Cargo.toml +++ b/packages/banking_replicator/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "banking_replicator" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dependencies] @@ -25,10 +25,10 @@ opentelemetry = { version = "0.20.0" } strum = { version = "0.25", features = ["derive"] } uuid = { version = "1.4.1", features = ["v4"] } -banking_common = { path = "../banking_common", version = "0.2.22-dev" } -cohort_sdk = { path = "../cohort_sdk", version = "0.2.22-dev" } -talos_metrics = { path = "../talos_metrics", version = "0.2.22-dev" } -talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.22-dev" } -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_certifier_adapters = { path = "../talos_certifier_adapters", version = "0.2.22-dev" } +banking_common = { path = "../banking_common", version = "0.2.23-dev" } +cohort_sdk = { path = "../cohort_sdk", version = "0.2.23-dev" } +talos_metrics = { path = "../talos_metrics", version = "0.2.23-dev" } +talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.23-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_certifier_adapters = { path = "../talos_certifier_adapters", version = "0.2.23-dev" } diff --git a/packages/cohort_banking/Cargo.toml b/packages/cohort_banking/Cargo.toml index f6a5d136..460d0086 100644 --- a/packages/cohort_banking/Cargo.toml +++ b/packages/cohort_banking/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "cohort_banking" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dependencies] @@ -23,11 +23,11 @@ strum = { version = "0.25", features = ["derive"] } tokio-postgres = { version = "0.7", features = [ "with-uuid-1", "with-serde_json-1" ] } uuid = { version = "1.4.1", features = ["v4"] } -cohort_sdk = { path = "../cohort_sdk", version = "0.2.22-dev" } -banking_common = { path = "../banking_common", version = "0.2.22-dev" } -talos_agent = { path = "../talos_agent", version = "0.2.22-dev" } -talos_metrics = { path = "../talos_metrics", version = "0.2.22-dev" } -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.22-dev" } -talos_common_utils = { path = "../talos_common_utils", version = "0.2.22-dev" } -talos_suffix = { path = "../talos_suffix", version = "0.2.22-dev" } +cohort_sdk = { path = "../cohort_sdk", version = "0.2.23-dev" } +banking_common = { path = "../banking_common", version = "0.2.23-dev" } +talos_agent = { path = "../talos_agent", version = "0.2.23-dev" } +talos_metrics = { path = "../talos_metrics", version = "0.2.23-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.23-dev" } +talos_common_utils = { path = "../talos_common_utils", version = "0.2.23-dev" } +talos_suffix = { path = "../talos_suffix", version = "0.2.23-dev" } diff --git a/packages/cohort_sdk/Cargo.toml b/packages/cohort_sdk/Cargo.toml index 2d5594a2..c1fab759 100644 --- a/packages/cohort_sdk/Cargo.toml +++ b/packages/cohort_sdk/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "cohort_sdk" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dependencies] @@ -19,11 +19,11 @@ rdkafka = { version = "0.34.0", features = ["sasl"] } serde = { workspace = true } serde_json = { workspace = true } strum = { version = "0.25", features = ["derive"] } -talos_metrics = { path = "../talos_metrics", version = "0.2.22-dev" } -talos_agent = { path = "../talos_agent", version = "0.2.22-dev" } -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.22-dev" } +talos_metrics = { path = "../talos_metrics", version = "0.2.23-dev" } +talos_agent = { path = "../talos_agent", version = "0.2.23-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.23-dev" } uuid = { version = "1.4.1", features = ["v4"] } tokio = { workspace = true, features = ["full"] } diff --git a/packages/cohort_sdk_js/Cargo.toml b/packages/cohort_sdk_js/Cargo.toml index 5e7c1167..e822950c 100644 --- a/packages/cohort_sdk_js/Cargo.toml +++ b/packages/cohort_sdk_js/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "cohort_sdk_js" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" @@ -33,12 +33,12 @@ env_logger = { workspace = true } log = { workspace = true } tokio = { workspace = true, features = ["full"] } -cohort_sdk = { path = "../cohort_sdk", version = "0.2.22-dev" } -talos_agent = { path = "../talos_agent", version = "0.2.22-dev" } -talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.22-dev" } -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_certifier_adapters = { path = "../talos_certifier_adapters", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.22-dev" } +cohort_sdk = { path = "../cohort_sdk", version = "0.2.23-dev" } +talos_agent = { path = "../talos_agent", version = "0.2.23-dev" } +talos_cohort_replicator = { path = "../talos_cohort_replicator", version = "0.2.23-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_certifier_adapters = { path = "../talos_certifier_adapters", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.23-dev" } async-trait = "0.1.72" diff --git a/packages/cohort_sdk_js/npm/darwin-arm64/package.json b/packages/cohort_sdk_js/npm/darwin-arm64/package.json index e75b11a2..b890c3b8 100644 --- a/packages/cohort_sdk_js/npm/darwin-arm64/package.json +++ b/packages/cohort_sdk_js/npm/darwin-arm64/package.json @@ -1,6 +1,6 @@ { "name": "cohort_sdk_js-darwin-arm64", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "os": [ "darwin" ], diff --git a/packages/cohort_sdk_js/npm/darwin-universal/package.json b/packages/cohort_sdk_js/npm/darwin-universal/package.json index ca15ad43..36aea8d4 100644 --- a/packages/cohort_sdk_js/npm/darwin-universal/package.json +++ b/packages/cohort_sdk_js/npm/darwin-universal/package.json @@ -1,6 +1,6 @@ { "name": "cohort_sdk_js-darwin-universal", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "os": [ "darwin" ], diff --git a/packages/cohort_sdk_js/npm/darwin-x64/package.json b/packages/cohort_sdk_js/npm/darwin-x64/package.json index bcb91714..9185fe77 100644 --- a/packages/cohort_sdk_js/npm/darwin-x64/package.json +++ b/packages/cohort_sdk_js/npm/darwin-x64/package.json @@ -1,6 +1,6 @@ { "name": "cohort_sdk_js-darwin-x64", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "os": [ "darwin" ], diff --git a/packages/cohort_sdk_js/npm/linux-x64-gnu/package.json b/packages/cohort_sdk_js/npm/linux-x64-gnu/package.json index 4c03ac98..de271db6 100644 --- a/packages/cohort_sdk_js/npm/linux-x64-gnu/package.json +++ b/packages/cohort_sdk_js/npm/linux-x64-gnu/package.json @@ -1,6 +1,6 @@ { "name": "cohort_sdk_js-linux-x64", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "os": [ "linux" ], diff --git a/packages/cohort_sdk_js/npm/win32-x64-msvc/package.json b/packages/cohort_sdk_js/npm/win32-x64-msvc/package.json index d3bb6045..8bac9d09 100644 --- a/packages/cohort_sdk_js/npm/win32-x64-msvc/package.json +++ b/packages/cohort_sdk_js/npm/win32-x64-msvc/package.json @@ -1,6 +1,6 @@ { "name": "cohort_sdk_js-win32-x64-msvc", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "os": [ "win32" ], diff --git a/packages/cohort_sdk_js/package-lock.json b/packages/cohort_sdk_js/package-lock.json index 99792fc3..f6527844 100644 --- a/packages/cohort_sdk_js/package-lock.json +++ b/packages/cohort_sdk_js/package-lock.json @@ -1,12 +1,12 @@ { "name": "cohort_sdk_js", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "lockfileVersion": 2, "requires": true, "packages": { "": { "name": "cohort_sdk_js", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "hasInstallScript": true, "license": "MIT", "dependencies": { diff --git a/packages/cohort_sdk_js/package.json b/packages/cohort_sdk_js/package.json index 66d0e9ee..2f3ead8f 100644 --- a/packages/cohort_sdk_js/package.json +++ b/packages/cohort_sdk_js/package.json @@ -1,6 +1,6 @@ { "name": "@kindredgroup/cohort_sdk_js", - "version": "0.2.22-dev", + "version": "0.2.23-dev", "author": "Kindredgroup", "license": "MIT", "main": "index.js", diff --git a/packages/examples_support/Cargo.toml b/packages/examples_support/Cargo.toml index 5be104f1..204f1d5f 100644 --- a/packages/examples_support/Cargo.toml +++ b/packages/examples_support/Cargo.toml @@ -1,11 +1,11 @@ [package] name = "examples_support" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dependencies] -talos_metrics = { path = "../talos_metrics", version = "0.2.22-dev" } +talos_metrics = { path = "../talos_metrics", version = "0.2.23-dev" } # Postgres refinery = { version = "0.8.7", features = ["tokio-postgres"] } diff --git a/packages/talos_agent/Cargo.toml b/packages/talos_agent/Cargo.toml index f6df8f53..f05dad1f 100644 --- a/packages/talos_agent/Cargo.toml +++ b/packages/talos_agent/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_agent" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [dependencies] @@ -18,7 +18,7 @@ time = { version = "0.3.17" } tokio = { workspace = true, features = ["full"] } uuid = { version = "1.4.1", features = ["v4"] } -talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.22-dev" } +talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.23-dev" } [dev-dependencies] mockall = { version = "0.11.3" } diff --git a/packages/talos_certifier/Cargo.toml b/packages/talos_certifier/Cargo.toml index 18bf37a1..ade57d88 100644 --- a/packages/talos_certifier/Cargo.toml +++ b/packages/talos_certifier/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_certifier" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" keywords = ["talos"] license = "MIT" @@ -35,7 +35,7 @@ time = { version = "0.3.30", features = ["formatting"]} thiserror = "1.0.31" # internal crates -talos_suffix = { path = "../talos_suffix", version = "0.2.22-dev" } +talos_suffix = { path = "../talos_suffix", version = "0.2.23-dev" } [dev-dependencies] tokio-test = "0.4" diff --git a/packages/talos_certifier_adapters/Cargo.toml b/packages/talos_certifier_adapters/Cargo.toml index e8bcf0e5..dfb2dd07 100644 --- a/packages/talos_certifier_adapters/Cargo.toml +++ b/packages/talos_certifier_adapters/Cargo.toml @@ -1,7 +1,7 @@ [package] # [package] name = "talos_certifier_adapters" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" keywords = ["talos", "adapters"] license = "MIT" @@ -48,11 +48,11 @@ thiserror = "1.0.31" mockall = "0.11.0" # internal crates -talos_metrics = { path = "../talos_metrics", version = "0.2.22-dev" } -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_suffix = { path = "../talos_suffix", version = "0.2.22-dev" } -talos_common_utils = { path = "../talos_common_utils", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.22-dev" } +talos_metrics = { path = "../talos_metrics", version = "0.2.23-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_suffix = { path = "../talos_suffix", version = "0.2.23-dev" } +talos_common_utils = { path = "../talos_common_utils", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.23-dev" } [dev-dependencies] diff --git a/packages/talos_certifier_adapters/src/kafka/kafka_deploy.rs b/packages/talos_certifier_adapters/src/kafka/kafka_deploy.rs index d3ba32e0..c7daa745 100644 --- a/packages/talos_certifier_adapters/src/kafka/kafka_deploy.rs +++ b/packages/talos_certifier_adapters/src/kafka/kafka_deploy.rs @@ -42,7 +42,7 @@ const DEFAULT_REPLICATION_FACTOR: i32 = 3; const DEFAULT_NUM_PARTITIONS: i32 = 3; pub async fn create_topic(kafka_config: &KafkaConfig, topic_configs: CreateTopicConfigs<'_>) -> Result { - println!("kafka brokers = {:?} and usename = {}", kafka_config.brokers, kafka_config.username); + println!("kafka brokers = {:?} and username = {}", kafka_config.brokers, kafka_config.username); println!("topic configs received from env = {topic_configs:#?}"); let consumer: StreamConsumer = kafka_config.build_consumer_config().create()?; @@ -70,6 +70,9 @@ pub async fn create_topic(kafka_config: &KafkaConfig, topic_configs: CreateTopic let admin: AdminClient = kafka_config.build_consumer_config().create()?; let results = admin.create_topics(&[topic], &opts).await?; + if let Err((_, RDKafkaErrorCode::TopicAlreadyExists)) = results[0] { + return Ok(KafkaDeployStatus::TopicExists); + } results[0].as_ref().map_err(|e| KafkaDeployError::TopicCreation(topic_configs.topic, e.1))?; diff --git a/packages/talos_cohort_replicator/Cargo.toml b/packages/talos_cohort_replicator/Cargo.toml index 85a00f9a..ca78161d 100644 --- a/packages/talos_cohort_replicator/Cargo.toml +++ b/packages/talos_cohort_replicator/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_cohort_replicator" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" [lib] @@ -26,8 +26,8 @@ time = { version = "0.3.17" } indexmap = { version = "2.0.0", features = ["rayon"]} ahash = "0.8.3" -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_suffix = { path = "../talos_suffix", version = "0.2.22-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_suffix = { path = "../talos_suffix", version = "0.2.23-dev" } [dev-dependencies] mockall = { version = "0.11.3" } diff --git a/packages/talos_common_utils/Cargo.toml b/packages/talos_common_utils/Cargo.toml index bf025762..ba584630 100644 --- a/packages/talos_common_utils/Cargo.toml +++ b/packages/talos_common_utils/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_common_utils" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" license = "MIT" homepage = "https://github.com/kindredgroup/talos" diff --git a/packages/talos_messenger_actions/Cargo.toml b/packages/talos_messenger_actions/Cargo.toml index 271c022d..49524209 100644 --- a/packages/talos_messenger_actions/Cargo.toml +++ b/packages/talos_messenger_actions/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_messenger_actions" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" license = "MIT" homepage = "https://github.com/kindredgroup/talos" @@ -42,12 +42,12 @@ time = { version = "0.3.30" } indexmap = { version = "2.0.0", features = ["rayon"] } ahash = "0.8.3" -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_suffix = { path = "../talos_suffix", version = "0.2.22-dev" } -talos_certifier_adapters = { path = "../talos_certifier_adapters", version = "0.2.22-dev" } -talos_common_utils = { path = "../talos_common_utils", version = "0.2.22-dev" } -talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.22-dev" } -talos_messenger_core = { path = "../talos_messenger_core", version = "0.2.22-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_suffix = { path = "../talos_suffix", version = "0.2.23-dev" } +talos_certifier_adapters = { path = "../talos_certifier_adapters", version = "0.2.23-dev" } +talos_common_utils = { path = "../talos_common_utils", version = "0.2.23-dev" } +talos_rdkafka_utils = { path = "../talos_rdkafka_utils", version = "0.2.23-dev" } +talos_messenger_core = { path = "../talos_messenger_core", version = "0.2.23-dev" } [dev-dependencies] diff --git a/packages/talos_messenger_core/Cargo.toml b/packages/talos_messenger_core/Cargo.toml index 80e35b34..c41f0da5 100644 --- a/packages/talos_messenger_core/Cargo.toml +++ b/packages/talos_messenger_core/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_messenger_core" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" license = "MIT" homepage = "https://github.com/kindredgroup/talos" @@ -41,9 +41,9 @@ time = { version = "0.3.30" } indexmap = { version = "2.0.0", features = ["rayon"] } ahash = "0.8.3" -talos_certifier = { path = "../talos_certifier", version = "0.2.22-dev" } -talos_suffix = { path = "../talos_suffix", version = "0.2.22-dev" } -talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.22-dev" } +talos_certifier = { path = "../talos_certifier", version = "0.2.23-dev" } +talos_suffix = { path = "../talos_suffix", version = "0.2.23-dev" } +talos_common_utils = { path = "../../packages/talos_common_utils", version = "0.2.23-dev" } [dev-dependencies] mockall = { version = "0.11.3" } diff --git a/packages/talos_metrics/Cargo.toml b/packages/talos_metrics/Cargo.toml index fff60a26..2a9ea6e5 100644 --- a/packages/talos_metrics/Cargo.toml +++ b/packages/talos_metrics/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_metrics" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" license = "MIT" homepage = "https://github.com/kindredgroup/talos" diff --git a/packages/talos_rdkafka_utils/Cargo.toml b/packages/talos_rdkafka_utils/Cargo.toml index 1d95b099..565f91e3 100644 --- a/packages/talos_rdkafka_utils/Cargo.toml +++ b/packages/talos_rdkafka_utils/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_rdkafka_utils" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" license = "MIT" homepage = "https://github.com/kindredgroup/talos" @@ -15,7 +15,7 @@ doctest = false [dependencies] async-trait = { workspace = true } tokio = { workspace = true, features = ["macros", "rt"] } -talos_common_utils = { path = "../talos_common_utils", version = "0.2.22-dev" } +talos_common_utils = { path = "../talos_common_utils", version = "0.2.23-dev" } # Logging log = { workspace = true } env_logger = { workspace = true } diff --git a/packages/talos_suffix/Cargo.toml b/packages/talos_suffix/Cargo.toml index c9b4bf45..39b6a6bb 100644 --- a/packages/talos_suffix/Cargo.toml +++ b/packages/talos_suffix/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "talos_suffix" -version = "0.2.22-dev" +version = "0.2.23-dev" edition = "2021" license = "MIT" homepage = "https://github.com/kindredgroup/talos"