mirror of
https://github.com/neondatabase/neon.git
synced 2026-01-16 18:02:56 +00:00
0323bb5870
Now proxy binary accepts `--auth-backend` CLI option, which determines
auth scheme and cluster routing method. Following backends are currently
implemented:
* legacy
old method, when username ends with `@zenith` it uses md5 auth dbname as
the cluster name; otherwise, it sends a login link and waits for the console
to call back
* console
new SCRAM-based console API; uses SNI info to select the destination
cluster
* postgres
uses postgres to select auth secrets of existing roles. Useful for local
testing
* link
sends login link for all usernames
32 lines
882 B
Rust
32 lines
882 B
Rust
pub mod console;
|
|
pub mod legacy_console;
|
|
pub mod link;
|
|
pub mod postgres;
|
|
|
|
pub use legacy_console::{AuthError, AuthErrorImpl};
|
|
|
|
use crate::mgmt;
|
|
use crate::waiters::{self, Waiter, Waiters};
|
|
use lazy_static::lazy_static;
|
|
|
|
lazy_static! {
|
|
static ref CPLANE_WAITERS: Waiters<mgmt::ComputeReady> = Default::default();
|
|
}
|
|
|
|
/// Give caller an opportunity to wait for the cloud's reply.
|
|
pub async fn with_waiter<R, T, E>(
|
|
psql_session_id: impl Into<String>,
|
|
action: impl FnOnce(Waiter<'static, mgmt::ComputeReady>) -> R,
|
|
) -> Result<T, E>
|
|
where
|
|
R: std::future::Future<Output = Result<T, E>>,
|
|
E: From<waiters::RegisterError>,
|
|
{
|
|
let waiter = CPLANE_WAITERS.register(psql_session_id.into())?;
|
|
action(waiter).await
|
|
}
|
|
|
|
pub fn notify(psql_session_id: &str, msg: mgmt::ComputeReady) -> Result<(), waiters::NotifyError> {
|
|
CPLANE_WAITERS.notify(psql_session_id, msg)
|
|
}
|