diff --git a/Cargo.lock b/Cargo.lock index 21b23c5d82..d5cc7c6c3a 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -449,7 +449,7 @@ dependencies = [ [[package]] name = "bare_gen" -version = "0.0.1" +version = "25.6.1" dependencies = [ "heck 0.5.0", "pest", @@ -755,7 +755,7 @@ dependencies = [ [[package]] name = "clickhouse-inserter" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-channel", @@ -779,7 +779,7 @@ dependencies = [ [[package]] name = "clickhouse-user-query" -version = "0.0.1" +version = "25.6.1" dependencies = [ "clickhouse", "serde", @@ -1382,7 +1382,7 @@ checksum = "c34f04666d835ff5d62e058c3995147c06f42fe86ff053337632bca83e42702d" [[package]] name = "epoxy" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -1421,7 +1421,7 @@ dependencies = [ [[package]] name = "epoxy-protocol" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "bare_gen", @@ -1683,7 +1683,7 @@ dependencies = [ [[package]] name = "gasoline" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-stream", @@ -1730,7 +1730,7 @@ dependencies = [ [[package]] name = "gasoline-macros" -version = "0.0.1" +version = "25.6.1" dependencies = [ "proc-macro2", "quote", @@ -2378,7 +2378,7 @@ dependencies = [ [[package]] name = "internal" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "gasoline", @@ -2776,7 +2776,7 @@ dependencies = [ [[package]] name = "namespace" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "gasoline", @@ -3256,7 +3256,7 @@ checksum = "df94ce210e5bc13cb6651479fa48d14f601d9858cfe0467f43ae157023b938d3" [[package]] name = "pegboard" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "epoxy", @@ -3284,7 +3284,7 @@ dependencies = [ [[package]] name = "pegboard-actor-kv" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "futures-util", @@ -3302,7 +3302,7 @@ dependencies = [ [[package]] name = "pegboard-gateway" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-trait", @@ -3327,7 +3327,7 @@ dependencies = [ [[package]] name = "pegboard-runner-ws" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "gasoline", @@ -3350,7 +3350,7 @@ dependencies = [ [[package]] name = "pegboard-serverless" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "epoxy", @@ -3367,7 +3367,7 @@ dependencies = [ [[package]] name = "pegboard-tunnel" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-trait", @@ -4078,7 +4078,7 @@ dependencies = [ [[package]] name = "rivet-api-builder" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -4109,7 +4109,7 @@ dependencies = [ [[package]] name = "rivet-api-client" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -4141,7 +4141,7 @@ dependencies = [ [[package]] name = "rivet-api-peer" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -4169,7 +4169,7 @@ dependencies = [ [[package]] name = "rivet-api-public" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -4200,7 +4200,7 @@ dependencies = [ [[package]] name = "rivet-api-types" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "gasoline", @@ -4215,7 +4215,7 @@ dependencies = [ [[package]] name = "rivet-api-util" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -4227,7 +4227,7 @@ dependencies = [ [[package]] name = "rivet-bootstrap" -version = "0.0.1" +version = "25.6.1" dependencies = [ "epoxy", "gasoline", @@ -4243,7 +4243,7 @@ dependencies = [ [[package]] name = "rivet-cache" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "futures-util", @@ -4266,14 +4266,14 @@ dependencies = [ [[package]] name = "rivet-cache-result" -version = "0.0.1" +version = "25.6.1" dependencies = [ "rivet-util", ] [[package]] name = "rivet-config" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "config", @@ -4291,7 +4291,7 @@ dependencies = [ [[package]] name = "rivet-data" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "bare_gen", @@ -4309,7 +4309,7 @@ dependencies = [ [[package]] name = "rivet-dump-openapi" -version = "0.0.1" +version = "25.6.1" dependencies = [ "rivet-api-public", "serde_json", @@ -4318,7 +4318,7 @@ dependencies = [ [[package]] name = "rivet-engine" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -4376,7 +4376,7 @@ dependencies = [ [[package]] name = "rivet-env" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "lazy_static", @@ -4386,7 +4386,7 @@ dependencies = [ [[package]] name = "rivet-error" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "indoc", @@ -4398,7 +4398,7 @@ dependencies = [ [[package]] name = "rivet-error-macros" -version = "0.0.1" +version = "25.6.1" dependencies = [ "indoc", "proc-macro2", @@ -4409,7 +4409,7 @@ dependencies = [ [[package]] name = "rivet-guard" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "axum 0.8.4", @@ -4452,7 +4452,7 @@ dependencies = [ [[package]] name = "rivet-guard-core" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-trait", @@ -4496,7 +4496,7 @@ dependencies = [ [[package]] name = "rivet-logs" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "chrono", @@ -4510,7 +4510,7 @@ dependencies = [ [[package]] name = "rivet-metrics" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "console-subscriber", @@ -4528,7 +4528,7 @@ dependencies = [ [[package]] name = "rivet-pools" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-nats", @@ -4561,7 +4561,7 @@ dependencies = [ [[package]] name = "rivet-runner-protocol" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "bare_gen", @@ -4580,7 +4580,7 @@ dependencies = [ [[package]] name = "rivet-runtime" -version = "0.0.1" +version = "25.6.1" dependencies = [ "console-subscriber", "lazy_static", @@ -4606,7 +4606,7 @@ dependencies = [ [[package]] name = "rivet-service-manager" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "chrono", @@ -4621,7 +4621,7 @@ dependencies = [ [[package]] name = "rivet-telemetry" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "rivet-config", @@ -4645,7 +4645,7 @@ dependencies = [ [[package]] name = "rivet-test-deps" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "futures-util", @@ -4663,7 +4663,7 @@ dependencies = [ [[package]] name = "rivet-test-deps-docker" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "portpicker", @@ -4676,7 +4676,7 @@ dependencies = [ [[package]] name = "rivet-tunnel-protocol" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "bare_gen", @@ -4693,7 +4693,7 @@ dependencies = [ [[package]] name = "rivet-types" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "gasoline", @@ -4709,7 +4709,7 @@ dependencies = [ [[package]] name = "rivet-ups-protocol" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "bare_gen", @@ -4726,7 +4726,7 @@ dependencies = [ [[package]] name = "rivet-util" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-trait", @@ -4755,7 +4755,7 @@ dependencies = [ [[package]] name = "rivet-util-id" -version = "0.0.1" +version = "25.6.1" dependencies = [ "serde", "thiserror 1.0.69", @@ -4766,7 +4766,7 @@ dependencies = [ [[package]] name = "rivet-workflow-worker" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "epoxy", @@ -6383,7 +6383,7 @@ checksum = "4a1a07cc7db3810833284e8d372ccdc6da29741639ecc70c9ec107df0fa6154c" [[package]] name = "universaldb" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-trait", @@ -6410,7 +6410,7 @@ dependencies = [ [[package]] name = "universalpubsub" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "async-nats", @@ -6574,7 +6574,7 @@ checksum = "0b928f33d975fc6ad9f86c8f283853ad26bdd5b10b7f1542aa2fa15e2289105a" [[package]] name = "versioned-data-util" -version = "0.0.1" +version = "25.6.1" dependencies = [ "anyhow", "serde", diff --git a/out/openapi.json b/out/openapi.json index 7622a2a249..71b8be245b 100644 --- a/out/openapi.json +++ b/out/openapi.json @@ -11,7 +11,7 @@ "name": "Apache-2.0", "identifier": "Apache-2.0" }, - "version": "0.0.1" + "version": "25.6.1" }, "paths": { "/actors": { diff --git a/packages/common/universalpubsub/src/driver/postgres/mod.rs b/packages/common/universalpubsub/src/driver/postgres/mod.rs index ddd845a878..c2f20b68d0 100644 --- a/packages/common/universalpubsub/src/driver/postgres/mod.rs +++ b/packages/common/universalpubsub/src/driver/postgres/mod.rs @@ -1,7 +1,3 @@ -use std::collections::HashMap; -use std::hash::{DefaultHasher, Hash, Hasher}; -use std::sync::{Arc, Mutex}; - use anyhow::*; use async_trait::async_trait; use base64::Engine; @@ -9,6 +5,9 @@ use base64::engine::general_purpose::STANDARD_NO_PAD as BASE64; use deadpool_postgres::{Config, ManagerConfig, Pool, PoolConfig, RecyclingMethod, Runtime}; use futures_util::future::poll_fn; use rivet_util::backoff::Backoff; +use std::collections::HashMap; +use std::hash::{DefaultHasher, Hash, Hasher}; +use std::sync::Arc; use tokio::sync::{Mutex, broadcast}; use tokio_postgres::{AsyncMessage, NoTls}; use tracing::Instrument;