rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-15 01:12:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Mangle gRPC connstrings to use port 51051

Browse Source
This commit is contained in:
Erik Grinaker
2025-06-05 17:46:58 +02:00
parent 2fb6164bf8
commit 28a61741b3
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pgxn/neon/communicator/src/worker_process/main_loop.rs
View File

@@ -70,7 +70,7 @@ pub(super) async fn init(
tenant_id: String,
timeline_id: String,
auth_token: Option<String>,
shard_map: HashMap<utils::shard::ShardIndex, String>,
mut shard_map: HashMap<utils::shard::ShardIndex, String>,
initial_file_cache_size: u64,
file_cache_path: Option<PathBuf>,
) -> CommunicatorWorkerProcessStruct<'static> {
@@ -86,6 +86,12 @@ pub(super) async fn init(
)
};
// TODO: for now, just hack in the gRPC port number. This needs to be plumbed through.
for connstr in shard_map.values_mut() {
*connstr = connstr.replace(":64000", ":51051");
}
tracing::warn!("mangled connstrings to use gRPC port 51051 shard_map={shard_map:?}");
// Initialize subsystems
let cache = cis
.integrated_cache_init_struct