nominal-api 0.1193.0

// This file is @generated by prost-build.
/// Canonical event type.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Event {
    #[prost(oneof = "event::EventType", tags = "1, 2")]
    pub event_type: ::core::option::Option<event::EventType>,
}
/// Nested message and enum types in `Event`.
pub mod event {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum EventType {
        #[prost(message, tag = "1")]
        DataStream(super::DataStreamEvent),
        #[prost(message, tag = "2")]
        FileIngest(super::FileIngestEvent),
    }
}
/// An event signifying that data was streamed into a dataset.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataStreamEvent {
    /// The original write batches requests containing the streamed data.
    #[prost(message, repeated, tag = "1")]
    pub write_batches_request: ::prost::alloc::vec::Vec<
        super::super::direct_channel_writer::v2::InternalWriteBatchesRequest,
    >,
    /// Timestamp when this event was created.
    #[prost(message, optional, tag = "2")]
    pub event_timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
}
/// An event signifying that a file was ingested into a dataset.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileIngestEvent {
    /// The RID of the dataset the file was ingested into.
    #[prost(string, tag = "1")]
    pub dataset_rid: ::prost::alloc::string::String,
    /// The uuid of the ingested file.
    #[prost(string, tag = "2")]
    pub file_id: ::prost::alloc::string::String,
    /// Timestamp when this event was created.
    #[prost(message, optional, tag = "3")]
    pub event_timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
    /// JSON-serialized IngestRequest from the original ingest. Empty for old events.
    #[prost(bytes = "vec", tag = "4")]
    pub ingest_request: ::prost::alloc::vec::Vec<u8>,
}