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

Method deliver_response

src/compute-client/src/controller/instance.rs:428–432  ·  view source on GitHub ↗

Enqueue the given response for delivery to the controller clients.

(&self, response: ComputeControllerResponse)

Source from the content-addressed store, hash-verified

426
427 /// Enqueue the given response for delivery to the controller clients.
428 fn deliver_response(&self, response: ComputeControllerResponse) {
429 // Failure to send means the `ComputeController` has been dropped and doesn't care about
430 // responses anymore.
431 let _ = self.response_tx.send(response);
432 }
433
434 /// Enqueue the given introspection updates for recording.
435 fn deliver_introspection_updates(&self, type_: IntrospectionType, updates: Vec<(Row, Diff)>) {

Callers 6

remove_replicaMethod · 0.80
cancel_peekMethod · 0.80
handle_peek_responseMethod · 0.80

Calls 1

sendMethod · 0.45

Tested by

no test coverage detected