goosefs-sdk 0.1.0

// This file is @generated by prost-build.
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct FsOpPId {
    #[prost(int64, optional, tag = "1")]
    pub most_significant_bits: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "2")]
    pub least_significant_bits: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct FileSystemMasterCommonPOptions {
    #[prost(int64, optional, tag = "1")]
    pub sync_interval_ms: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "4")]
    pub operation_id: ::core::option::Option<FsOpPId>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAccessPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<CheckAccessPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CheckAccessPResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CheckAccessPOptions {
    #[prost(enumeration = "super::Bits", optional, tag = "1")]
    pub bits: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "2")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckConsistencyPResponse {
    #[prost(string, repeated, tag = "1")]
    pub inconsistent_paths: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CheckConsistencyPOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckConsistencyPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<CheckConsistencyPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CompleteFilePResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CompleteFilePOptions {
    #[prost(int64, optional, tag = "1")]
    pub ufs_length: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "2")]
    pub async_persist_options: ::core::option::Option<ScheduleAsyncPersistencePOptions>,
    #[prost(message, optional, tag = "3")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CompleteFilePRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<CompleteFilePOptions>,
    #[prost(int64, optional, tag = "3")]
    pub inode_id: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct OpenFilePOptions {
    #[prost(enumeration = "ReadPType", optional, tag = "1")]
    pub read_type: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "2")]
    pub max_ufs_read_concurrency: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "3")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(bool, optional, tag = "4", default = "true")]
    pub update_last_access_time: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CreateDirectoryPResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CreateDirectoryPOptions {
    #[prost(bool, optional, tag = "1")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "2")]
    pub allow_exists: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "3")]
    pub mode: ::core::option::Option<super::PMode>,
    #[prost(enumeration = "WritePType", optional, tag = "4")]
    pub write_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "5")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(enumeration = "WritePType", optional, tag = "6")]
    pub default_write_type: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateDirectoryPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<CreateDirectoryPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateFilePResponse {
    #[prost(message, optional, tag = "1")]
    pub file_info: ::core::option::Option<FileInfo>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CreateFilePOptions {
    #[prost(int64, optional, tag = "1")]
    pub block_size_bytes: ::core::option::Option<i64>,
    #[prost(bool, optional, tag = "2")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "3")]
    pub mode: ::core::option::Option<super::PMode>,
    #[prost(enumeration = "WritePType", optional, tag = "4")]
    pub write_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "5")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(int64, optional, tag = "6")]
    pub persistence_wait_time: ::core::option::Option<i64>,
    #[prost(enumeration = "WritePType", optional, tag = "7")]
    pub default_write_type: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateFilePRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<CreateFilePOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DeletePResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DeletePOptions {
    #[prost(bool, optional, tag = "1")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "2")]
    pub goosefs_only: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3")]
    pub unchecked: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub ttl: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeletePRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<DeletePOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct FreePResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct FreePOptions {
    #[prost(bool, optional, tag = "1")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "2")]
    pub forced: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "3")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FreePRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<FreePOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetStatusPResponse {
    #[prost(message, optional, tag = "1")]
    pub file_info: ::core::option::Option<FileInfo>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetStatusPOptions {
    #[prost(enumeration = "LoadMetadataPType", optional, tag = "1")]
    pub load_metadata_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "2")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(enumeration = "super::Bits", optional, tag = "3")]
    pub access_mode: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "4", default = "true")]
    pub update_timestamps: ::core::option::Option<bool>,
    #[prost(enumeration = "LoadMetadataPType", optional, tag = "5")]
    pub default_load_metadata_type: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub resolve_link: ::core::option::Option<bool>,
    #[prost(int32, optional, tag = "7", default = "0")]
    pub check_block_replicas: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetStatusPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<GetStatusPOptions>,
    #[prost(string, optional, tag = "3")]
    pub request_id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ExistsPOptions {
    #[prost(enumeration = "LoadMetadataPType", optional, tag = "1")]
    pub load_metadata_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "2")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(enumeration = "LoadMetadataPType", optional, tag = "3")]
    pub default_load_metadata_type: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SyncPointInfo {
    #[prost(string, optional, tag = "1")]
    pub sync_point_uri: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "SyncPointStatus", optional, tag = "2")]
    pub sync_status: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetSyncPathListPResponse {
    #[prost(message, repeated, tag = "1")]
    pub sync_paths: ::prost::alloc::vec::Vec<SyncPointInfo>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetSyncPathListPRequest {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListStatusPResponse {
    #[prost(message, repeated, tag = "1")]
    pub file_infos: ::prost::alloc::vec::Vec<FileInfo>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ListStatusPOptions {
    #[prost(bool, optional, tag = "1")]
    pub load_direct_children: ::core::option::Option<bool>,
    #[prost(enumeration = "LoadMetadataPType", optional, tag = "2")]
    pub load_metadata_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "3")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(bool, optional, tag = "4")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5")]
    pub load_metadata_only: ::core::option::Option<bool>,
    #[prost(enumeration = "LoadMetadataPType", optional, tag = "6")]
    pub default_load_metadata_type: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub is_load_metadata: ::core::option::Option<bool>,
    #[prost(int32, optional, tag = "8", default = "0")]
    pub check_block_replicas: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListStatusPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<ListStatusPOptions>,
    #[prost(string, optional, tag = "3")]
    pub request_id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListNamespacePResponse {
    #[prost(message, repeated, tag = "1")]
    pub file_info: ::prost::alloc::vec::Vec<FileInfo>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ListNamespacePOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ListNamespacePRequest {
    #[prost(message, optional, tag = "1")]
    pub options: ::core::option::Option<ListNamespacePOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StatNamespacePResponse {
    #[prost(message, optional, tag = "1")]
    pub file_info: ::core::option::Option<FileInfo>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct StatNamespacePOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StatNamespacePRequest {
    #[prost(string, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<StatNamespacePOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct LoadMetadataPOptions {
    #[prost(bool, optional, tag = "1")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "2")]
    pub create_ancestors: ::core::option::Option<bool>,
    #[prost(enumeration = "super::fscommon::LoadDescendantPType", optional, tag = "3")]
    pub load_descendant_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "4")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PAclEntry {
    #[prost(enumeration = "PAclEntryType", optional, tag = "1")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "2")]
    pub subject: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "PAclAction", repeated, packed = "false", tag = "3")]
    pub actions: ::prost::alloc::vec::Vec<i32>,
    #[prost(bool, optional, tag = "4")]
    pub is_default: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PAcl {
    #[prost(string, optional, tag = "1")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub owning_group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "3")]
    pub entries: ::prost::alloc::vec::Vec<PAclEntry>,
    #[prost(int32, optional, tag = "4")]
    pub mode: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "5")]
    pub is_default: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6")]
    pub is_default_empty: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileBlockInfo {
    #[prost(message, optional, tag = "1")]
    pub block_info: ::core::option::Option<super::BlockInfo>,
    #[prost(int64, optional, tag = "2")]
    pub offset: ::core::option::Option<i64>,
    #[prost(message, repeated, tag = "3")]
    pub ufs_locations: ::prost::alloc::vec::Vec<super::WorkerNetAddress>,
    #[prost(string, repeated, tag = "4")]
    pub ufs_string_locations: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileInfo {
    #[prost(int64, optional, tag = "1")]
    pub file_id: ::core::option::Option<i64>,
    #[prost(string, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "3")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "4")]
    pub ufs_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(int64, optional, tag = "5")]
    pub length: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "6")]
    pub block_size_bytes: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "7")]
    pub creation_time_ms: ::core::option::Option<i64>,
    #[prost(bool, optional, tag = "8")]
    pub completed: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9")]
    pub folder: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "10")]
    pub cacheable: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "11")]
    pub persisted: ::core::option::Option<bool>,
    #[prost(int64, repeated, packed = "false", tag = "12")]
    pub block_ids: ::prost::alloc::vec::Vec<i64>,
    #[prost(int64, optional, tag = "13")]
    pub last_modification_time_ms: ::core::option::Option<i64>,
    #[prost(string, optional, tag = "14")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "15")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(int32, optional, tag = "16")]
    pub mode: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "17")]
    pub persistence_state: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "18")]
    pub mount_point: ::core::option::Option<bool>,
    #[prost(message, repeated, tag = "19")]
    pub file_block_infos: ::prost::alloc::vec::Vec<FileBlockInfo>,
    #[prost(int64, optional, tag = "20")]
    pub mount_id: ::core::option::Option<i64>,
    #[prost(int32, optional, tag = "21")]
    pub in_goose_fs_percentage: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "22")]
    pub in_memory_percentage: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "23")]
    pub ufs_fingerprint: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "24")]
    pub acl: ::core::option::Option<PAcl>,
    #[prost(message, optional, tag = "25")]
    pub default_acl: ::core::option::Option<PAcl>,
    #[prost(int64, optional, tag = "26")]
    pub last_access_time_ms: ::core::option::Option<i64>,
    #[prost(map = "string, bytes", tag = "27")]
    pub xattr: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::vec::Vec<u8>,
    >,
    #[prost(message, optional, tag = "28")]
    pub capability: ::core::option::Option<super::super::proto::security::Capability>,
    #[prost(string, optional, tag = "29")]
    pub symlink: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetFilePathPResponse {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetFilePathPRequest {
    #[prost(int64, optional, tag = "1")]
    pub file_id: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct MountPResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MountPOptions {
    #[prost(bool, optional, tag = "1")]
    pub read_only: ::core::option::Option<bool>,
    #[prost(map = "string, string", tag = "2")]
    pub properties: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(bool, optional, tag = "3")]
    pub shared: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MountPRequest {
    #[prost(string, optional, tag = "1")]
    pub goosefs_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub ufs_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub options: ::core::option::Option<MountPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CreateNamespacePResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateNamespacePOptions {
    #[prost(bool, optional, tag = "1")]
    pub read_only: ::core::option::Option<bool>,
    #[prost(map = "string, string", tag = "2")]
    pub properties: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(bool, optional, tag = "3")]
    pub shared: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(enumeration = "ReadPType", optional, tag = "5")]
    pub read_p_type: ::core::option::Option<i32>,
    #[prost(enumeration = "WritePType", optional, tag = "6")]
    pub write_p_type: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateNamespacePRequest {
    #[prost(string, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub ufs_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub options: ::core::option::Option<CreateNamespacePOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UpdateNamespacePResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateNamespacePOptions {
    #[prost(bool, optional, tag = "1")]
    pub read_only: ::core::option::Option<bool>,
    #[prost(map = "string, string", tag = "2")]
    pub properties: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(bool, optional, tag = "3")]
    pub shared: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateNamespacePRequest {
    #[prost(string, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<UpdateNamespacePOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetMountPointPResponse {
    #[prost(message, required, tag = "1")]
    pub mount_point_info: MountPointInfo,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetMountPointPRequest {
    #[prost(string, required, tag = "1")]
    pub path: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetMountTablePResponse {
    #[prost(map = "string, message", tag = "1")]
    pub mount_points: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        MountPointInfo,
    >,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetMountTablePRequest {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MountPointInfo {
    #[prost(string, optional, tag = "1")]
    pub ufs_uri: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub ufs_type: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(int64, optional, tag = "3", default = "-1")]
    pub ufs_capacity_bytes: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "4", default = "-1")]
    pub ufs_used_bytes: ::core::option::Option<i64>,
    #[prost(bool, optional, tag = "5")]
    pub read_only: ::core::option::Option<bool>,
    #[prost(map = "string, string", tag = "6")]
    pub properties: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(bool, optional, tag = "7")]
    pub shared: ::core::option::Option<bool>,
    #[prost(int64, optional, tag = "8")]
    pub mount_id: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileSystemCommandOptions {
    #[prost(message, optional, tag = "1")]
    pub persist_options: ::core::option::Option<PersistCommandOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PersistCommandOptions {
    #[prost(message, repeated, tag = "1")]
    pub persist_files: ::prost::alloc::vec::Vec<PersistFile>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PersistFile {
    #[prost(int64, optional, tag = "1")]
    pub file_id: ::core::option::Option<i64>,
    #[prost(int64, repeated, packed = "false", tag = "2")]
    pub block_ids: ::prost::alloc::vec::Vec<i64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FileSystemCommand {
    #[prost(enumeration = "super::CommandType", optional, tag = "1")]
    pub command_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "2")]
    pub command_options: ::core::option::Option<FileSystemCommandOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct RenamePResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct RenamePOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(bool, optional, tag = "2")]
    pub persist: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RenamePRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub dst_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub options: ::core::option::Option<RenamePOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReverseResolvePRequest {
    #[prost(string, optional, tag = "1")]
    pub ufs_uri: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReverseResolvePResponse {
    #[prost(string, optional, tag = "1")]
    pub goosefs_path: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SetAttributePResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SetAttributePOptions {
    #[prost(bool, optional, tag = "1")]
    pub persisted: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "2")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "3")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub mode: ::core::option::Option<super::PMode>,
    #[prost(bool, optional, tag = "5")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "8")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(enumeration = "ReadPType", optional, tag = "9")]
    pub read_p_type: ::core::option::Option<i32>,
    #[prost(enumeration = "WritePType", optional, tag = "10")]
    pub write_p_type: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "11")]
    pub direct_children_load: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SetAttributePRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<SetAttributePOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SetAclPResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SetAclPOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(bool, optional, tag = "2")]
    pub recursive: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SetAclPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "SetAclAction", optional, tag = "2")]
    pub action: ::core::option::Option<i32>,
    #[prost(message, repeated, tag = "3")]
    pub entries: ::prost::alloc::vec::Vec<PAclEntry>,
    #[prost(message, optional, tag = "4")]
    pub options: ::core::option::Option<SetAclPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ScheduleAsyncPersistencePResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ScheduleAsyncPersistencePOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(int64, optional, tag = "2")]
    pub persistence_wait_time: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScheduleAsyncPersistencePRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<ScheduleAsyncPersistencePOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct StartSyncPResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct StartSyncPOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StartSyncPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<StartSyncPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct StopSyncPResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct StopSyncPOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StopSyncPRequest {
    #[prost(string, optional, tag = "1")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<StopSyncPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UnmountPResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UnmountPOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnmountPRequest {
    #[prost(string, optional, tag = "1")]
    pub goosefs_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<UnmountPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DeleteNamespacePResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DeleteNamespacePOptions {
    #[prost(message, optional, tag = "1")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteNamespacePRequest {
    #[prost(string, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<DeleteNamespacePOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SetNamespaceAttributePResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SetNamespaceAttributePOptions {
    #[prost(bool, optional, tag = "1")]
    pub persisted: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "2")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "3")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub mode: ::core::option::Option<super::PMode>,
    #[prost(message, optional, tag = "5")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(enumeration = "ReadPType", optional, tag = "6")]
    pub read_p_type: ::core::option::Option<i32>,
    #[prost(enumeration = "WritePType", optional, tag = "7")]
    pub write_p_type: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "8")]
    pub direct_children_load: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SetNamespaceAttributePRequest {
    #[prost(string, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<SetNamespaceAttributePOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UfsInfo {
    #[prost(string, optional, tag = "1")]
    pub uri: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub properties: ::core::option::Option<MountPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateMountPRequest {
    #[prost(string, optional, tag = "1")]
    pub goosefs_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub options: ::core::option::Option<MountPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UpdateMountPResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UpdateUfsModePResponse {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UpdateUfsModePOptions {
    #[prost(enumeration = "UfsPMode", optional, tag = "1")]
    pub ufs_mode: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateUfsModePRequest {
    #[prost(string, optional, tag = "1")]
    pub ufs_path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<UpdateUfsModePOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetStateLockHoldersPResponse {
    #[prost(string, repeated, tag = "1")]
    pub threads: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetStateLockHoldersPOptions {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetStateLockHoldersPRequest {
    #[prost(message, optional, tag = "1")]
    pub options: ::core::option::Option<GetStateLockHoldersPOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommonCacheRestrictPRequest {
    #[prost(string, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RemoveBlocksPRequest {
    #[prost(int64, repeated, packed = "false", tag = "1")]
    pub block_ids: ::prost::alloc::vec::Vec<i64>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct RemoveBlocksPResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDelegationTokenPRequest {
    #[prost(string, required, tag = "1")]
    pub renewer: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDelegationTokenPResponse {
    #[prost(message, required, tag = "1")]
    pub token: super::super::proto::security::DelegationToken,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RenewDelegationTokenPRequest {
    #[prost(message, required, tag = "1")]
    pub token: super::super::proto::security::DelegationToken,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RenewDelegationTokenPResponse {
    #[prost(message, required, tag = "1")]
    pub token: super::super::proto::security::DelegationToken,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CancelDelegationTokenPRequest {
    #[prost(message, required, tag = "1")]
    pub token: super::super::proto::security::DelegationToken,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CancelDelegationTokenPResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateSymlinkPOptions {
    #[prost(string, optional, tag = "1")]
    pub target: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub common_options: ::core::option::Option<FileSystemMasterCommonPOptions>,
    #[prost(message, optional, tag = "4")]
    pub mode: ::core::option::Option<super::PMode>,
    #[prost(enumeration = "WritePType", optional, tag = "5")]
    pub write_type: ::core::option::Option<i32>,
    #[prost(enumeration = "WritePType", optional, tag = "6")]
    pub default_write_type: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub create_parent: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateSymlinkPRequest {
    #[prost(string, optional, tag = "1")]
    pub link: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub options: ::core::option::Option<CreateSymlinkPOptions>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CreateSymlinkPResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetLinkTargetPRequest {
    #[prost(string, optional, tag = "1")]
    pub link: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetLinkTargetPResponse {
    #[prost(string, optional, tag = "1")]
    pub target: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum WritePType {
    UnspecifiedWriteType = 0,
    MustCache = 1,
    TryCache = 2,
    CacheThrough = 3,
    Through = 4,
    AsyncThrough = 5,
    None = 6,
}
impl WritePType {
    /// 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::UnspecifiedWriteType => "UNSPECIFIED_WRITE_TYPE",
            Self::MustCache => "MUST_CACHE",
            Self::TryCache => "TRY_CACHE",
            Self::CacheThrough => "CACHE_THROUGH",
            Self::Through => "THROUGH",
            Self::AsyncThrough => "ASYNC_THROUGH",
            Self::None => "NONE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "UNSPECIFIED_WRITE_TYPE" => Some(Self::UnspecifiedWriteType),
            "MUST_CACHE" => Some(Self::MustCache),
            "TRY_CACHE" => Some(Self::TryCache),
            "CACHE_THROUGH" => Some(Self::CacheThrough),
            "THROUGH" => Some(Self::Through),
            "ASYNC_THROUGH" => Some(Self::AsyncThrough),
            "NONE" => Some(Self::None),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ReadPType {
    UnspecifiedReadType = 0,
    NoCache = 1,
    Cache = 2,
}
impl ReadPType {
    /// 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::UnspecifiedReadType => "UNSPECIFIED_READ_TYPE",
            Self::NoCache => "NO_CACHE",
            Self::Cache => "CACHE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "UNSPECIFIED_READ_TYPE" => Some(Self::UnspecifiedReadType),
            "NO_CACHE" => Some(Self::NoCache),
            "CACHE" => Some(Self::Cache),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum LoadMetadataPType {
    Never = 0,
    Once = 1,
    Always = 2,
}
impl LoadMetadataPType {
    /// 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::Never => "NEVER",
            Self::Once => "ONCE",
            Self::Always => "ALWAYS",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "NEVER" => Some(Self::Never),
            "ONCE" => Some(Self::Once),
            "ALWAYS" => Some(Self::Always),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SyncPointStatus {
    NotInitiallySynced = 0,
    Syncing = 1,
    InitiallySynced = 2,
}
impl SyncPointStatus {
    /// 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::NotInitiallySynced => "Not_Initially_Synced",
            Self::Syncing => "Syncing",
            Self::InitiallySynced => "Initially_Synced",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "Not_Initially_Synced" => Some(Self::NotInitiallySynced),
            "Syncing" => Some(Self::Syncing),
            "Initially_Synced" => Some(Self::InitiallySynced),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum PAclEntryType {
    Owner = 0,
    NamedUser = 1,
    OwningGroup = 2,
    NamedGroup = 3,
    Mask = 4,
    Other = 5,
}
impl PAclEntryType {
    /// 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::Owner => "Owner",
            Self::NamedUser => "NamedUser",
            Self::OwningGroup => "OwningGroup",
            Self::NamedGroup => "NamedGroup",
            Self::Mask => "Mask",
            Self::Other => "Other",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "Owner" => Some(Self::Owner),
            "NamedUser" => Some(Self::NamedUser),
            "OwningGroup" => Some(Self::OwningGroup),
            "NamedGroup" => Some(Self::NamedGroup),
            "Mask" => Some(Self::Mask),
            "Other" => Some(Self::Other),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum PAclAction {
    Read = 0,
    Write = 1,
    Execute = 2,
}
impl PAclAction {
    /// 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::Read => "Read",
            Self::Write => "Write",
            Self::Execute => "Execute",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "Read" => Some(Self::Read),
            "Write" => Some(Self::Write),
            "Execute" => Some(Self::Execute),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SetAclAction {
    Replace = 0,
    Modify = 1,
    Remove = 2,
    RemoveAll = 3,
    RemoveDefault = 4,
}
impl SetAclAction {
    /// 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::Replace => "REPLACE",
            Self::Modify => "MODIFY",
            Self::Remove => "REMOVE",
            Self::RemoveAll => "REMOVE_ALL",
            Self::RemoveDefault => "REMOVE_DEFAULT",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "REPLACE" => Some(Self::Replace),
            "MODIFY" => Some(Self::Modify),
            "REMOVE" => Some(Self::Remove),
            "REMOVE_ALL" => Some(Self::RemoveAll),
            "REMOVE_DEFAULT" => Some(Self::RemoveDefault),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum UfsPMode {
    NoAccess = 1,
    ReadOnly = 2,
    ReadWrite = 3,
}
impl UfsPMode {
    /// 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::NoAccess => "NO_ACCESS",
            Self::ReadOnly => "READ_ONLY",
            Self::ReadWrite => "READ_WRITE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "NO_ACCESS" => Some(Self::NoAccess),
            "READ_ONLY" => Some(Self::ReadOnly),
            "READ_WRITE" => Some(Self::ReadWrite),
            _ => None,
        }
    }
}
/// Generated client implementations.
pub mod file_system_master_client_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 FileSystemMasterClientServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl FileSystemMasterClientServiceClient<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> FileSystemMasterClientServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::BoxBody>,
        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,
        ) -> FileSystemMasterClientServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            FileSystemMasterClientServiceClient::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 check_access(
            &mut self,
            request: impl tonic::IntoRequest<super::CheckAccessPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CheckAccessPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CheckAccess",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CheckAccess",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn check_consistency(
            &mut self,
            request: impl tonic::IntoRequest<super::CheckConsistencyPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CheckConsistencyPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CheckConsistency",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CheckConsistency",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn complete_file(
            &mut self,
            request: impl tonic::IntoRequest<super::CompleteFilePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CompleteFilePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CompleteFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CompleteFile",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn create_directory(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateDirectoryPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateDirectoryPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CreateDirectory",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CreateDirectory",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn create_file(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateFilePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateFilePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CreateFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CreateFile",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn free(
            &mut self,
            request: impl tonic::IntoRequest<super::FreePRequest>,
        ) -> std::result::Result<tonic::Response<super::FreePResponse>, 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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/Free",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "Free",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_file_path(
            &mut self,
            request: impl tonic::IntoRequest<super::GetFilePathPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetFilePathPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetFilePath",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetFilePath",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_mount_point(
            &mut self,
            request: impl tonic::IntoRequest<super::GetMountPointPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetMountPointPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetMountPoint",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetMountPoint",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_mount_table(
            &mut self,
            request: impl tonic::IntoRequest<super::GetMountTablePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetMountTablePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetMountTable",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetMountTable",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_sync_path_list(
            &mut self,
            request: impl tonic::IntoRequest<super::GetSyncPathListPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetSyncPathListPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetSyncPathList",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetSyncPathList",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_status(
            &mut self,
            request: impl tonic::IntoRequest<super::GetStatusPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetStatusPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetStatus",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetStatus",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_status(
            &mut self,
            request: impl tonic::IntoRequest<super::ListStatusPRequest>,
        ) -> std::result::Result<
            tonic::Response<tonic::codec::Streaming<super::ListStatusPResponse>>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/ListStatus",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "ListStatus",
                    ),
                );
            self.inner.server_streaming(req, path, codec).await
        }
        pub async fn mount(
            &mut self,
            request: impl tonic::IntoRequest<super::MountPRequest>,
        ) -> std::result::Result<tonic::Response<super::MountPResponse>, 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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/Mount",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "Mount",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn remove(
            &mut self,
            request: impl tonic::IntoRequest<super::DeletePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::DeletePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/Remove",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "Remove",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rename(
            &mut self,
            request: impl tonic::IntoRequest<super::RenamePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RenamePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/Rename",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "Rename",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn reverse_resolve(
            &mut self,
            request: impl tonic::IntoRequest<super::ReverseResolvePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ReverseResolvePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/ReverseResolve",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "ReverseResolve",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn schedule_async_persistence(
            &mut self,
            request: impl tonic::IntoRequest<super::ScheduleAsyncPersistencePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ScheduleAsyncPersistencePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/ScheduleAsyncPersistence",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "ScheduleAsyncPersistence",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn set_acl(
            &mut self,
            request: impl tonic::IntoRequest<super::SetAclPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::SetAclPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/SetAcl",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "SetAcl",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn set_attribute(
            &mut self,
            request: impl tonic::IntoRequest<super::SetAttributePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::SetAttributePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/SetAttribute",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "SetAttribute",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn start_sync(
            &mut self,
            request: impl tonic::IntoRequest<super::StartSyncPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::StartSyncPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/StartSync",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "StartSync",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn stop_sync(
            &mut self,
            request: impl tonic::IntoRequest<super::StopSyncPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::StopSyncPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/StopSync",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "StopSync",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn unmount(
            &mut self,
            request: impl tonic::IntoRequest<super::UnmountPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UnmountPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/Unmount",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "Unmount",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_mount(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateMountPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UpdateMountPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/UpdateMount",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "UpdateMount",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_ufs_mode(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateUfsModePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UpdateUfsModePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/UpdateUfsMode",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "UpdateUfsMode",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_state_lock_holders(
            &mut self,
            request: impl tonic::IntoRequest<super::GetStateLockHoldersPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetStateLockHoldersPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetStateLockHolders",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetStateLockHolders",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn create_namespace(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateNamespacePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateNamespacePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CreateNamespace",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CreateNamespace",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_namespace(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateNamespacePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UpdateNamespacePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/UpdateNamespace",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "UpdateNamespace",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn delete_namespace(
            &mut self,
            request: impl tonic::IntoRequest<super::DeleteNamespacePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::DeleteNamespacePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/DeleteNamespace",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "DeleteNamespace",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_namespace(
            &mut self,
            request: impl tonic::IntoRequest<super::ListNamespacePRequest>,
        ) -> std::result::Result<
            tonic::Response<tonic::codec::Streaming<super::ListNamespacePResponse>>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/ListNamespace",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "ListNamespace",
                    ),
                );
            self.inner.server_streaming(req, path, codec).await
        }
        pub async fn stat_namespace(
            &mut self,
            request: impl tonic::IntoRequest<super::StatNamespacePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::StatNamespacePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/StatNamespace",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "StatNamespace",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn set_namespace_attribute(
            &mut self,
            request: impl tonic::IntoRequest<super::SetNamespaceAttributePRequest>,
        ) -> std::result::Result<
            tonic::Response<super::SetNamespaceAttributePResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/SetNamespaceAttribute",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "SetNamespaceAttribute",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn remove_blocks(
            &mut self,
            request: impl tonic::IntoRequest<super::RemoveBlocksPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RemoveBlocksPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/RemoveBlocks",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "RemoveBlocks",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_delegation_token(
            &mut self,
            request: impl tonic::IntoRequest<super::GetDelegationTokenPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetDelegationTokenPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetDelegationToken",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetDelegationToken",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn renew_delegation_token(
            &mut self,
            request: impl tonic::IntoRequest<super::RenewDelegationTokenPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RenewDelegationTokenPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/RenewDelegationToken",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "RenewDelegationToken",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn cancel_delegation_token(
            &mut self,
            request: impl tonic::IntoRequest<super::CancelDelegationTokenPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CancelDelegationTokenPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CancelDelegationToken",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CancelDelegationToken",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn create_symlink(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateSymlinkPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateSymlinkPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/CreateSymlink",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "CreateSymlink",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_link_target(
            &mut self,
            request: impl tonic::IntoRequest<super::GetLinkTargetPRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetLinkTargetPResponse>,
            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(
                "/com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService/GetLinkTarget",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "com.qcloud.cos.goosefs.grpc.file.FileSystemMasterClientService",
                        "GetLinkTarget",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}