azure_storage_blob/generated/models/

header_traits.rs

// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
//
// Code generated by Microsoft (R) Rust Code Generator. DO NOT EDIT.

use super::{
    AccountKind, AppendBlobClientAppendBlockFromUrlResult, AppendBlobClientAppendBlockResult,
    AppendBlobClientCreateResult, AppendBlobClientSealResult, ArchiveStatus,
    BlobClientAcquireLeaseResult, BlobClientBreakLeaseResult, BlobClientChangeLeaseResult,
    BlobClientCreateSnapshotResult, BlobClientDownloadInternalResult,
    BlobClientGetAccountInfoResult, BlobClientGetPropertiesResult, BlobClientReleaseLeaseResult,
    BlobClientRenewLeaseResult, BlobClientStartCopyFromUrlResult,
    BlobContainerClientAcquireLeaseResult, BlobContainerClientBreakLeaseResult,
    BlobContainerClientChangeLeaseResult, BlobContainerClientGetAccountInfoResult,
    BlobContainerClientGetPropertiesResult, BlobContainerClientReleaseLeaseResult,
    BlobContainerClientRenewLeaseResult, BlobServiceClientGetAccountInfoResult, BlobType,
    BlockBlobClientCommitBlockListResult, BlockBlobClientStageBlockFromUrlResult,
    BlockBlobClientStageBlockResult, BlockBlobClientUploadBlobFromUrlResult,
    BlockBlobClientUploadInternalResult, BlockList, CopyStatus, ImmutabilityPolicyMode,
    LeaseDuration, LeaseState, LeaseStatus, PageBlobClientClearPagesResult,
    PageBlobClientCreateResult, PageBlobClientResizeResult, PageBlobClientSetSequenceNumberResult,
    PageBlobClientUploadPagesFromUrlResult, PageBlobClientUploadPagesResult, PageList,
    PublicAccessType, RehydratePriority, SignedIdentifiers, SkuName,
};
use azure_core::{
    base64,
    http::{
        headers::{HeaderName, Headers},
        AsyncResponse, Etag, NoFormat, Response, XmlFormat,
    },
    time::{parse_rfc7231, OffsetDateTime},
    Result,
};
use std::collections::HashMap;

const ACCESS_TIER: HeaderName = HeaderName::from_static("x-ms-access-tier");
const ACCESS_TIER_CHANGE_TIME: HeaderName = HeaderName::from_static("x-ms-access-tier-change-time");
const ACCESS_TIER_INFERRED: HeaderName = HeaderName::from_static("x-ms-access-tier-inferred");
const ACCOUNT_KIND: HeaderName = HeaderName::from_static("x-ms-account-kind");
const ARCHIVE_STATUS: HeaderName = HeaderName::from_static("x-ms-archive-status");
const BLOB_APPEND_OFFSET: HeaderName = HeaderName::from_static("x-ms-blob-append-offset");
const BLOB_COMMITTED_BLOCK_COUNT: HeaderName =
    HeaderName::from_static("x-ms-blob-committed-block-count");
const BLOB_CONTENT_LENGTH: HeaderName = HeaderName::from_static("x-ms-blob-content-length");
const BLOB_CONTENT_MD5: HeaderName = HeaderName::from_static("x-ms-blob-content-md5");
const BLOB_PUBLIC_ACCESS: HeaderName = HeaderName::from_static("x-ms-blob-public-access");
const BLOB_SEALED: HeaderName = HeaderName::from_static("x-ms-blob-sealed");
const BLOB_SEQUENCE_NUMBER: HeaderName = HeaderName::from_static("x-ms-blob-sequence-number");
const BLOB_TYPE: HeaderName = HeaderName::from_static("x-ms-blob-type");
const CACHE_CONTROL: HeaderName = HeaderName::from_static("cache-control");
const CONTENT_CRC64: HeaderName = HeaderName::from_static("x-ms-content-crc64");
const CONTENT_DISPOSITION: HeaderName = HeaderName::from_static("content-disposition");
const CONTENT_ENCODING: HeaderName = HeaderName::from_static("content-encoding");
const CONTENT_LANGUAGE: HeaderName = HeaderName::from_static("content-language");
const CONTENT_LENGTH: HeaderName = HeaderName::from_static("content-length");
const CONTENT_MD5: HeaderName = HeaderName::from_static("content-md5");
const CONTENT_RANGE: HeaderName = HeaderName::from_static("content-range");
const CONTENT_TYPE: HeaderName = HeaderName::from_static("content-type");
const COPY_COMPLETION_TIME: HeaderName = HeaderName::from_static("x-ms-copy-completion-time");
const COPY_DESTINATION_SNAPSHOT: HeaderName =
    HeaderName::from_static("x-ms-copy-destination-snapshot");
const COPY_ID: HeaderName = HeaderName::from_static("x-ms-copy-id");
const COPY_PROGRESS: HeaderName = HeaderName::from_static("x-ms-copy-progress");
const COPY_SOURCE: HeaderName = HeaderName::from_static("x-ms-copy-source");
const COPY_STATUS: HeaderName = HeaderName::from_static("x-ms-copy-status");
const COPY_STATUS_DESCRIPTION: HeaderName = HeaderName::from_static("x-ms-copy-status-description");
const CREATION_TIME: HeaderName = HeaderName::from_static("x-ms-creation-time");
const DEFAULT_ENCRYPTION_SCOPE: HeaderName =
    HeaderName::from_static("x-ms-default-encryption-scope");
const DENY_ENCRYPTION_SCOPE_OVERRIDE: HeaderName =
    HeaderName::from_static("x-ms-deny-encryption-scope-override");
const ENCRYPTION_KEY_SHA256: HeaderName = HeaderName::from_static("x-ms-encryption-key-sha256");
const ENCRYPTION_SCOPE: HeaderName = HeaderName::from_static("x-ms-encryption-scope");
const ETAG: HeaderName = HeaderName::from_static("etag");
const EXPIRY_TIME: HeaderName = HeaderName::from_static("x-ms-expiry-time");
const HAS_IMMUTABILITY_POLICY: HeaderName = HeaderName::from_static("x-ms-has-immutability-policy");
const HAS_LEGAL_HOLD: HeaderName = HeaderName::from_static("x-ms-has-legal-hold");
const IMMUTABILITY_POLICY_MODE: HeaderName =
    HeaderName::from_static("x-ms-immutability-policy-mode");
const IMMUTABILITY_POLICY_UNTIL_DATE: HeaderName =
    HeaderName::from_static("x-ms-immutability-policy-until-date");
const IMMUTABLE_STORAGE_WITH_VERSIONING_ENABLED: HeaderName =
    HeaderName::from_static("x-ms-immutable-storage-with-versioning-enabled");
