(&self, write_ts: Timestamp)
| 957 | |
| 958 | #[instrument] |
| 959 | async fn apply_write(&self, write_ts: Timestamp) { |
| 960 | let metrics = &self.metrics.retries.apply_write; |
| 961 | |
| 962 | let res = retry_fallible(metrics, || { |
| 963 | self.metrics |
| 964 | .oracle |
| 965 | .apply_write |
| 966 | .run_op(|| self.fallible_apply_write(write_ts.clone())) |
| 967 | }) |
| 968 | .await; |
| 969 | |
| 970 | res |
| 971 | } |
| 972 | } |
| 973 | |
| 974 | pub const INFO_MIN_ATTEMPTS: usize = 3; |
no test coverage detected