Method on_copy_data

nodedb/src/control/server/pgwire/handler/copy_handler.rs:109–126

(&self, client: &mut C, copy_data: CopyData)

#[async_trait]
impl CopyHandler for NodeDbCopyHandler {
    async fn on_copy_data<C>(&self, client: &mut C, copy_data: CopyData) -> PgWireResult<()>
    where
        C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync,
        C::Error: Debug,
        PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>,
    {
        let id = conn_id(&client.socket_addr());
        match self.restore_state.append(id, &copy_data.data) {
            Ok(()) => Ok(()),
            Err(e @ AppendError::NotPending) => {
                Err(sqlstate(ss::FEATURE_NOT_SUPPORTED, &e.to_string()))
            }
            Err(e @ AppendError::OverCap { .. }) => {
                self.restore_state.cancel(id);
                Err(sqlstate(ss::PROGRAM_LIMIT_EXCEEDED, &e.to_string()))
            }
        }
    }

    async fn on_copy_done<C>(&self, client: &mut C, _done: CopyDone) -> PgWireResult<()>
    where