const INCREMENTAL_COPY: HeaderName = HeaderName::from_static("x-ms-incremental-copy");
const IS_CURRENT_VERSION: HeaderName = HeaderName::from_static("x-ms-is-current-version");
const IS_HNS_ENABLED: HeaderName = HeaderName::from_static("x-ms-is-hns-enabled");
const LAST_ACCESS_TIME: HeaderName = HeaderName::from_static("x-ms-last-access-time");
const LAST_MODIFIED: HeaderName = HeaderName::from_static("last-modified");
const LEASE_DURATION: HeaderName = HeaderName::from_static("x-ms-lease-duration");
const LEASE_ID: HeaderName = HeaderName::from_static("x-ms-lease-id");
const LEASE_STATE: HeaderName = HeaderName::from_static("x-ms-lease-state");
const LEASE_STATUS: HeaderName = HeaderName::from_static("x-ms-lease-status");
const LEASE_TIME: HeaderName = HeaderName::from_static("x-ms-lease-time");
const LEGAL_HOLD: HeaderName = HeaderName::from_static("x-ms-legal-hold");
const META: &str = "x-ms-meta-";
const OR: &str = "x-ms-or-";
const OR_POLICY_ID: HeaderName = HeaderName::from_static("x-ms-or-policy-id");
const REHYDRATE_PRIORITY: HeaderName = HeaderName::from_static("x-ms-rehydrate-priority");
const REQUEST_SERVER_ENCRYPTED: HeaderName =
    HeaderName::from_static("x-ms-request-server-encrypted");
const SERVER_ENCRYPTED: HeaderName = HeaderName::from_static("x-ms-server-encrypted");
const SKU_NAME: HeaderName = HeaderName::from_static("x-ms-sku-name");
const SNAPSHOT: HeaderName = HeaderName::from_static("x-ms-snapshot");
const TAG_COUNT: HeaderName = HeaderName::from_static("x-ms-tag-count");
const VERSION_ID: HeaderName = HeaderName::from_static("x-ms-version-id");

/// Provides access to typed response headers for `AppendBlobClient::append_block_from_url()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{AppendBlobClientAppendBlockFromUrlResult, AppendBlobClientAppendBlockFromUrlResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<AppendBlobClientAppendBlockFromUrlResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait AppendBlobClientAppendBlockFromUrlResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_append_offset(&self) -> Result<Option<String>>;
    fn blob_committed_block_count(&self) -> Result<Option<i32>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
}

impl AppendBlobClientAppendBlockFromUrlResultHeaders
    for Response<AppendBlobClientAppendBlockFromUrlResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The offset at which the block was committed, in bytes.
    fn blob_append_offset(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &BLOB_APPEND_OFFSET)
    }

    /// The number of committed blocks present in the blob.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }
}

/// Provides access to typed response headers for `AppendBlobClient::append_block()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{AppendBlobClientAppendBlockResult, AppendBlobClientAppendBlockResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<AppendBlobClientAppendBlockResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait AppendBlobClientAppendBlockResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_append_offset(&self) -> Result<Option<String>>;
    fn blob_committed_block_count(&self) -> Result<Option<i32>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
}

impl AppendBlobClientAppendBlockResultHeaders
    for Response<AppendBlobClientAppendBlockResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The offset at which the block was committed, in bytes.
    fn blob_append_offset(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &BLOB_APPEND_OFFSET)
    }

    /// The number of committed blocks present in the blob.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }
}

/// Provides access to typed response headers for `AppendBlobClient::create()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{AppendBlobClientCreateResult, AppendBlobClientCreateResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<AppendBlobClientCreateResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait AppendBlobClientCreateResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl AppendBlobClientCreateResultHeaders for Response<AppendBlobClientCreateResult, NoFormat> {
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `AppendBlobClient::seal()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{AppendBlobClientSealResult, AppendBlobClientSealResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<AppendBlobClientSealResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(is_sealed) = response.is_sealed()? {
///         println!("x-ms-blob-sealed: {:?}", is_sealed);
///     }
///     Ok(())
/// }
/// ```
pub trait AppendBlobClientSealResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn is_sealed(&self) -> Result<Option<bool>>;
}

impl AppendBlobClientSealResultHeaders for Response<AppendBlobClientSealResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Whether the blob is sealed.
    fn is_sealed(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEALED)
    }
}

/// Provides access to typed response headers for `BlobClient::acquire_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientAcquireLeaseResult, BlobClientAcquireLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientAcquireLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_id) = response.lease_id()? {
///         println!("x-ms-lease-id: {:?}", lease_id);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientAcquireLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_id(&self) -> Result<Option<String>>;
}

impl BlobClientAcquireLeaseResultHeaders for Response<BlobClientAcquireLeaseResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Uniquely identifies a blob's lease.
    fn lease_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &LEASE_ID)
    }
}

/// Provides access to typed response headers for `BlobClient::break_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientBreakLeaseResult, BlobClientBreakLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientBreakLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_time) = response.lease_time()? {
///         println!("x-ms-lease-time: {:?}", lease_time);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientBreakLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_time(&self) -> Result<Option<i32>>;
}

impl BlobClientBreakLeaseResultHeaders for Response<BlobClientBreakLeaseResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Approximate time remaining in the lease period, in seconds.
    fn lease_time(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &LEASE_TIME)
    }
}

/// Provides access to typed response headers for `BlobClient::change_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientChangeLeaseResult, BlobClientChangeLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientChangeLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_id) = response.lease_id()? {
///         println!("x-ms-lease-id: {:?}", lease_id);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientChangeLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_id(&self) -> Result<Option<String>>;
}

impl BlobClientChangeLeaseResultHeaders for Response<BlobClientChangeLeaseResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Uniquely identifies a blob's lease.
    fn lease_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &LEASE_ID)
    }
}

/// Provides access to typed response headers for `BlobClient::create_snapshot()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientCreateSnapshotResult, BlobClientCreateSnapshotResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientCreateSnapshotResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(is_server_encrypted) = response.is_server_encrypted()? {
///         println!("x-ms-request-server-encrypted: {:?}", is_server_encrypted);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientCreateSnapshotResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn snapshot(&self) -> Result<Option<String>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl BlobClientCreateSnapshotResultHeaders for Response<BlobClientCreateSnapshotResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// Uniquely identifies the snapshot and indicates the snapshot version.
    fn snapshot(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &SNAPSHOT)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `BlobClient::download_internal()`
