nominal_api_proto/proto/

nominal.file_store.v1.rs

// This file is @generated by prost-build.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Attribution {
    #[prost(message, optional, tag = "1")]
    pub time: ::core::option::Option<super::super::super::google::protobuf::Timestamp>,
    #[prost(string, tag = "2")]
    pub user_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Drive {
    #[prost(string, tag = "1")]
    pub rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub workspace_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub id: ::prost::alloc::string::String,
    #[prost(enumeration = "DriveState", tag = "4")]
    pub state: i32,
    #[prost(message, optional, tag = "5")]
    pub created: ::core::option::Option<Attribution>,
    #[prost(enumeration = "DriveSource", tag = "6")]
    pub source: i32,
    #[prost(enumeration = "DriveMutability", tag = "7")]
    pub content_mutability: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VirtualDrive {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub connection_details: ::core::option::Option<VirtualDriveConnectionDetails>,
    #[prost(message, optional, tag = "3")]
    pub status: ::core::option::Option<VirtualDriveStatus>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VirtualDriveDetails {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub connection_details: ::core::option::Option<VirtualDriveConnectionDetails>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VirtualDriveStatus {
    #[prost(enumeration = "VirtualDriveState", tag = "1")]
    pub state: i32,
    #[prost(message, optional, tag = "2")]
    pub last_successful_check_time: ::core::option::Option<
        super::super::super::google::protobuf::Timestamp,
    >,
    #[prost(string, tag = "3")]
    pub message: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VirtualDriveConnectionDetails {
    #[prost(oneof = "virtual_drive_connection_details::Details", tags = "1, 2, 3")]
    pub details: ::core::option::Option<virtual_drive_connection_details::Details>,
}
/// Nested message and enum types in `VirtualDriveConnectionDetails`.
pub mod virtual_drive_connection_details {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Details {
        #[prost(message, tag = "1")]
        S3(super::S3VirtualDriveConnectionDetails),
        #[prost(message, tag = "2")]
        GoogleDrive(super::GoogleDriveVirtualDriveConnectionDetails),
        #[prost(message, tag = "3")]
        Gcs(super::GcsVirtualDriveConnectionDetails),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct S3VirtualDriveConnectionDetails {
    #[prost(string, tag = "1")]
    pub bucket: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub prefix: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub credentials_secret_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub endpoint: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GoogleDriveVirtualDriveConnectionDetails {
    #[prost(string, tag = "1")]
    pub folder_id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub credentials_secret_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GcsVirtualDriveConnectionDetails {
    #[prost(string, tag = "1")]
    pub bucket: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub prefix: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub credentials_secret_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LogicalPath {
    #[prost(string, tag = "1")]
    pub path: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LogicalFile {
    #[prost(message, optional, tag = "1")]
    pub identity: ::core::option::Option<LogicalFileIdentity>,
    #[prost(message, optional, tag = "2")]
    pub path: ::core::option::Option<LogicalPath>,
    #[prost(enumeration = "FileState", tag = "3")]
    pub state: i32,
    #[prost(message, optional, tag = "4")]
    pub created: ::core::option::Option<Attribution>,
    #[prost(uint64, tag = "5")]
    pub size_bytes: u64,
    #[prost(message, optional, tag = "6")]
    pub observed: ::core::option::Option<Attribution>,
    #[prost(message, optional, tag = "7")]
    pub current_revision: ::core::option::Option<FileRevisionRef>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LogicalFileIdentity {
    #[prost(oneof = "logical_file_identity::Identity", tags = "1, 2")]
    pub identity: ::core::option::Option<logical_file_identity::Identity>,
}
/// Nested message and enum types in `LogicalFileIdentity`.
pub mod logical_file_identity {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Identity {
        #[prost(message, tag = "1")]
        Managed(super::ManagedFileIdentity),
        #[prost(message, tag = "2")]
        Virtual(super::VirtualFileIdentity),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManagedFileIdentity {
    #[prost(string, tag = "1")]
    pub file_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VirtualFileIdentity {
    #[prost(oneof = "virtual_file_identity::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<virtual_file_identity::Kind>,
}
/// Nested message and enum types in `VirtualFileIdentity`.
pub mod virtual_file_identity {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        S3(super::S3FileIdentity),
        #[prost(message, tag = "2")]
        GoogleDrive(super::GoogleDriveFileIdentity),
        #[prost(message, tag = "3")]
        Gcs(super::GcsFileIdentity),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct S3FileIdentity {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub path: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GoogleDriveFileIdentity {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub file_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GcsFileIdentity {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub path: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileRevisionRef {
    #[prost(oneof = "file_revision_ref::Reference", tags = "1, 2")]
    pub reference: ::core::option::Option<file_revision_ref::Reference>,
}
/// Nested message and enum types in `FileRevisionRef`.
pub mod file_revision_ref {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Reference {
        #[prost(message, tag = "1")]
        Managed(super::ManagedFileRevisionRef),
        #[prost(message, tag = "2")]
        Virtual(super::VirtualFileRevisionRef),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManagedFileRevisionRef {
    #[prost(string, tag = "1")]
    pub file_revision_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VirtualFileRevisionRef {
    #[prost(oneof = "virtual_file_revision_ref::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<virtual_file_revision_ref::Kind>,
}
/// Nested message and enum types in `VirtualFileRevisionRef`.
pub mod virtual_file_revision_ref {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        S3(super::S3FileRevisionRef),
        #[prost(message, tag = "2")]
        GoogleDrive(super::GoogleDriveFileRevisionRef),
        #[prost(message, tag = "3")]
        Gcs(super::GcsFileRevisionRef),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct S3FileRevisionRef {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub path: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub etag: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GoogleDriveFileRevisionRef {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub file_id: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub revision_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GcsFileRevisionRef {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub path: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub generation: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManagedFileRevision {
    #[prost(string, tag = "1")]
    pub file_revision_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub file_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "3")]
    pub path: ::core::option::Option<LogicalPath>,
    #[prost(uint64, tag = "4")]
    pub size_bytes: u64,
    #[prost(message, optional, tag = "5")]
    pub created: ::core::option::Option<Attribution>,
    #[prost(enumeration = "FileState", tag = "6")]
    pub state: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VirtualFileRevision {
    #[prost(string, tag = "1")]
    pub file_revision_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub file_identity: ::core::option::Option<VirtualFileIdentity>,
    #[prost(message, optional, tag = "3")]
    pub path: ::core::option::Option<LogicalPath>,
    #[prost(uint64, tag = "4")]
    pub size_bytes: u64,
    #[prost(message, optional, tag = "5")]
    pub observed: ::core::option::Option<Attribution>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Directory {
    #[prost(message, optional, tag = "1")]
    pub path: ::core::option::Option<LogicalPath>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileEntry {
    #[prost(oneof = "file_entry::Entry", tags = "1, 2")]
    pub entry: ::core::option::Option<file_entry::Entry>,
}
/// Nested message and enum types in `FileEntry`.
pub mod file_entry {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Entry {
        #[prost(message, tag = "1")]
        File(super::LogicalFile),
        #[prost(message, tag = "2")]
        Directory(super::Directory),
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DriveState {
    Unspecified = 0,
    Active = 1,
    Archived = 2,
}
impl DriveState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "DRIVE_STATE_UNSPECIFIED",
            Self::Active => "DRIVE_STATE_ACTIVE",
            Self::Archived => "DRIVE_STATE_ARCHIVED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "DRIVE_STATE_UNSPECIFIED" => Some(Self::Unspecified),
            "DRIVE_STATE_ACTIVE" => Some(Self::Active),
            "DRIVE_STATE_ARCHIVED" => Some(Self::Archived),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DriveSource {
    Unspecified = 0,
    Nominal = 1,
    S3 = 2,
    GoogleDrive = 3,
    Gcs = 4,
}
impl DriveSource {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "DRIVE_SOURCE_UNSPECIFIED",
            Self::Nominal => "DRIVE_SOURCE_NOMINAL",
            Self::S3 => "DRIVE_SOURCE_S3",
            Self::GoogleDrive => "DRIVE_SOURCE_GOOGLE_DRIVE",
            Self::Gcs => "DRIVE_SOURCE_GCS",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "DRIVE_SOURCE_UNSPECIFIED" => Some(Self::Unspecified),
            "DRIVE_SOURCE_NOMINAL" => Some(Self::Nominal),
            "DRIVE_SOURCE_S3" => Some(Self::S3),
            "DRIVE_SOURCE_GOOGLE_DRIVE" => Some(Self::GoogleDrive),
            "DRIVE_SOURCE_GCS" => Some(Self::Gcs),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DriveMutability {
    Unspecified = 0,
    Writable = 1,
    ReadOnly = 2,
}
impl DriveMutability {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "DRIVE_MUTABILITY_UNSPECIFIED",
            Self::Writable => "DRIVE_MUTABILITY_WRITABLE",
            Self::ReadOnly => "DRIVE_MUTABILITY_READ_ONLY",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "DRIVE_MUTABILITY_UNSPECIFIED" => Some(Self::Unspecified),
            "DRIVE_MUTABILITY_WRITABLE" => Some(Self::Writable),
            "DRIVE_MUTABILITY_READ_ONLY" => Some(Self::ReadOnly),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum VirtualDriveState {
    Unspecified = 0,
    Active = 1,
    AuthError = 2,
    Unreachable = 3,
    InvalidConfiguration = 4,
}
impl VirtualDriveState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "VIRTUAL_DRIVE_STATE_UNSPECIFIED",
            Self::Active => "VIRTUAL_DRIVE_STATE_ACTIVE",
            Self::AuthError => "VIRTUAL_DRIVE_STATE_AUTH_ERROR",
            Self::Unreachable => "VIRTUAL_DRIVE_STATE_UNREACHABLE",
            Self::InvalidConfiguration => "VIRTUAL_DRIVE_STATE_INVALID_CONFIGURATION",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "VIRTUAL_DRIVE_STATE_UNSPECIFIED" => Some(Self::Unspecified),
            "VIRTUAL_DRIVE_STATE_ACTIVE" => Some(Self::Active),
            "VIRTUAL_DRIVE_STATE_AUTH_ERROR" => Some(Self::AuthError),
            "VIRTUAL_DRIVE_STATE_UNREACHABLE" => Some(Self::Unreachable),
            "VIRTUAL_DRIVE_STATE_INVALID_CONFIGURATION" => {
                Some(Self::InvalidConfiguration)
            }
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum FileState {
    Unspecified = 0,
    Active = 1,
    Removed = 2,
}
impl FileState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "FILE_STATE_UNSPECIFIED",
            Self::Active => "FILE_STATE_ACTIVE",
            Self::Removed => "FILE_STATE_REMOVED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "FILE_STATE_UNSPECIFIED" => Some(Self::Unspecified),
            "FILE_STATE_ACTIVE" => Some(Self::Active),
            "FILE_STATE_REMOVED" => Some(Self::Removed),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum FileStoreError {
    Unspecified = 0,
    DriveNotFound = 1,
    FileNotFound = 2,
    FileRevisionNotFound = 3,
    PathAlreadyExists = 4,
    InvalidLogicalPath = 5,
    PermissionDenied = 6,
    RevisionPreconditionFailed = 7,
    VirtualDriveNotFound = 8,
    InvalidVirtualDriveConfiguration = 9,
    ReadOnlyDrive = 10,
    FileHistoryNotAvailable = 11,
    UpstreamUnavailable = 12,
    RevisionBytesReclaimed = 13,
    UpstreamFileNotFound = 14,
    DriveIdAlreadyExists = 15,
    VirtualDriveCredentialsNotFound = 16,
    VirtualDriveCredentialsInvalid = 17,
    VirtualDriveCredentialsRejected = 18,
    MaterializationFailed = 19,
    IngestRuleNotFound = 20,
    UploadedObjectNotFound = 21,
    InvalidObjectKey = 22,
    InvalidUpstreamState = 23,
}
impl FileStoreError {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "FILE_STORE_ERROR_UNSPECIFIED",
            Self::DriveNotFound => "FILE_STORE_ERROR_DRIVE_NOT_FOUND",
            Self::FileNotFound => "FILE_STORE_ERROR_FILE_NOT_FOUND",
            Self::FileRevisionNotFound => "FILE_STORE_ERROR_FILE_REVISION_NOT_FOUND",
            Self::PathAlreadyExists => "FILE_STORE_ERROR_PATH_ALREADY_EXISTS",
            Self::InvalidLogicalPath => "FILE_STORE_ERROR_INVALID_LOGICAL_PATH",
            Self::PermissionDenied => "FILE_STORE_ERROR_PERMISSION_DENIED",
            Self::RevisionPreconditionFailed => {
                "FILE_STORE_ERROR_REVISION_PRECONDITION_FAILED"
            }
            Self::VirtualDriveNotFound => "FILE_STORE_ERROR_VIRTUAL_DRIVE_NOT_FOUND",
            Self::InvalidVirtualDriveConfiguration => {
                "FILE_STORE_ERROR_INVALID_VIRTUAL_DRIVE_CONFIGURATION"
            }
            Self::ReadOnlyDrive => "FILE_STORE_ERROR_READ_ONLY_DRIVE",
            Self::FileHistoryNotAvailable => {
                "FILE_STORE_ERROR_FILE_HISTORY_NOT_AVAILABLE"
            }
            Self::UpstreamUnavailable => "FILE_STORE_ERROR_UPSTREAM_UNAVAILABLE",
            Self::RevisionBytesReclaimed => "FILE_STORE_ERROR_REVISION_BYTES_RECLAIMED",
            Self::UpstreamFileNotFound => "FILE_STORE_ERROR_UPSTREAM_FILE_NOT_FOUND",
            Self::DriveIdAlreadyExists => "FILE_STORE_ERROR_DRIVE_ID_ALREADY_EXISTS",
            Self::VirtualDriveCredentialsNotFound => {
                "FILE_STORE_ERROR_VIRTUAL_DRIVE_CREDENTIALS_NOT_FOUND"
            }
            Self::VirtualDriveCredentialsInvalid => {
                "FILE_STORE_ERROR_VIRTUAL_DRIVE_CREDENTIALS_INVALID"
            }
            Self::VirtualDriveCredentialsRejected => {
                "FILE_STORE_ERROR_VIRTUAL_DRIVE_CREDENTIALS_REJECTED"
            }
            Self::MaterializationFailed => "FILE_STORE_ERROR_MATERIALIZATION_FAILED",
            Self::IngestRuleNotFound => "FILE_STORE_ERROR_INGEST_RULE_NOT_FOUND",
            Self::UploadedObjectNotFound => "FILE_STORE_ERROR_UPLOADED_OBJECT_NOT_FOUND",
            Self::InvalidObjectKey => "FILE_STORE_ERROR_INVALID_OBJECT_KEY",
            Self::InvalidUpstreamState => "FILE_STORE_ERROR_INVALID_UPSTREAM_STATE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "FILE_STORE_ERROR_UNSPECIFIED" => Some(Self::Unspecified),
            "FILE_STORE_ERROR_DRIVE_NOT_FOUND" => Some(Self::DriveNotFound),
            "FILE_STORE_ERROR_FILE_NOT_FOUND" => Some(Self::FileNotFound),
            "FILE_STORE_ERROR_FILE_REVISION_NOT_FOUND" => {
                Some(Self::FileRevisionNotFound)
            }
            "FILE_STORE_ERROR_PATH_ALREADY_EXISTS" => Some(Self::PathAlreadyExists),
            "FILE_STORE_ERROR_INVALID_LOGICAL_PATH" => Some(Self::InvalidLogicalPath),
            "FILE_STORE_ERROR_PERMISSION_DENIED" => Some(Self::PermissionDenied),
            "FILE_STORE_ERROR_REVISION_PRECONDITION_FAILED" => {
                Some(Self::RevisionPreconditionFailed)
            }
            "FILE_STORE_ERROR_VIRTUAL_DRIVE_NOT_FOUND" => {
                Some(Self::VirtualDriveNotFound)
            }
            "FILE_STORE_ERROR_INVALID_VIRTUAL_DRIVE_CONFIGURATION" => {
                Some(Self::InvalidVirtualDriveConfiguration)
            }
            "FILE_STORE_ERROR_READ_ONLY_DRIVE" => Some(Self::ReadOnlyDrive),
            "FILE_STORE_ERROR_FILE_HISTORY_NOT_AVAILABLE" => {
                Some(Self::FileHistoryNotAvailable)
            }
            "FILE_STORE_ERROR_UPSTREAM_UNAVAILABLE" => Some(Self::UpstreamUnavailable),
            "FILE_STORE_ERROR_REVISION_BYTES_RECLAIMED" => {
                Some(Self::RevisionBytesReclaimed)
            }
            "FILE_STORE_ERROR_UPSTREAM_FILE_NOT_FOUND" => {
                Some(Self::UpstreamFileNotFound)
            }
            "FILE_STORE_ERROR_DRIVE_ID_ALREADY_EXISTS" => {
                Some(Self::DriveIdAlreadyExists)
            }
            "FILE_STORE_ERROR_VIRTUAL_DRIVE_CREDENTIALS_NOT_FOUND" => {
                Some(Self::VirtualDriveCredentialsNotFound)
            }
            "FILE_STORE_ERROR_VIRTUAL_DRIVE_CREDENTIALS_INVALID" => {
                Some(Self::VirtualDriveCredentialsInvalid)
            }
            "FILE_STORE_ERROR_VIRTUAL_DRIVE_CREDENTIALS_REJECTED" => {
                Some(Self::VirtualDriveCredentialsRejected)
            }
            "FILE_STORE_ERROR_MATERIALIZATION_FAILED" => {
                Some(Self::MaterializationFailed)
            }
            "FILE_STORE_ERROR_INGEST_RULE_NOT_FOUND" => Some(Self::IngestRuleNotFound),
            "FILE_STORE_ERROR_UPLOADED_OBJECT_NOT_FOUND" => {
                Some(Self::UploadedObjectNotFound)
            }
            "FILE_STORE_ERROR_INVALID_OBJECT_KEY" => Some(Self::InvalidObjectKey),
            "FILE_STORE_ERROR_INVALID_UPSTREAM_STATE" => Some(Self::InvalidUpstreamState),
            _ => None,
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateDriveRequest {
    #[prost(string, tag = "1")]
    pub workspace_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateDriveResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateVirtualDriveRequest {
    #[prost(string, tag = "1")]
    pub workspace_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub id: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "3")]
    pub connection_details: ::core::option::Option<VirtualDriveConnectionDetails>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateVirtualDriveResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
    #[prost(message, optional, tag = "2")]
    pub virtual_drive: ::core::option::Option<VirtualDrive>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDriveRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDriveResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveDetailsRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveDetailsResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
    #[prost(message, optional, tag = "2")]
    pub virtual_drive_details: ::core::option::Option<VirtualDriveDetails>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveStatusRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveStatusResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<VirtualDriveStatus>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDriveByIdRequest {
    #[prost(string, tag = "1")]
    pub workspace_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDriveByIdResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveDetailsByIdRequest {
    #[prost(string, tag = "1")]
    pub workspace_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveDetailsByIdResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
    #[prost(message, optional, tag = "2")]
    pub virtual_drive_details: ::core::option::Option<VirtualDriveDetails>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveStatusByIdRequest {
    #[prost(string, tag = "1")]
    pub workspace_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVirtualDriveStatusByIdResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<VirtualDriveStatus>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDrivesRequest {
    #[prost(string, tag = "1")]
    pub workspace_rid: ::prost::alloc::string::String,
    #[prost(bool, tag = "2")]
    pub include_archived: bool,
    #[prost(int32, optional, tag = "3")]
    pub page_size: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "4")]
    pub page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDrivesResponse {
    #[prost(message, repeated, tag = "1")]
    pub drives: ::prost::alloc::vec::Vec<Drive>,
    #[prost(string, optional, tag = "2")]
    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateVirtualDriveRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub connection_details: ::core::option::Option<VirtualDriveConnectionDetails>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateVirtualDriveResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
    #[prost(message, optional, tag = "2")]
    pub virtual_drive: ::core::option::Option<VirtualDrive>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateDriveDetailsRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "2")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateDriveDetailsResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveDriveRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveDriveResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnarchiveDriveRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnarchiveDriveResponse {
    #[prost(message, optional, tag = "1")]
    pub drive: ::core::option::Option<Drive>,
}
/// Generated client implementations.
pub mod drives_service_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct DrivesServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl DrivesServiceClient<tonic::transport::Channel> {
        /// Attempt to create a new client by connecting to a given endpoint.
        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
        where
            D: TryInto<tonic::transport::Endpoint>,
            D::Error: Into<StdError>,
        {
            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
            Ok(Self::new(conn))
        }
    }
    impl<T> DrivesServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> DrivesServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            DrivesServiceClient::new(InterceptedService::new(inner, interceptor))
        }
        /// Compress requests with the given encoding.
        ///
        /// This requires the server to support it otherwise it might respond with an
        /// error.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.send_compressed(encoding);
            self
        }
        /// Enable decompressing responses.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.accept_compressed(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_decoding_message_size(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_encoding_message_size(limit);
            self
        }
        pub async fn create_drive(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateDriveRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateDriveResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/CreateDrive",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.file_store.v1.DrivesService", "CreateDrive"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn create_virtual_drive(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateVirtualDriveRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateVirtualDriveResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/CreateVirtualDrive",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "CreateVirtualDrive",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_drive(
            &mut self,
            request: impl tonic::IntoRequest<super::GetDriveRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetDriveResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/GetDrive",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.file_store.v1.DrivesService", "GetDrive"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_virtual_drive_details(
            &mut self,
            request: impl tonic::IntoRequest<super::GetVirtualDriveDetailsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetVirtualDriveDetailsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/GetVirtualDriveDetails",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "GetVirtualDriveDetails",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_virtual_drive_status(
            &mut self,
            request: impl tonic::IntoRequest<super::GetVirtualDriveStatusRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetVirtualDriveStatusResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/GetVirtualDriveStatus",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "GetVirtualDriveStatus",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_drive_by_id(
            &mut self,
            request: impl tonic::IntoRequest<super::GetDriveByIdRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetDriveByIdResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/GetDriveById",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "GetDriveById",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_virtual_drive_details_by_id(
            &mut self,
            request: impl tonic::IntoRequest<super::GetVirtualDriveDetailsByIdRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetVirtualDriveDetailsByIdResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/GetVirtualDriveDetailsById",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "GetVirtualDriveDetailsById",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_virtual_drive_status_by_id(
            &mut self,
            request: impl tonic::IntoRequest<super::GetVirtualDriveStatusByIdRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetVirtualDriveStatusByIdResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/GetVirtualDriveStatusById",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "GetVirtualDriveStatusById",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_drives(
            &mut self,
            request: impl tonic::IntoRequest<super::ListDrivesRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListDrivesResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/ListDrives",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.file_store.v1.DrivesService", "ListDrives"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_virtual_drive(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateVirtualDriveRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UpdateVirtualDriveResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/UpdateVirtualDrive",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "UpdateVirtualDrive",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_drive_details(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateDriveDetailsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UpdateDriveDetailsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/UpdateDriveDetails",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "UpdateDriveDetails",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn archive_drive(
            &mut self,
            request: impl tonic::IntoRequest<super::ArchiveDriveRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ArchiveDriveResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/ArchiveDrive",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "ArchiveDrive",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn unarchive_drive(
            &mut self,
            request: impl tonic::IntoRequest<super::UnarchiveDriveRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UnarchiveDriveResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.DrivesService/UnarchiveDrive",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.DrivesService",
                        "UnarchiveDrive",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UploadedObjectRef {
    #[prost(string, tag = "1")]
    pub object_key: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PathTarget {
    #[prost(message, optional, tag = "1")]
    pub path: ::core::option::Option<LogicalPath>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Destination {
    #[prost(oneof = "destination::Target", tags = "1, 2")]
    pub target: ::core::option::Option<destination::Target>,
}
/// Nested message and enum types in `Destination`.
pub mod destination {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Target {
        #[prost(message, tag = "1")]
        Path(super::PathTarget),
        #[prost(string, tag = "2")]
        FileRevisionRid(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PutFile {
    #[prost(message, optional, tag = "1")]
    pub object: ::core::option::Option<UploadedObjectRef>,
    #[prost(uint64, tag = "2")]
    pub size_bytes: u64,
    #[prost(message, optional, tag = "3")]
    pub destination: ::core::option::Option<Destination>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MoveFile {
    #[prost(string, tag = "1")]
    pub source_revision_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub destination: ::core::option::Option<Destination>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RemoveFile {
    #[prost(string, tag = "1")]
    pub revision_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RestoreFile {
    #[prost(string, tag = "1")]
    pub restore_revision_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub destination: ::core::option::Option<Destination>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileChange {
    #[prost(oneof = "file_change::Change", tags = "1, 2, 3, 4")]
    pub change: ::core::option::Option<file_change::Change>,
}
/// Nested message and enum types in `FileChange`.
pub mod file_change {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Change {
        #[prost(message, tag = "1")]
        Put(super::PutFile),
        #[prost(message, tag = "2")]
        Move(super::MoveFile),
        #[prost(message, tag = "3")]
        Remove(super::RemoveFile),
        #[prost(message, tag = "4")]
        Restore(super::RestoreFile),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetFileRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub path: ::core::option::Option<LogicalPath>,
    #[prost(bool, tag = "3")]
    pub include_removed: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetFileByIdentityRequest {
    #[prost(message, optional, tag = "1")]
    pub identity: ::core::option::Option<LogicalFileIdentity>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetFileResponse {
    #[prost(message, optional, tag = "1")]
    pub file: ::core::option::Option<LogicalFile>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetFileByIdentityResponse {
    #[prost(message, optional, tag = "1")]
    pub file: ::core::option::Option<LogicalFile>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ResolveFileRevisionRequest {
    #[prost(message, optional, tag = "2")]
    pub source_ref: ::core::option::Option<FileRevisionRef>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ResolveFileRevisionResponse {
    #[prost(string, tag = "1")]
    pub file_revision_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListFilesRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub parent_path: ::core::option::Option<LogicalPath>,
    #[prost(bool, tag = "3")]
    pub include_removed: bool,
    #[prost(int32, optional, tag = "4")]
    pub page_size: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "5")]
    pub page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListFilesResponse {
    #[prost(message, repeated, tag = "1")]
    pub entries: ::prost::alloc::vec::Vec<FileEntry>,
    #[prost(string, optional, tag = "2")]
    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ApplyFileChangesRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub changes: ::prost::alloc::vec::Vec<FileChange>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ApplyFileChangesResponse {
    #[prost(message, repeated, tag = "1")]
    pub results: ::prost::alloc::vec::Vec<FileChangeResult>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileChangeSuccess {
    #[prost(message, optional, tag = "1")]
    pub file: ::core::option::Option<LogicalFile>,
    #[prost(message, optional, tag = "2")]
    pub file_revision: ::core::option::Option<ManagedFileRevision>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileChangeFailure {
    #[prost(enumeration = "FileStoreError", tag = "1")]
    pub code: i32,
    #[prost(string, tag = "2")]
    pub message: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileChangeResult {
    #[prost(oneof = "file_change_result::Result", tags = "1, 2")]
    pub result: ::core::option::Option<file_change_result::Result>,
}
/// Nested message and enum types in `FileChangeResult`.
pub mod file_change_result {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Result {
        #[prost(message, tag = "1")]
        Success(super::FileChangeSuccess),
        #[prost(message, tag = "2")]
        Failure(super::FileChangeFailure),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListFileRevisionsRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub file_rid: ::prost::alloc::string::String,
    #[prost(int32, optional, tag = "3")]
    pub page_size: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "4")]
    pub page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListFileRevisionsResponse {
    #[prost(message, repeated, tag = "1")]
    pub file_revisions: ::prost::alloc::vec::Vec<ManagedFileRevision>,
    #[prost(string, optional, tag = "2")]
    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PurgeFileRequest {
    #[prost(string, tag = "1")]
    pub file_revision_rid: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct PurgeFileResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDownloadUrlRequest {
    #[prost(string, tag = "1")]
    pub file_revision_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDownloadUrlResponse {
    #[prost(string, tag = "1")]
    pub url: ::prost::alloc::string::String,
}
/// Generated client implementations.
pub mod files_service_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct FilesServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl FilesServiceClient<tonic::transport::Channel> {
        /// Attempt to create a new client by connecting to a given endpoint.
        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
        where
            D: TryInto<tonic::transport::Endpoint>,
            D::Error: Into<StdError>,
        {
            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
            Ok(Self::new(conn))
        }
    }
    impl<T> FilesServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> FilesServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            FilesServiceClient::new(InterceptedService::new(inner, interceptor))
        }
        /// Compress requests with the given encoding.
        ///
        /// This requires the server to support it otherwise it might respond with an
        /// error.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.send_compressed(encoding);
            self
        }
        /// Enable decompressing responses.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.accept_compressed(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_decoding_message_size(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_encoding_message_size(limit);
            self
        }
        pub async fn get_file(
            &mut self,
            request: impl tonic::IntoRequest<super::GetFileRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetFileResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/GetFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.file_store.v1.FilesService", "GetFile"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_file_by_identity(
            &mut self,
            request: impl tonic::IntoRequest<super::GetFileByIdentityRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetFileByIdentityResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/GetFileByIdentity",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.FilesService",
                        "GetFileByIdentity",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn resolve_file_revision(
            &mut self,
            request: impl tonic::IntoRequest<super::ResolveFileRevisionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ResolveFileRevisionResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/ResolveFileRevision",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.FilesService",
                        "ResolveFileRevision",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_files(
            &mut self,
            request: impl tonic::IntoRequest<super::ListFilesRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListFilesResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/ListFiles",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.file_store.v1.FilesService", "ListFiles"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn apply_file_changes(
            &mut self,
            request: impl tonic::IntoRequest<super::ApplyFileChangesRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ApplyFileChangesResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/ApplyFileChanges",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.FilesService",
                        "ApplyFileChanges",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_file_revisions(
            &mut self,
            request: impl tonic::IntoRequest<super::ListFileRevisionsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListFileRevisionsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/ListFileRevisions",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.FilesService",
                        "ListFileRevisions",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn purge_file(
            &mut self,
            request: impl tonic::IntoRequest<super::PurgeFileRequest>,
        ) -> std::result::Result<
            tonic::Response<super::PurgeFileResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/PurgeFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.file_store.v1.FilesService", "PurgeFile"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_download_url(
            &mut self,
            request: impl tonic::IntoRequest<super::GetDownloadUrlRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetDownloadUrlResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.FilesService/GetDownloadUrl",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.FilesService",
                        "GetDownloadUrl",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateIngestRuleRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub matcher: ::core::option::Option<FileMatcher>,
    #[prost(message, optional, tag = "3")]
    pub triggers: ::core::option::Option<IngestTriggers>,
    #[prost(enumeration = "BackfillMode", tag = "4")]
    pub backfill_mode: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateIngestRuleResponse {
    #[prost(message, optional, tag = "1")]
    pub rule: ::core::option::Option<IngestRule>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListIngestRulesRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(bool, tag = "2")]
    pub include_archived: bool,
    #[prost(int32, optional, tag = "3")]
    pub page_size: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "4")]
    pub page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListIngestRulesResponse {
    #[prost(message, repeated, tag = "1")]
    pub rules: ::prost::alloc::vec::Vec<IngestRule>,
    #[prost(string, optional, tag = "2")]
    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetIngestRuleRequest {
    #[prost(string, tag = "1")]
    pub rule_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetIngestRuleResponse {
    #[prost(message, optional, tag = "1")]
    pub rule: ::core::option::Option<IngestRule>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateIngestRuleRequest {
    #[prost(string, tag = "1")]
    pub rule_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub matcher: ::core::option::Option<FileMatcher>,
    #[prost(message, optional, tag = "3")]
    pub triggers: ::core::option::Option<IngestTriggers>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateIngestRuleResponse {
    #[prost(message, optional, tag = "1")]
    pub rule: ::core::option::Option<IngestRule>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveIngestRuleRequest {
    #[prost(string, tag = "1")]
    pub rule_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveIngestRuleResponse {
    #[prost(message, optional, tag = "1")]
    pub rule: ::core::option::Option<IngestRule>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnarchiveIngestRuleRequest {
    #[prost(string, tag = "1")]
    pub rule_rid: ::prost::alloc::string::String,
    #[prost(enumeration = "BackfillMode", tag = "2")]
    pub backfill_mode: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnarchiveIngestRuleResponse {
    #[prost(message, optional, tag = "1")]
    pub rule: ::core::option::Option<IngestRule>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IngestRule {
    #[prost(string, tag = "1")]
    pub rule_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "3")]
    pub matcher: ::core::option::Option<FileMatcher>,
    #[prost(message, optional, tag = "4")]
    pub triggers: ::core::option::Option<IngestTriggers>,
    #[prost(message, optional, tag = "5")]
    pub created: ::core::option::Option<Attribution>,
    #[prost(enumeration = "IngestRuleState", tag = "6")]
    pub state: i32,
    #[prost(message, optional, tag = "7")]
    pub archived: ::core::option::Option<Attribution>,
    #[prost(message, optional, tag = "8")]
    pub updated: ::core::option::Option<Attribution>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileMatcher {
    #[prost(oneof = "file_matcher::Matcher", tags = "1")]
    pub matcher: ::core::option::Option<file_matcher::Matcher>,
}
/// Nested message and enum types in `FileMatcher`.
pub mod file_matcher {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Matcher {
        #[prost(message, tag = "1")]
        Path(super::PathMatcher),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PathMatcher {
    #[prost(message, optional, tag = "1")]
    pub pattern: ::core::option::Option<PathPattern>,
    #[prost(message, optional, tag = "2")]
    pub format: ::core::option::Option<FormatConfig>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FormatConfig {
    #[prost(oneof = "format_config::Format", tags = "1, 2")]
    pub format: ::core::option::Option<format_config::Format>,
}
/// Nested message and enum types in `FormatConfig`.
pub mod format_config {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Format {
        #[prost(message, tag = "1")]
        Csv(super::CsvIngestConfig),
        #[prost(message, tag = "2")]
        Parquet(super::ParquetIngestConfig),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CsvIngestConfig {
    #[prost(message, optional, tag = "1")]
    pub timestamp: ::core::option::Option<TimestampConfig>,
    #[prost(string, optional, tag = "2")]
    pub channel_prefix: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ParquetIngestConfig {
    #[prost(message, optional, tag = "1")]
    pub timestamp: ::core::option::Option<TimestampConfig>,
    #[prost(string, optional, tag = "2")]
    pub channel_prefix: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TimestampConfig {
    #[prost(oneof = "timestamp_config::Kind", tags = "1")]
    pub kind: ::core::option::Option<timestamp_config::Kind>,
}
/// Nested message and enum types in `TimestampConfig`.
pub mod timestamp_config {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        Single(super::TimestampCandidate),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TimestampCandidate {
    #[prost(string, tag = "1")]
    pub column: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub r#type: ::core::option::Option<super::super::types::time::AbsoluteTimestamp>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PathPattern {
    #[prost(message, optional, tag = "1")]
    pub first: ::core::option::Option<PatternSegment>,
    #[prost(message, repeated, tag = "2")]
    pub rest: ::prost::alloc::vec::Vec<JoinedSegment>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct JoinedSegment {
    #[prost(enumeration = "SegmentDelimiter", tag = "1")]
    pub delimiter: i32,
    #[prost(message, optional, tag = "2")]
    pub segment: ::core::option::Option<PatternSegment>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PatternSegment {
    #[prost(oneof = "pattern_segment::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<pattern_segment::Kind>,
}
/// Nested message and enum types in `PatternSegment`.
pub mod pattern_segment {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        ShallowWildcard(super::ShallowWildcard),
        #[prost(message, tag = "2")]
        DeepWildcard(super::DeepWildcard),
        #[prost(string, tag = "3")]
        Literal(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ShallowWildcard {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DeepWildcard {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IngestTriggers {
    #[prost(message, optional, tag = "1")]
    pub new_match: ::core::option::Option<IngestTarget>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IngestTarget {
    #[prost(oneof = "ingest_target::Target", tags = "1, 2")]
    pub target: ::core::option::Option<ingest_target::Target>,
}
/// Nested message and enum types in `IngestTarget`.
pub mod ingest_target {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Target {
        #[prost(message, tag = "1")]
        NewDataset(super::NewDatasetTarget),
        #[prost(message, tag = "2")]
        ExistingDataset(super::ExistingDatasetTarget),
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct NewDatasetTarget {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ExistingDatasetTarget {
    #[prost(string, tag = "1")]
    pub dataset_rid: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum BackfillMode {
    Unspecified = 0,
    NewFilesOnly = 1,
    BackfillExisting = 2,
}
impl BackfillMode {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "BACKFILL_MODE_UNSPECIFIED",
            Self::NewFilesOnly => "BACKFILL_MODE_NEW_FILES_ONLY",
            Self::BackfillExisting => "BACKFILL_MODE_BACKFILL_EXISTING",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "BACKFILL_MODE_UNSPECIFIED" => Some(Self::Unspecified),
            "BACKFILL_MODE_NEW_FILES_ONLY" => Some(Self::NewFilesOnly),
            "BACKFILL_MODE_BACKFILL_EXISTING" => Some(Self::BackfillExisting),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum IngestRuleState {
    Unspecified = 0,
    Active = 1,
    Archived = 2,
}
impl IngestRuleState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "INGEST_RULE_STATE_UNSPECIFIED",
            Self::Active => "INGEST_RULE_STATE_ACTIVE",
            Self::Archived => "INGEST_RULE_STATE_ARCHIVED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "INGEST_RULE_STATE_UNSPECIFIED" => Some(Self::Unspecified),
            "INGEST_RULE_STATE_ACTIVE" => Some(Self::Active),
            "INGEST_RULE_STATE_ARCHIVED" => Some(Self::Archived),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SegmentDelimiter {
    Unspecified = 0,
    PathSeparator = 1,
    Concat = 2,
}
impl SegmentDelimiter {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "SEGMENT_DELIMITER_UNSPECIFIED",
            Self::PathSeparator => "SEGMENT_DELIMITER_PATH_SEPARATOR",
            Self::Concat => "SEGMENT_DELIMITER_CONCAT",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SEGMENT_DELIMITER_UNSPECIFIED" => Some(Self::Unspecified),
            "SEGMENT_DELIMITER_PATH_SEPARATOR" => Some(Self::PathSeparator),
            "SEGMENT_DELIMITER_CONCAT" => Some(Self::Concat),
            _ => None,
        }
    }
}
/// Generated client implementations.
pub mod internal_ingest_rules_service_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct InternalIngestRulesServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl InternalIngestRulesServiceClient<tonic::transport::Channel> {
        /// Attempt to create a new client by connecting to a given endpoint.
        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
        where
            D: TryInto<tonic::transport::Endpoint>,
            D::Error: Into<StdError>,
        {
            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
            Ok(Self::new(conn))
        }
    }
    impl<T> InternalIngestRulesServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> InternalIngestRulesServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            InternalIngestRulesServiceClient::new(
                InterceptedService::new(inner, interceptor),
            )
        }
        /// Compress requests with the given encoding.
        ///
        /// This requires the server to support it otherwise it might respond with an
        /// error.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.send_compressed(encoding);
            self
        }
        /// Enable decompressing responses.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.accept_compressed(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_decoding_message_size(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_encoding_message_size(limit);
            self
        }
        pub async fn create_ingest_rule(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateIngestRuleRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateIngestRuleResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.InternalIngestRulesService/CreateIngestRule",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.InternalIngestRulesService",
                        "CreateIngestRule",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_ingest_rules(
            &mut self,
            request: impl tonic::IntoRequest<super::ListIngestRulesRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListIngestRulesResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.InternalIngestRulesService/ListIngestRules",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.InternalIngestRulesService",
                        "ListIngestRules",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_ingest_rule(
            &mut self,
            request: impl tonic::IntoRequest<super::GetIngestRuleRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetIngestRuleResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.InternalIngestRulesService/GetIngestRule",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.InternalIngestRulesService",
                        "GetIngestRule",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_ingest_rule(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateIngestRuleRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UpdateIngestRuleResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.InternalIngestRulesService/UpdateIngestRule",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.InternalIngestRulesService",
                        "UpdateIngestRule",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn archive_ingest_rule(
            &mut self,
            request: impl tonic::IntoRequest<super::ArchiveIngestRuleRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ArchiveIngestRuleResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.InternalIngestRulesService/ArchiveIngestRule",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.InternalIngestRulesService",
                        "ArchiveIngestRule",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn unarchive_ingest_rule(
            &mut self,
            request: impl tonic::IntoRequest<super::UnarchiveIngestRuleRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UnarchiveIngestRuleResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.file_store.v1.InternalIngestRulesService/UnarchiveIngestRule",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.file_store.v1.InternalIngestRulesService",
                        "UnarchiveIngestRule",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}