nominal_api/proto/
nominal.events.v1.rs

1// This file is @generated by prost-build.
2/// Canonical event type.
3#[derive(Clone, PartialEq, ::prost::Message)]
4pub struct Event {
5    #[prost(oneof = "event::EventType", tags = "1, 2")]
6    pub event_type: ::core::option::Option<event::EventType>,
7}
8/// Nested message and enum types in `Event`.
9pub mod event {
10    #[derive(Clone, PartialEq, ::prost::Oneof)]
11    pub enum EventType {
12        #[prost(message, tag = "1")]
13        DataStream(super::DataStreamEvent),
14        #[prost(message, tag = "2")]
15        FileIngest(super::FileIngestEvent),
16    }
17}
18/// An event signifying that data was streamed into a dataset.
19#[derive(Clone, PartialEq, ::prost::Message)]
20pub struct DataStreamEvent {
21    /// The original write batches requests containing the streamed data.
22    #[prost(message, repeated, tag = "1")]
23    pub write_batches_request: ::prost::alloc::vec::Vec<
24        super::super::direct_channel_writer::v2::WriteBatchesRequest,
25    >,
26    /// Timestamp when this event was created.
27    #[prost(message, optional, tag = "2")]
28    pub event_timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
29}
30/// An event signifying that a file was ingested into a dataset.
31#[derive(Clone, PartialEq, ::prost::Message)]
32pub struct FileIngestEvent {
33    /// The RID of the dataset the file was ingested into.
34    #[prost(string, tag = "1")]
35    pub dataset_rid: ::prost::alloc::string::String,
36    /// The uuid of the ingested file.
37    #[prost(string, tag = "2")]
38    pub file_id: ::prost::alloc::string::String,
39    /// Timestamp when this event was created.
40    #[prost(message, optional, tag = "3")]
41    pub event_timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
42}
nominal_api/proto/nominal.events.v1.rs

nominal_api/proto/
nominal.events.v1.rs