///
/// # Examples
///
/// ```ignore
/// use azure_core::{Result, http::AsyncResponse};
/// use azure_storage_blob::models::{BlobClientDownloadInternalResult, BlobClientDownloadInternalResultHeaders};
/// async fn example() -> Result<()> {
///     let response: AsyncResponse<BlobClientDownloadInternalResult> = unimplemented!();
///     // Access response headers
///     if let Some(cache_control) = response.cache_control()? {
///         println!("cache-control: {:?}", cache_control);
///     }
///     if let Some(content_disposition) = response.content_disposition()? {
///         println!("content-disposition: {:?}", content_disposition);
///     }
///     if let Some(content_encoding) = response.content_encoding()? {
///         println!("content-encoding: {:?}", content_encoding);
///     }
///     Ok(())
/// }
/// ```
pub(crate) trait BlobClientDownloadInternalResultHeaders: private::Sealed {
    fn cache_control(&self) -> Result<Option<String>>;
    fn content_disposition(&self) -> Result<Option<String>>;
    fn content_encoding(&self) -> Result<Option<String>>;
    fn content_language(&self) -> Result<Option<String>>;
    fn content_length(&self) -> Result<Option<u64>>;
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn content_range(&self) -> Result<Option<String>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_committed_block_count(&self) -> Result<Option<i32>>;
    fn blob_content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn is_sealed(&self) -> Result<Option<bool>>;
    fn blob_sequence_number(&self) -> Result<Option<i64>>;
    fn blob_type(&self) -> Result<Option<BlobType>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn copy_completion_time(&self) -> Result<Option<OffsetDateTime>>;
    fn copy_id(&self) -> Result<Option<String>>;
    fn copy_progress(&self) -> Result<Option<String>>;
    fn copy_source(&self) -> Result<Option<String>>;
    fn copy_status(&self) -> Result<Option<CopyStatus>>;
    fn copy_status_description(&self) -> Result<Option<String>>;
    fn creation_time(&self) -> Result<Option<OffsetDateTime>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn immutability_policy_mode(&self) -> Result<Option<ImmutabilityPolicyMode>>;
    fn immutability_policy_expires_on(&self) -> Result<Option<OffsetDateTime>>;
    fn is_current_version(&self) -> Result<Option<bool>>;
    fn last_accessed(&self) -> Result<Option<OffsetDateTime>>;
    fn duration(&self) -> Result<Option<LeaseDuration>>;
    fn lease_state(&self) -> Result<Option<LeaseState>>;
    fn lease_status(&self) -> Result<Option<LeaseStatus>>;
    fn legal_hold(&self) -> Result<Option<bool>>;
    fn metadata(&self) -> Result<HashMap<String, String>>;
    fn object_replication_rules(&self) -> Result<HashMap<String, String>>;
    fn object_replication_policy_id(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn tag_count(&self) -> Result<Option<i64>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl BlobClientDownloadInternalResultHeaders for AsyncResponse<BlobClientDownloadInternalResult> {
    /// The Cache-Control of the blob.
    fn cache_control(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CACHE_CONTROL)
    }

    /// The Content-Disposition of the blob.
    fn content_disposition(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_DISPOSITION)
    }

