MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / handle_connection

Method handle_connection

src/pgwire/src/server.rs:82–95  ·  view source on GitHub ↗
(
        &self,
        conn: Connection,
        tokio_metrics_intervals: impl Iterator<Item = TaskMetrics> + Send + 'static,
    )

Source from the content-addressed store, hash-verified

80 const NAME: &'static str = "pgwire";
81
82 fn handle_connection(
83 &self,
84 conn: Connection,
85 tokio_metrics_intervals: impl Iterator<Item = TaskMetrics> + Send + 'static,
86 ) -> ConnectionHandler {
87 // Using fully-qualified syntax means we won't accidentally call
88 // ourselves (i.e., silently infinitely recurse) if the name or type of
89 // `crate::Server::handle_connection` changes.
90 Box::pin(crate::Server::handle_connection(
91 self,
92 conn,
93 tokio_metrics_intervals,
94 ))
95 }
96}
97
98impl Server {

Callers

nothing calls this directly

Calls 15

decode_startupFunction · 0.85
epoch_to_uuid_v7Function · 0.85
new_conn_idMethod · 0.80
uuid_handleMethod · 0.80
is_someMethod · 0.80
cancel_requestMethod · 0.80
runFunction · 0.70
cloneMethod · 0.45
inner_mutMethod · 0.45
removeMethod · 0.45
okMethod · 0.45
parseMethod · 0.45

Tested by

no test coverage detected