alien-core 1.4.0

Deploy software into your customers' cloud accounts and keep it fully managed
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use std::collections::HashMap;

#[cfg(feature = "openapi")]
use utoipa::ToSchema;

/// Represents the type of storage event that occurred.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
#[cfg_attr(feature = "openapi", derive(ToSchema))]
#[serde(rename_all = "camelCase")]
pub enum StorageEventType {
    /// An object was created (e.g., uploaded, put).
    Created,
    /// An object was deleted.
    Deleted,
    /// An object was copied.
    Copied,
    /// An object's metadata was updated.
    MetadataUpdated,
    /// An object was restored from an archive tier.
    Restored,
    /// An object's storage tier was changed.
    TierChanged,
    /// An unknown or unsupported storage event type.
    Unknown,
}

/// Represents an event triggered by an action in an object storage service.
///
/// This struct provides a generic representation for events from services like
/// AWS S3, Google Cloud Storage (GCS), and Azure Blob Storage.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
#[cfg_attr(feature = "openapi", derive(ToSchema))]
#[serde(rename_all = "camelCase")]
pub struct StorageEvent {
    /// The type of storage event.
    pub event_type: StorageEventType,

    /// The name of the bucket or container where the event occurred.
    pub bucket_name: String,

    /// The key or path of the object involved in the event.
    pub object_key: String,

    /// The timestamp when the event occurred.
    pub timestamp: DateTime<Utc>,

    /// Optional size of the object in bytes.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub size: Option<u64>,

    /// Optional ETag or hash of the object content.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub etag: Option<String>,

    /// Optional content type (MIME type) of the object.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub content_type: Option<String>,

    /// Optional metadata associated with the object.
    #[serde(default, skip_serializing_if = "HashMap::is_empty")]
    pub metadata: HashMap<String, String>,

    /// Optional information about the source object for copy events.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub copy_source: Option<String>,

    /// Optional previous storage tier for TierChanged or Restored events.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub previous_tier: Option<String>,

    /// Optional current storage tier for TierChanged or Restored events.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub current_tier: Option<String>,

    /// Optional region where the event originated.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub region: Option<String>,

    /// Optional version or sequencer identifier for the event or object state.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub version_id: Option<String>,
}

/// A wrapper type for a list of storage events.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
#[cfg_attr(feature = "openapi", derive(ToSchema))]
#[serde(rename_all = "camelCase")]
pub struct StorageEvents(pub Vec<StorageEvent>);