    /// The Content-Encoding of the blob.
    fn content_encoding(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_ENCODING)
    }

    /// The Content-Language of the blob.
    fn content_language(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_LANGUAGE)
    }

    /// The number of bytes present in the response body.
    fn content_length(&self) -> Result<Option<u64>> {
        Headers::get_optional_as(self.headers(), &CONTENT_LENGTH)
    }

    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// Indicates the range of bytes returned in this response.
    fn content_range(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_RANGE)
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The number of committed blocks present in the blob.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// MD5 hash of the full blob content only returned for ranged reads. This is the hash of the complete blob, not just the
    /// requested range.
    fn blob_content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &BLOB_CONTENT_MD5, |h| {
            base64::decode(h.as_str())
        })
    }

    /// Whether the blob is sealed.
    fn is_sealed(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEALED)
    }

    /// The current sequence number for a page blob.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// The type of the blob.
    fn blob_type(&self) -> Result<Option<BlobType>> {
        Headers::get_optional_as(self.headers(), &BLOB_TYPE)
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// If this blob was the destination of a copy, specifies the completion time of the last attempted copy operation.
    fn copy_completion_time(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &COPY_COMPLETION_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Identifier for this copy operation.
    fn copy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_ID)
    }

    /// If this blob was the destination of a copy, specifies the number of bytes copied and the total bytes in the source.
    fn copy_progress(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_PROGRESS)
    }

    /// If this blob was the destination of a copy, specifies the source URL.
    fn copy_source(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_SOURCE)
    }

    /// Status of the copy operation.
    fn copy_status(&self) -> Result<Option<CopyStatus>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS)
    }

    /// If this blob was the destination of a copy, specifies the cause of the copy operation failure.
    fn copy_status_description(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS_DESCRIPTION)
    }

    /// The date-time the blob was created.
    fn creation_time(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &CREATION_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates the immutability policy mode of the blob.
    fn immutability_policy_mode(&self) -> Result<Option<ImmutabilityPolicyMode>> {
        Headers::get_optional_as(self.headers(), &IMMUTABILITY_POLICY_MODE)
    }

    /// The date-time that indicates the time at which the blob immutability policy will expire.
    fn immutability_policy_expires_on(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &IMMUTABILITY_POLICY_UNTIL_DATE, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Indicates whether this is the current version of the blob.
    fn is_current_version(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IS_CURRENT_VERSION)
    }

    /// The date-time value that indicates the time at which the blob was last read or written.
    fn last_accessed(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_ACCESS_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Specifies the duration of the lease.
    fn duration(&self) -> Result<Option<LeaseDuration>> {
        Headers::get_optional_as(self.headers(), &LEASE_DURATION)
    }

    /// The lease state of the blob.
    fn lease_state(&self) -> Result<Option<LeaseState>> {
        Headers::get_optional_as(self.headers(), &LEASE_STATE)
    }

    /// The lease status of the blob.
    fn lease_status(&self) -> Result<Option<LeaseStatus>> {
        Headers::get_optional_as(self.headers(), &LEASE_STATUS)
    }

    /// Indicates whether the blob has a legal hold.
    fn legal_hold(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &LEGAL_HOLD)
    }

    /// The metadata headers.
    fn metadata(&self) -> Result<HashMap<String, String>> {
        let mut values = HashMap::new();
        for h in self.headers().iter() {
            let name = h.0.as_str();
            if name.len() > META.len() && name.starts_with(META) {
                values.insert(name[META.len()..].to_owned(), h.1.as_str().to_owned());
            }
        }
        Ok(values)
    }

    /// The object replication status headers.
    fn object_replication_rules(&self) -> Result<HashMap<String, String>> {
        let mut values = HashMap::new();
        for h in self.headers().iter() {
            let name = h.0.as_str();
            if name.len() > OR.len() && name.starts_with(OR) {
                values.insert(name[OR.len()..].to_owned(), h.1.as_str().to_owned());
            }
        }
        Ok(values)
    }

    /// The object replication policy ID.
    fn object_replication_policy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &OR_POLICY_ID)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &SERVER_ENCRYPTED)
    }

    /// The number of tags associated with the blob.
    fn tag_count(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &TAG_COUNT)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `BlobClient::get_account_info()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientGetAccountInfoResult, BlobClientGetAccountInfoResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientGetAccountInfoResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(account_kind) = response.account_kind()? {
///         println!("x-ms-account-kind: {:?}", account_kind);
///     }
///     if let Some(is_hierarchical_namespace_enabled) = response.is_hierarchical_namespace_enabled()? {
///         println!("x-ms-is-hns-enabled: {:?}", is_hierarchical_namespace_enabled);
///     }
///     if let Some(sku_name) = response.sku_name()? {
///         println!("x-ms-sku-name: {:?}", sku_name);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientGetAccountInfoResultHeaders: private::Sealed {
    fn account_kind(&self) -> Result<Option<AccountKind>>;
    fn is_hierarchical_namespace_enabled(&self) -> Result<Option<bool>>;
    fn sku_name(&self) -> Result<Option<SkuName>>;
}

impl BlobClientGetAccountInfoResultHeaders for Response<BlobClientGetAccountInfoResult, NoFormat> {
    /// The account kind.
    fn account_kind(&self) -> Result<Option<AccountKind>> {
        Headers::get_optional_as(self.headers(), &ACCOUNT_KIND)
    }

    /// Indicates if the account has a hierarchical namespace enabled.
    fn is_hierarchical_namespace_enabled(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IS_HNS_ENABLED)
    }

    /// The SKU name of the account.
    fn sku_name(&self) -> Result<Option<SkuName>> {
        Headers::get_optional_as(self.headers(), &SKU_NAME)
    }
}

/// Provides access to typed response headers for `BlobClient::get_properties()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientGetPropertiesResult, BlobClientGetPropertiesResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientGetPropertiesResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(cache_control) = response.cache_control()? {
///         println!("cache-control: {:?}", cache_control);
///     }
///     if let Some(content_disposition) = response.content_disposition()? {
///         println!("content-disposition: {:?}", content_disposition);
///     }
///     if let Some(content_encoding) = response.content_encoding()? {
///         println!("content-encoding: {:?}", content_encoding);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientGetPropertiesResultHeaders: private::Sealed {
    fn cache_control(&self) -> Result<Option<String>>;
    fn content_disposition(&self) -> Result<Option<String>>;
    fn content_encoding(&self) -> Result<Option<String>>;
    fn content_language(&self) -> Result<Option<String>>;
    fn content_length(&self) -> Result<Option<u64>>;
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn content_type(&self) -> Result<Option<String>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn access_tier(&self) -> Result<Option<String>>;
    fn access_tier_change_time(&self) -> Result<Option<OffsetDateTime>>;
    fn access_tier_inferred(&self) -> Result<Option<bool>>;
    fn archive_status(&self) -> Result<Option<ArchiveStatus>>;
    fn blob_committed_block_count(&self) -> Result<Option<i32>>;
    fn is_sealed(&self) -> Result<Option<bool>>;
    fn blob_sequence_number(&self) -> Result<Option<i64>>;
    fn blob_type(&self) -> Result<Option<BlobType>>;
    fn copy_completion_time(&self) -> Result<Option<OffsetDateTime>>;
    fn destination_snapshot(&self) -> Result<Option<String>>;
    fn copy_id(&self) -> Result<Option<String>>;
    fn copy_progress(&self) -> Result<Option<String>>;
    fn copy_source(&self) -> Result<Option<String>>;
    fn copy_status(&self) -> Result<Option<CopyStatus>>;
    fn copy_status_description(&self) -> Result<Option<String>>;
    fn creation_time(&self) -> Result<Option<OffsetDateTime>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn expires_on(&self) -> Result<Option<OffsetDateTime>>;
    fn immutability_policy_mode(&self) -> Result<Option<ImmutabilityPolicyMode>>;
    fn immutability_policy_expires_on(&self) -> Result<Option<OffsetDateTime>>;
    fn is_incremental_copy(&self) -> Result<Option<bool>>;
    fn is_current_version(&self) -> Result<Option<bool>>;
    fn last_accessed(&self) -> Result<Option<OffsetDateTime>>;
    fn duration(&self) -> Result<Option<LeaseDuration>>;
    fn lease_state(&self) -> Result<Option<LeaseState>>;
    fn lease_status(&self) -> Result<Option<LeaseStatus>>;
    fn legal_hold(&self) -> Result<Option<bool>>;
    fn metadata(&self) -> Result<HashMap<String, String>>;
    fn object_replication_rules(&self) -> Result<HashMap<String, String>>;
    fn object_replication_policy_id(&self) -> Result<Option<String>>;
    fn rehydrate_priority(&self) -> Result<Option<RehydratePriority>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn tag_count(&self) -> Result<Option<i64>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl BlobClientGetPropertiesResultHeaders for Response<BlobClientGetPropertiesResult, NoFormat> {
    /// The Cache-Control of the blob.
    fn cache_control(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CACHE_CONTROL)
    }

    /// The Content-Disposition of the blob.
    fn content_disposition(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_DISPOSITION)
    }

    /// The Content-Encoding of the blob.
    fn content_encoding(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_ENCODING)
    }

    /// The Content-Language of the blob.
    fn content_language(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_LANGUAGE)
    }

    /// The number of bytes present in the response body.
    fn content_length(&self) -> Result<Option<u64>> {
        Headers::get_optional_as(self.headers(), &CONTENT_LENGTH)
    }

    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// Content-type.
    fn content_type(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_TYPE)
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The access tier of the blob.
    fn access_tier(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ACCESS_TIER)
    }

    /// The time the tier was changed on the blob. This is only returned if the tier on the blob was ever set.
    fn access_tier_change_time(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &ACCESS_TIER_CHANGE_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Included if the access tier is inferred.
    fn access_tier_inferred(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &ACCESS_TIER_INFERRED)
    }

    /// Included if the blob rehydrate operation is pending. Indicates the destination tier.
    fn archive_status(&self) -> Result<Option<ArchiveStatus>> {
        Headers::get_optional_as(self.headers(), &ARCHIVE_STATUS)
    }

    /// The number of committed blocks present in the blob.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// Whether the blob is sealed.
    fn is_sealed(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEALED)
    }

    /// The current sequence number for a page blob.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// The type of the blob.
    fn blob_type(&self) -> Result<Option<BlobType>> {
        Headers::get_optional_as(self.headers(), &BLOB_TYPE)
    }

    /// If this blob was the destination of a copy, specifies the completion time of the last attempted copy operation.
    fn copy_completion_time(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &COPY_COMPLETION_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Included if the blob is incremental copy blob or incremental copy snapshot, if x-ms-copy-status is success.
    fn destination_snapshot(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_DESTINATION_SNAPSHOT)
    }

    /// Identifier for this copy operation.
    fn copy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_ID)
    }

    /// If this blob was the destination of a copy, specifies the number of bytes copied and the total bytes in the source.
    fn copy_progress(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_PROGRESS)
    }

    /// If this blob was the destination of a copy, specifies the source URL.
    fn copy_source(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_SOURCE)
    }

    /// Status of the copy operation.
    fn copy_status(&self) -> Result<Option<CopyStatus>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS)
    }

    /// If this blob was the destination of a copy, specifies the cause of the copy operation failure.
    fn copy_status_description(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS_DESCRIPTION)
    }

    /// The date-time the blob was created.
    fn creation_time(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &CREATION_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The date-time this blob will expire.
    fn expires_on(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &EXPIRY_TIME, |h| parse_rfc7231(h.as_str()))
    }

    /// Indicates the immutability policy mode of the blob.
    fn immutability_policy_mode(&self) -> Result<Option<ImmutabilityPolicyMode>> {
        Headers::get_optional_as(self.headers(), &IMMUTABILITY_POLICY_MODE)
    }

    /// The date-time that indicates the time at which the blob immutability policy will expire.
    fn immutability_policy_expires_on(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &IMMUTABILITY_POLICY_UNTIL_DATE, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Included if the blob is incremental copy blob.
    fn is_incremental_copy(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &INCREMENTAL_COPY)
    }

    /// Indicates whether this is the current version of the blob.
    fn is_current_version(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IS_CURRENT_VERSION)
    }

    /// The date-time value that indicates the time at which the blob was last read or written.
    fn last_accessed(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_ACCESS_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Specifies the duration of the lease.
    fn duration(&self) -> Result<Option<LeaseDuration>> {
        Headers::get_optional_as(self.headers(), &LEASE_DURATION)
    }

    /// The lease state of the blob.
    fn lease_state(&self) -> Result<Option<LeaseState>> {
        Headers::get_optional_as(self.headers(), &LEASE_STATE)
    }

    /// The lease status of the blob.
    fn lease_status(&self) -> Result<Option<LeaseStatus>> {
        Headers::get_optional_as(self.headers(), &LEASE_STATUS)
    }

    /// Indicates whether the blob has a legal hold.
    fn legal_hold(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &LEGAL_HOLD)
    }

    /// The metadata headers.
    fn metadata(&self) -> Result<HashMap<String, String>> {
        let mut values = HashMap::new();
        for h in self.headers().iter() {
            let name = h.0.as_str();
            if name.len() > META.len() && name.starts_with(META) {
                values.insert(name[META.len()..].to_owned(), h.1.as_str().to_owned());
            }
        }
        Ok(values)
    }

    /// The object replication status headers.
    fn object_replication_rules(&self) -> Result<HashMap<String, String>> {
        let mut values = HashMap::new();
        for h in self.headers().iter() {
            let name = h.0.as_str();
            if name.len() > OR.len() && name.starts_with(OR) {
                values.insert(name[OR.len()..].to_owned(), h.1.as_str().to_owned());
            }
        }
        Ok(values)
    }

    /// The object replication policy ID.
    fn object_replication_policy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &OR_POLICY_ID)
    }

    /// The priority of the rehydration operation.
    fn rehydrate_priority(&self) -> Result<Option<RehydratePriority>> {
        Headers::get_optional_as(self.headers(), &REHYDRATE_PRIORITY)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &SERVER_ENCRYPTED)
    }

    /// The number of tags associated with the blob.
    fn tag_count(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &TAG_COUNT)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `BlobClient::release_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientReleaseLeaseResult, BlobClientReleaseLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientReleaseLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientReleaseLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
}

impl BlobClientReleaseLeaseResultHeaders for Response<BlobClientReleaseLeaseResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }
}

/// Provides access to typed response headers for `BlobClient::renew_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientRenewLeaseResult, BlobClientRenewLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientRenewLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_id) = response.lease_id()? {
///         println!("x-ms-lease-id: {:?}", lease_id);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientRenewLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_id(&self) -> Result<Option<String>>;
}

