Struct LaminarPgwireHandler

Source

pub struct LaminarPgwireHandler {
    db: Arc<LaminarDB>,
    connections: Mutex<HashMap<SocketAddr, Arc<ConnState>>>,
}

Fields§

§db: Arc<LaminarDB>§connections: Mutex<HashMap<SocketAddr, Arc<ConnState>>>

Per-peer SimpleQuery cursor map. Entries are evicted at the start of every do_query call once their cursors are dead and no transaction is open — pgwire 0.39 doesn’t give us a connection-close hook, so this is the cheapest way to keep stale state from leaking on port reuse.

Struct LaminarPgwireHandler Copy item path

Fields§

Implementations§

impl LaminarPgwireHandler

fn new(db: Arc<LaminarDB>) -> Self

fn conn_state(&self, peer: SocketAddr) -> Arc<ConnState>

fn evict_idle_peer(&self, peer: SocketAddr)

Trait Implementations§

impl ExtendedQueryHandler for LaminarPgwireHandler

type Statement = LaminarStmt

type QueryParser = LaminarQueryParser

fn query_parser(&self) -> Arc<Self::QueryParser>

impl NoopStartupHandler for LaminarPgwireHandler

fn connection_manager(&self) -> Option<Arc<ConnectionManager>>

fn pid_secret_key_generator(&self) -> &dyn PidSecretKeyGenerator

impl SimpleQueryHandler for LaminarPgwireHandler

Auto Trait Implementations§

impl !Freeze for LaminarPgwireHandler

impl !RefUnwindSafe for LaminarPgwireHandler

impl Send for LaminarPgwireHandler

impl Sync for LaminarPgwireHandler

impl Unpin for LaminarPgwireHandler

impl UnsafeUnpin for LaminarPgwireHandler

impl !UnwindSafe for LaminarPgwireHandler

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

impl<U> As for U

fn as_<T>(self) -> Twhere T: CastFrom<U>,

impl<T> AsAny for Twhere T: Any + Send + Sync,

fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)

fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>

fn type_name(&self) -> &'static str

impl<T> AsAny for Twhere T: Any,

fn as_any(&self) -> &(dyn Any + 'static)

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

fn type_name(&self) -> &'static str

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> Conv for T

fn conv<T>(self) -> Twhere Self: Into<T>,

impl<T> Downcast for Twhere T: AsAny + ?Sized,

fn is<T>(&self) -> boolwhere T: AsAny,

fn downcast_ref<T>(&self) -> Option<&T>where T: AsAny,

fn downcast_mut<T>(&mut self) -> Option<&mut T>where T: AsAny,

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self>where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>where &'a Self: for<'a> IntoIterator,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

Struct LaminarPgwireHandler

impl<T> Any for T
where T: 'static + ?Sized,

fn as_<T>(self) -> T
where T: CastFrom<U>,

impl<T> AsAny for T
where T: Any + Send + Sync,

impl<T> AsAny for T
where T: Any,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn conv<T>(self) -> T
where Self: Into<T>,

impl<T> Downcast for T
where T: AsAny + ?Sized,

fn is<T>(&self) -> bool
where T: AsAny,

fn downcast_ref<T>(&self) -> Option<&T>
where T: AsAny,

fn downcast_mut<T>(&mut self) -> Option<&mut T>
where T: AsAny,

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

impl<T> Pipe for T
where T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn with<F, R>(self, f: F) -> R
where Self: Sized, F: FnOnce(Self) -> R,

fn with_ref<F, R>(&self, f: F) -> R
where F: FnOnce(&Self) -> R,

fn with_mut<F, R>(&mut self, f: F) -> R
where F: FnOnce(&mut Self) -> R,

impl<H> StartupHandler for H
where H: NoopStartupHandler,

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,