List and decode protobuf messages, hydrating `resource_version` from the authoritative DB row (mirrors `get_message`).
(
&self,
limit: u32,
offset: u32,
)
| 392 | /// List and decode protobuf messages, hydrating `resource_version` from |
| 393 | /// the authoritative DB row (mirrors `get_message`). |
| 394 | pub async fn list_messages<T: Message + Default + ObjectType + SetResourceVersion>( |
| 395 | &self, |
| 396 | limit: u32, |
| 397 | offset: u32, |
| 398 | ) -> PersistenceResult<Vec<T>> { |
| 399 | self.list(T::object_type(), limit, offset) |
| 400 | .await? |
| 401 | .into_iter() |
| 402 | .map(decode_record) |
| 403 | .collect() |
| 404 | } |
| 405 | |
| 406 | /// List and decode protobuf messages with label selector filtering, |
| 407 | /// hydrating `resource_version` from the authoritative DB row. |
no test coverage detected