impl BlobClientRenewLeaseResultHeaders for Response<BlobClientRenewLeaseResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Uniquely identifies a blob's lease.
    fn lease_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &LEASE_ID)
    }
}

/// Provides access to typed response headers for `BlobClient::start_copy_from_url()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobClientStartCopyFromUrlResult, BlobClientStartCopyFromUrlResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobClientStartCopyFromUrlResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(copy_id) = response.copy_id()? {
///         println!("x-ms-copy-id: {:?}", copy_id);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobClientStartCopyFromUrlResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn copy_id(&self) -> Result<Option<String>>;
    fn copy_status(&self) -> Result<Option<CopyStatus>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl BlobClientStartCopyFromUrlResultHeaders
    for Response<BlobClientStartCopyFromUrlResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Identifier for this copy operation.
    fn copy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_ID)
    }

    /// Status of the copy operation.
    fn copy_status(&self) -> Result<Option<CopyStatus>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `BlobContainerClient::acquire_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobContainerClientAcquireLeaseResult, BlobContainerClientAcquireLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobContainerClientAcquireLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_id) = response.lease_id()? {
///         println!("x-ms-lease-id: {:?}", lease_id);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobContainerClientAcquireLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_id(&self) -> Result<Option<String>>;
}

impl BlobContainerClientAcquireLeaseResultHeaders
    for Response<BlobContainerClientAcquireLeaseResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Uniquely identifies a blob's lease.
    fn lease_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &LEASE_ID)
    }
}

/// Provides access to typed response headers for `BlobContainerClient::break_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobContainerClientBreakLeaseResult, BlobContainerClientBreakLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobContainerClientBreakLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_time) = response.lease_time()? {
///         println!("x-ms-lease-time: {:?}", lease_time);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobContainerClientBreakLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_time(&self) -> Result<Option<i32>>;
}

impl BlobContainerClientBreakLeaseResultHeaders
    for Response<BlobContainerClientBreakLeaseResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Approximate time remaining in the lease period, in seconds.
    fn lease_time(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &LEASE_TIME)
    }
}

/// Provides access to typed response headers for `BlobContainerClient::change_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobContainerClientChangeLeaseResult, BlobContainerClientChangeLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobContainerClientChangeLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_id) = response.lease_id()? {
///         println!("x-ms-lease-id: {:?}", lease_id);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobContainerClientChangeLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_id(&self) -> Result<Option<String>>;
}

impl BlobContainerClientChangeLeaseResultHeaders
    for Response<BlobContainerClientChangeLeaseResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Uniquely identifies a blob's lease.
    fn lease_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &LEASE_ID)
    }
}

/// Provides access to typed response headers for `BlobContainerClient::get_account_info()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobContainerClientGetAccountInfoResult, BlobContainerClientGetAccountInfoResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobContainerClientGetAccountInfoResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(account_kind) = response.account_kind()? {
///         println!("x-ms-account-kind: {:?}", account_kind);
///     }
///     if let Some(is_hierarchical_namespace_enabled) = response.is_hierarchical_namespace_enabled()? {
///         println!("x-ms-is-hns-enabled: {:?}", is_hierarchical_namespace_enabled);
///     }
///     if let Some(sku_name) = response.sku_name()? {
///         println!("x-ms-sku-name: {:?}", sku_name);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobContainerClientGetAccountInfoResultHeaders: private::Sealed {
    fn account_kind(&self) -> Result<Option<AccountKind>>;
    fn is_hierarchical_namespace_enabled(&self) -> Result<Option<bool>>;
    fn sku_name(&self) -> Result<Option<SkuName>>;
}

