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

Method sync

src/pgwire/src/protocol.rs:1892–1898  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

1890
1891 #[instrument(level = "debug")]
1892 async fn sync(&mut self) -> Result<State, io::Error> {
1893 // Close the current transaction if we are in an implicit transaction.
1894 if self.adapter_client.session().transaction().is_implicit() {
1895 self.commit_transaction().await?;
1896 }
1897 self.ready().await
1898 }
1899
1900 #[instrument(level = "debug")]
1901 async fn ready(&mut self) -> Result<State, io::Error> {

Callers 2

advance_readyMethod · 0.45
advance_drainMethod · 0.45

Calls 5

is_implicitMethod · 0.45
transactionMethod · 0.45
sessionMethod · 0.45
commit_transactionMethod · 0.45
readyMethod · 0.45

Tested by

no test coverage detected