use super::STREAM_POLICY;
use crate::MemorySize;
use crate::model::storage::codec::{Nested, Unsigned, product};
use crate::model::storage::{FileBatch, FileProgress, StagedFile};
use crate::operations::Visibility;
product!(FollowFile {
file: Nested<StagedFile> => 1,
offset: Unsigned => 2,
});
crate::declare!(FollowFile {
id: "storage.follow_file",
version: 1,
policy: STREAM_POLICY,
response: FileProgress,
output: FileBatch,
visibility: Visibility::Host,
});
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct FollowFile {
pub file: StagedFile,
pub offset: u64,
}
impl MemorySize for FollowFile {
fn memory_size(&self) -> usize {
std::mem::size_of::<Self>()
.saturating_add(self.file.memory_size().saturating_sub(std::mem::size_of_val(&self.file)))
.saturating_add(self.offset.memory_size().saturating_sub(std::mem::size_of_val(&self.offset)))
}
}