impl BlobContainerClientGetAccountInfoResultHeaders
    for Response<BlobContainerClientGetAccountInfoResult, NoFormat>
{
    /// The account kind.
    fn account_kind(&self) -> Result<Option<AccountKind>> {
        Headers::get_optional_as(self.headers(), &ACCOUNT_KIND)
    }

    /// Indicates if the account has a hierarchical namespace enabled.
    fn is_hierarchical_namespace_enabled(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IS_HNS_ENABLED)
    }

    /// The SKU name of the account.
    fn sku_name(&self) -> Result<Option<SkuName>> {
        Headers::get_optional_as(self.headers(), &SKU_NAME)
    }
}

/// Provides access to typed response headers for `BlobContainerClient::get_properties()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobContainerClientGetPropertiesResult, BlobContainerClientGetPropertiesResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobContainerClientGetPropertiesResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(access) = response.access()? {
///         println!("x-ms-blob-public-access: {:?}", access);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobContainerClientGetPropertiesResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn access(&self) -> Result<Option<PublicAccessType>>;
    fn default_encryption_scope(&self) -> Result<Option<String>>;
    fn prevent_encryption_scope_override(&self) -> Result<Option<bool>>;
    fn has_immutability_policy(&self) -> Result<Option<bool>>;
    fn has_legal_hold(&self) -> Result<Option<bool>>;
    fn is_immutable_storage_with_versioning_enabled(&self) -> Result<Option<bool>>;
    fn duration(&self) -> Result<Option<LeaseDuration>>;
    fn lease_state(&self) -> Result<Option<LeaseState>>;
    fn lease_status(&self) -> Result<Option<LeaseStatus>>;
    fn metadata(&self) -> Result<HashMap<String, String>>;
}

impl BlobContainerClientGetPropertiesResultHeaders
    for Response<BlobContainerClientGetPropertiesResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The public access setting for the container.
    fn access(&self) -> Result<Option<PublicAccessType>> {
        Headers::get_optional_as(self.headers(), &BLOB_PUBLIC_ACCESS)
    }

    /// The default encryption scope for the container.
    fn default_encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &DEFAULT_ENCRYPTION_SCOPE)
    }

    /// Whether to prevent encryption scope override.
    fn prevent_encryption_scope_override(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &DENY_ENCRYPTION_SCOPE_OVERRIDE)
    }

    /// Indicates whether the container has an immutability policy set on it.
    fn has_immutability_policy(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &HAS_IMMUTABILITY_POLICY)
    }

    /// Indicates whether the container has a legal hold.
    fn has_legal_hold(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &HAS_LEGAL_HOLD)
    }

    /// Indicates whether version level WORM (Write Once, Read Many) is enabled on a container.
    fn is_immutable_storage_with_versioning_enabled(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IMMUTABLE_STORAGE_WITH_VERSIONING_ENABLED)
    }

    /// Specifies the duration of the lease.
    fn duration(&self) -> Result<Option<LeaseDuration>> {
        Headers::get_optional_as(self.headers(), &LEASE_DURATION)
    }

    /// The lease state of the blob.
    fn lease_state(&self) -> Result<Option<LeaseState>> {
        Headers::get_optional_as(self.headers(), &LEASE_STATE)
    }

    /// The lease status of the blob.
    fn lease_status(&self) -> Result<Option<LeaseStatus>> {
        Headers::get_optional_as(self.headers(), &LEASE_STATUS)
    }

    /// The metadata headers.
    fn metadata(&self) -> Result<HashMap<String, String>> {
        let mut values = HashMap::new();
        for h in self.headers().iter() {
            let name = h.0.as_str();
            if name.len() > META.len() && name.starts_with(META) {
                values.insert(name[META.len()..].to_owned(), h.1.as_str().to_owned());
            }
        }
        Ok(values)
    }
}

/// Provides access to typed response headers for `BlobContainerClient::release_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobContainerClientReleaseLeaseResult, BlobContainerClientReleaseLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobContainerClientReleaseLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobContainerClientReleaseLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
}

impl BlobContainerClientReleaseLeaseResultHeaders
    for Response<BlobContainerClientReleaseLeaseResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }
}

/// Provides access to typed response headers for `BlobContainerClient::renew_lease()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobContainerClientRenewLeaseResult, BlobContainerClientRenewLeaseResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobContainerClientRenewLeaseResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(lease_id) = response.lease_id()? {
///         println!("x-ms-lease-id: {:?}", lease_id);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobContainerClientRenewLeaseResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn lease_id(&self) -> Result<Option<String>>;
}

impl BlobContainerClientRenewLeaseResultHeaders
    for Response<BlobContainerClientRenewLeaseResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// Uniquely identifies a blob's lease.
    fn lease_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &LEASE_ID)
    }
}

/// Provides access to typed response headers for `BlobServiceClient::get_account_info()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlobServiceClientGetAccountInfoResult, BlobServiceClientGetAccountInfoResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlobServiceClientGetAccountInfoResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(account_kind) = response.account_kind()? {
///         println!("x-ms-account-kind: {:?}", account_kind);
///     }
///     if let Some(is_hierarchical_namespace_enabled) = response.is_hierarchical_namespace_enabled()? {
///         println!("x-ms-is-hns-enabled: {:?}", is_hierarchical_namespace_enabled);
///     }
///     if let Some(sku_name) = response.sku_name()? {
///         println!("x-ms-sku-name: {:?}", sku_name);
///     }
///     Ok(())
/// }
/// ```
pub trait BlobServiceClientGetAccountInfoResultHeaders: private::Sealed {
    fn account_kind(&self) -> Result<Option<AccountKind>>;
    fn is_hierarchical_namespace_enabled(&self) -> Result<Option<bool>>;
    fn sku_name(&self) -> Result<Option<SkuName>>;
}

impl BlobServiceClientGetAccountInfoResultHeaders
    for Response<BlobServiceClientGetAccountInfoResult, NoFormat>
{
    /// The account kind.
    fn account_kind(&self) -> Result<Option<AccountKind>> {
        Headers::get_optional_as(self.headers(), &ACCOUNT_KIND)
    }

    /// Indicates if the account has hierarchical namespace enabled.
    fn is_hierarchical_namespace_enabled(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IS_HNS_ENABLED)
    }

    /// The SKU name of the account.
    fn sku_name(&self) -> Result<Option<SkuName>> {
        Headers::get_optional_as(self.headers(), &SKU_NAME)
    }
}

