harmos_domain/operations/storage/
write_file.rs

1/* ***
2 *
3 * Harmos
4 *
5 * SPDX-License-Identifier: Apache-2.0
6 *
7 * ***
8 */
9
10/* === Modules === */
11
12/* === Re-Exports === */
13
14/* === Imports === */
15
16// Standard Library Imports
17
18// Third Party Imports
19
20// Local Imports
21use super::IO_POLICY;
22use crate::MemorySize;
23use crate::model::storage::codec::{Nested, product};
24use crate::model::storage::{FileBatch, FileMetadata, FileReference};
25use crate::operations::{ReplaySafety, Visibility};
26
27/* === Constants === */
28
29/* === Macros === */
30
31product!(WriteFile {
32    metadata: Nested<FileMetadata> => 1,
33});
34
35crate::declare!(WriteFile {
36    id: "storage.write_file",
37    version: 1,
38    policy: IO_POLICY,
39    response: FileReference,
40    input: FileBatch,
41    visibility: Visibility::Shared,
42    replay: ReplaySafety::Unknown,
43    grpc: ("harmos.storage.v1", "Storage", "WriteFile"),
44    grant: |request: &WriteFile| Some(crate::plugin::Grant::of("storage.write_file", request.metadata.id.as_str().to_owned(),)),
45});
46
47/* === Type Aliases === */
48
49/* === Structs === */
50
51// Write One Finished File From Streamed Batches.
52#[derive(Clone, Debug, PartialEq, Eq)]
53pub struct WriteFile {
54    pub metadata: FileMetadata,
55}
56
57/* === Enums === */
58
59/* === Traits === */
60
61/* === Implementations === */
62
63impl MemorySize for WriteFile {
64    fn memory_size(&self) -> usize {
65        std::mem::size_of::<Self>().saturating_add(self.metadata.memory_size().saturating_sub(std::mem::size_of_val(&self.metadata)))
66    }
67}
68
69/* === Public Functions === */
70
71/* === Private Functions === */
72
73/* === Tests === */
harmos_domain/operations/storage/write_file.rs

harmos_domain/operations/storage/
write_file.rs