/// Provides access to typed response headers for `BlockBlobClient::commit_block_list()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlockBlobClientCommitBlockListResult, BlockBlobClientCommitBlockListResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlockBlobClientCommitBlockListResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait BlockBlobClientCommitBlockListResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl BlockBlobClientCommitBlockListResultHeaders
    for Response<BlockBlobClientCommitBlockListResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `BlockBlobClient::stage_block_from_url()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlockBlobClientStageBlockFromUrlResult, BlockBlobClientStageBlockFromUrlResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlockBlobClientStageBlockFromUrlResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(content_crc64) = response.content_crc64()? {
///         println!("x-ms-content-crc64: {:?}", content_crc64);
///     }
///     if let Some(encryption_key_sha256) = response.encryption_key_sha256()? {
///         println!("x-ms-encryption-key-sha256: {:?}", encryption_key_sha256);
///     }
///     Ok(())
/// }
/// ```
pub trait BlockBlobClientStageBlockFromUrlResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
}

impl BlockBlobClientStageBlockFromUrlResultHeaders
    for Response<BlockBlobClientStageBlockFromUrlResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }
}

/// Provides access to typed response headers for `BlockBlobClient::stage_block()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlockBlobClientStageBlockResult, BlockBlobClientStageBlockResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlockBlobClientStageBlockResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(content_crc64) = response.content_crc64()? {
///         println!("x-ms-content-crc64: {:?}", content_crc64);
///     }
///     if let Some(encryption_key_sha256) = response.encryption_key_sha256()? {
///         println!("x-ms-encryption-key-sha256: {:?}", encryption_key_sha256);
///     }
///     Ok(())
/// }
/// ```
pub trait BlockBlobClientStageBlockResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
}

impl BlockBlobClientStageBlockResultHeaders
    for Response<BlockBlobClientStageBlockResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }
}

/// Provides access to typed response headers for `BlockBlobClient::upload_blob_from_url()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlockBlobClientUploadBlobFromUrlResult, BlockBlobClientUploadBlobFromUrlResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlockBlobClientUploadBlobFromUrlResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait BlockBlobClientUploadBlobFromUrlResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl BlockBlobClientUploadBlobFromUrlResultHeaders
    for Response<BlockBlobClientUploadBlobFromUrlResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `BlockBlobClient::upload_internal()`
///
/// # Examples
///
/// ```ignore
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{BlockBlobClientUploadInternalResult, BlockBlobClientUploadInternalResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlockBlobClientUploadInternalResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub(crate) trait BlockBlobClientUploadInternalResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl BlockBlobClientUploadInternalResultHeaders
    for Response<BlockBlobClientUploadInternalResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `BlockBlobClient::get_block_list()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, XmlFormat}};
/// use azure_storage_blob::models::{BlockList, BlockListHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<BlockList, XmlFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(blob_content_length) = response.blob_content_length()? {
///         println!("x-ms-blob-content-length: {:?}", blob_content_length);
///     }
///     Ok(())
/// }
/// ```
pub trait BlockListHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_content_length(&self) -> Result<Option<i64>>;
}

impl BlockListHeaders for Response<BlockList, XmlFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The size of the blob in bytes.
    fn blob_content_length(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_CONTENT_LENGTH)
    }
}

/// Provides access to typed response headers for `PageBlobClient::clear_pages()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{PageBlobClientClearPagesResult, PageBlobClientClearPagesResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<PageBlobClientClearPagesResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait PageBlobClientClearPagesResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_sequence_number(&self) -> Result<Option<i64>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
}

impl PageBlobClientClearPagesResultHeaders for Response<PageBlobClientClearPagesResult, NoFormat> {
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The current sequence number for a page blob.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }
}

/// Provides access to typed response headers for `PageBlobClient::create()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{PageBlobClientCreateResult, PageBlobClientCreateResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<PageBlobClientCreateResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait PageBlobClientCreateResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
    fn version_id(&self) -> Result<Option<String>>;
}

impl PageBlobClientCreateResultHeaders for Response<PageBlobClientCreateResult, NoFormat> {
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// The version ID of the blob.
    fn version_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &VERSION_ID)
    }
}

/// Provides access to typed response headers for `PageBlobClient::resize()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{PageBlobClientResizeResult, PageBlobClientResizeResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<PageBlobClientResizeResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(blob_sequence_number) = response.blob_sequence_number()? {
///         println!("x-ms-blob-sequence-number: {:?}", blob_sequence_number);
///     }
///     Ok(())
/// }
/// ```
pub trait PageBlobClientResizeResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_sequence_number(&self) -> Result<Option<i64>>;
}

impl PageBlobClientResizeResultHeaders for Response<PageBlobClientResizeResult, NoFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The current sequence number for a page blob.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }
}

/// Provides access to typed response headers for `PageBlobClient::set_sequence_number()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{PageBlobClientSetSequenceNumberResult, PageBlobClientSetSequenceNumberResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<PageBlobClientSetSequenceNumberResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(blob_sequence_number) = response.blob_sequence_number()? {
///         println!("x-ms-blob-sequence-number: {:?}", blob_sequence_number);
///     }
///     Ok(())
/// }
/// ```
pub trait PageBlobClientSetSequenceNumberResultHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_sequence_number(&self) -> Result<Option<i64>>;
}

impl PageBlobClientSetSequenceNumberResultHeaders
    for Response<PageBlobClientSetSequenceNumberResult, NoFormat>
{
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The current sequence number for a page blob.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }
}

/// Provides access to typed response headers for `PageBlobClient::upload_pages_from_url()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{PageBlobClientUploadPagesFromUrlResult, PageBlobClientUploadPagesFromUrlResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<PageBlobClientUploadPagesFromUrlResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait PageBlobClientUploadPagesFromUrlResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_sequence_number(&self) -> Result<Option<i64>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
}

impl PageBlobClientUploadPagesFromUrlResultHeaders
    for Response<PageBlobClientUploadPagesFromUrlResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The current sequence number for a page blob.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }
}

/// Provides access to typed response headers for `PageBlobClient::upload_pages()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, NoFormat}};
/// use azure_storage_blob::models::{PageBlobClientUploadPagesResult, PageBlobClientUploadPagesResultHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<PageBlobClientUploadPagesResult, NoFormat> = unimplemented!();
///     // Access response headers
///     if let Some(content_md5) = response.content_md5()? {
///         println!("content-md5: {:?}", content_md5);
///     }
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     Ok(())
/// }
/// ```
pub trait PageBlobClientUploadPagesResultHeaders: private::Sealed {
    fn content_md5(&self) -> Result<Option<Vec<u8>>>;
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_sequence_number(&self) -> Result<Option<i64>>;
    fn content_crc64(&self) -> Result<Option<Vec<u8>>>;
    fn encryption_key_sha256(&self) -> Result<Option<String>>;
    fn encryption_scope(&self) -> Result<Option<String>>;
    fn is_server_encrypted(&self) -> Result<Option<bool>>;
}

impl PageBlobClientUploadPagesResultHeaders
    for Response<PageBlobClientUploadPagesResult, NoFormat>
{
    /// The blob content MD5 hash. Only returned if the full blob is read.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The current sequence number for a page blob.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// The CRC64 hash of the content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// The SHA-256 hash of the provided encryption key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// Specifies the encryption scope used to encrypt the data.
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// Indicates whether the contents of the request are successfully encrypted.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }
}

/// Provides access to typed response headers for `PageBlobClient::list_page_ranges()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, XmlFormat}};
/// use azure_storage_blob::models::{PageList, PageListHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<PageList, XmlFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(blob_content_length) = response.blob_content_length()? {
///         println!("x-ms-blob-content-length: {:?}", blob_content_length);
///     }
///     Ok(())
/// }
/// ```
pub trait PageListHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn blob_content_length(&self) -> Result<Option<i64>>;
}

impl PageListHeaders for Response<PageList, XmlFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The size of the blob in bytes.
    fn blob_content_length(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_CONTENT_LENGTH)
    }
}

/// Provides access to typed response headers for `BlobContainerClient::get_access_policy()`
///
/// # Examples
///
/// ```no_run
/// use azure_core::{Result, http::{Response, XmlFormat}};
/// use azure_storage_blob::models::{SignedIdentifiers, SignedIdentifiersHeaders};
/// async fn example() -> Result<()> {
///     let response: Response<SignedIdentifiers, XmlFormat> = unimplemented!();
///     // Access response headers
///     if let Some(etag) = response.etag()? {
///         println!("etag: {:?}", etag);
///     }
///     if let Some(last_modified) = response.last_modified()? {
///         println!("last-modified: {:?}", last_modified);
///     }
///     if let Some(access) = response.access()? {
///         println!("x-ms-blob-public-access: {:?}", access);
///     }
///     Ok(())
/// }
/// ```
pub trait SignedIdentifiersHeaders: private::Sealed {
    fn etag(&self) -> Result<Option<Etag>>;
    fn last_modified(&self) -> Result<Option<OffsetDateTime>>;
    fn access(&self) -> Result<Option<PublicAccessType>>;
}

impl SignedIdentifiersHeaders for Response<SignedIdentifiers, XmlFormat> {
    /// An opaque identifier for the current state of the resource.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date-time that the resource was last modified.
    fn last_modified(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &LAST_MODIFIED, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// The public access setting for the container.
    fn access(&self) -> Result<Option<PublicAccessType>> {
        Headers::get_optional_as(self.headers(), &BLOB_PUBLIC_ACCESS)
    }
}

mod private {
    use super::{
        AppendBlobClientAppendBlockFromUrlResult, AppendBlobClientAppendBlockResult,
        AppendBlobClientCreateResult, AppendBlobClientSealResult, BlobClientAcquireLeaseResult,
        BlobClientBreakLeaseResult, BlobClientChangeLeaseResult, BlobClientCreateSnapshotResult,
        BlobClientDownloadInternalResult, BlobClientGetAccountInfoResult,
        BlobClientGetPropertiesResult, BlobClientReleaseLeaseResult, BlobClientRenewLeaseResult,
        BlobClientStartCopyFromUrlResult, BlobContainerClientAcquireLeaseResult,
        BlobContainerClientBreakLeaseResult, BlobContainerClientChangeLeaseResult,
        BlobContainerClientGetAccountInfoResult, BlobContainerClientGetPropertiesResult,
        BlobContainerClientReleaseLeaseResult, BlobContainerClientRenewLeaseResult,
        BlobServiceClientGetAccountInfoResult, BlockBlobClientCommitBlockListResult,
        BlockBlobClientStageBlockFromUrlResult, BlockBlobClientStageBlockResult,
        BlockBlobClientUploadBlobFromUrlResult, BlockBlobClientUploadInternalResult, BlockList,
        PageBlobClientClearPagesResult, PageBlobClientCreateResult, PageBlobClientResizeResult,
        PageBlobClientSetSequenceNumberResult, PageBlobClientUploadPagesFromUrlResult,
        PageBlobClientUploadPagesResult, PageList, SignedIdentifiers,
    };
    use azure_core::http::{AsyncResponse, NoFormat, Response, XmlFormat};

    pub trait Sealed {}

    impl Sealed for AsyncResponse<BlobClientDownloadInternalResult> {}
    impl Sealed for Response<AppendBlobClientAppendBlockFromUrlResult, NoFormat> {}
    impl Sealed for Response<AppendBlobClientAppendBlockResult, NoFormat> {}
    impl Sealed for Response<AppendBlobClientCreateResult, NoFormat> {}
    impl Sealed for Response<AppendBlobClientSealResult, NoFormat> {}
    impl Sealed for Response<BlobClientAcquireLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobClientBreakLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobClientChangeLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobClientCreateSnapshotResult, NoFormat> {}
    impl Sealed for Response<BlobClientGetAccountInfoResult, NoFormat> {}
    impl Sealed for Response<BlobClientGetPropertiesResult, NoFormat> {}
    impl Sealed for Response<BlobClientReleaseLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobClientRenewLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobClientStartCopyFromUrlResult, NoFormat> {}
    impl Sealed for Response<BlobContainerClientAcquireLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobContainerClientBreakLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobContainerClientChangeLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobContainerClientGetAccountInfoResult, NoFormat> {}
    impl Sealed for Response<BlobContainerClientGetPropertiesResult, NoFormat> {}
    impl Sealed for Response<BlobContainerClientReleaseLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobContainerClientRenewLeaseResult, NoFormat> {}
    impl Sealed for Response<BlobServiceClientGetAccountInfoResult, NoFormat> {}
    impl Sealed for Response<BlockBlobClientCommitBlockListResult, NoFormat> {}
    impl Sealed for Response<BlockBlobClientStageBlockFromUrlResult, NoFormat> {}
    impl Sealed for Response<BlockBlobClientStageBlockResult, NoFormat> {}
    impl Sealed for Response<BlockBlobClientUploadBlobFromUrlResult, NoFormat> {}
    impl Sealed for Response<BlockBlobClientUploadInternalResult, NoFormat> {}
    impl Sealed for Response<BlockList, XmlFormat> {}
    impl Sealed for Response<PageBlobClientClearPagesResult, NoFormat> {}
    impl Sealed for Response<PageBlobClientCreateResult, NoFormat> {}
    impl Sealed for Response<PageBlobClientResizeResult, NoFormat> {}
    impl Sealed for Response<PageBlobClientSetSequenceNumberResult, NoFormat> {}
    impl Sealed for Response<PageBlobClientUploadPagesFromUrlResult, NoFormat> {}
    impl Sealed for Response<PageBlobClientUploadPagesResult, NoFormat> {}
    impl Sealed for Response<PageList, XmlFormat> {}
    impl Sealed for Response<SignedIdentifiers, XmlFormat> {}
}