azure_storage_blob 0.11.0

// 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, 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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

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

    /// This response header is returned only for append operations. It returns 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. This header is returned only for append blobs.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

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

    /// This response header is returned only for append operations. It returns 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. This header is returned only for append blobs.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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> {
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

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

    /// If this blob has been 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 blobs' 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 blobs' 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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. It may be used in subsequent requests to access the
    /// snapshot.
    fn snapshot(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &SNAPSHOT)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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
///
/// ```no_run
/// 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 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> {
    /// This header is returned if it was previously specified for the blob.
    fn cache_control(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CACHE_CONTROL)
    }

    /// This header returns the value that was specified for the 'x-ms-blob-content-disposition' header. The Content-Disposition
    /// response header field conveys additional information about how to process the response payload, and also can be used to
    /// attach additional metadata. For example, if set to attachment, it indicates that the user-agent should not display the
    /// response, but instead show a Save As dialog with a filename other than the blob name specified.
    fn content_disposition(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_DISPOSITION)
    }

    /// This header returns the value that was specified for the Content-Encoding request header
    fn content_encoding(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_ENCODING)
    }

    /// This header returns the value that was specified for the Content-Language request header.
    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)
    }

    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    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 the event that the client requested a subset of the blob by setting the 'Range'
    /// request header.
    fn content_range(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_RANGE)
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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. This header is returned only for append blobs.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from 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())
        })
    }

    /// If this blob has been sealed
    fn is_sealed(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEALED)
    }

    /// The current sequence number for a page blob. This header is not returned for block blobs or append blobs.
    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)
    }

    /// This response header is returned so that the client can check for the integrity of the copied content.
    fn content_crc64(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_CRC64, |h| {
            base64::decode(h.as_str())
        })
    }

    /// Conclusion time of the last attempted Copy Blob operation where this blob was the destination blob. This value can specify
    /// the time of a completed, aborted, or failed copy attempt. This header does not appear if a copy is pending, if this blob
    /// has never been the destination in a Copy Blob operation, or if this blob has been modified after a concluded Copy Blob
    /// operation using Set Blob Properties, Put Blob, or Put Block List.
    fn copy_completion_time(&self) -> Result<Option<OffsetDateTime>> {
        Headers::get_optional_with(self.headers(), &COPY_COMPLETION_TIME, |h| {
            parse_rfc7231(h.as_str())
        })
    }

    /// String identifier for this copy operation. Use with Get Blob Properties to check the status of this copy operation, or
    /// pass to Abort Copy Blob to abort a pending copy.
    fn copy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_ID)
    }

    /// Contains the number of bytes copied and the total bytes in the source in the last attempted Copy Blob operation where
    /// this blob was the destination blob. Can show between 0 and Content-Length bytes copied. This header does not appear if
    /// this blob has never been the destination in a Copy Blob operation, or if this blob has been modified after a concluded
    /// Copy Blob operation using Set Blob Properties, Put Blob, or Put Block List
    fn copy_progress(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_PROGRESS)
    }

    /// URL up to 2 KB in length that specifies the source blob or file used in the last attempted Copy Blob operation where this
    /// blob was the destination blob. This header does not appear if this blob has never been the destination in a Copy Blob
    /// operation, or if this blob has been modified after a concluded Copy Blob operation using Set Blob Properties, Put Blob,
    /// or Put Block List.
    fn copy_source(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_SOURCE)
    }

    /// State of the copy operation identified by x-ms-copy-id.
    fn copy_status(&self) -> Result<Option<CopyStatus>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS)
    }

    /// Only appears when x-ms-copy-status is failed or pending. Describes the cause of the last fatal or non-fatal copy operation
    /// failure. This header does not appear if this blob has never been the destination in a Copy Blob operation, or if this
    /// blob has been modified after a concluded Copy Blob operation using Set Blob Properties, Put Blob, or Put Block List
    fn copy_status_description(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS_DESCRIPTION)
    }

    /// Returns the date and 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    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)
    }

    /// UTC date/time value generated by the service 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())
        })
    }

    /// The value of this header indicates whether version of this blob is a current version, see also x-ms-version-id header.
    fn is_current_version(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IS_CURRENT_VERSION)
    }

    /// UTC date/time value generated by the service that indicates the time at which the blob was last read or written to
    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, in seconds, or negative one (-1) for a lease that never expires. A non-infinite lease
    /// can be between 15 and 60 seconds. A lease duration cannot be changed using renew or change.
    fn duration(&self) -> Result<Option<LeaseDuration>> {
        Headers::get_optional_as(self.headers(), &LEASE_DURATION)
    }

    /// 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)
    }

    /// Optional. Only valid when Object Replication is enabled for the storage container and on the source blob of the replication.
    /// When retrieving this header, it will return the header with the policy id and rule id (e.g. x-ms-or-policyid_ruleid),
    /// and the value will be the status of the replication (e.g. complete, failed).
    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)
    }

    /// Optional. Only valid when Object Replication is enabled for the storage container and on the destination blob of the replication.
    fn object_replication_policy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &OR_POLICY_ID)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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> {
    /// Identifies the account kind
    fn account_kind(&self) -> Result<Option<AccountKind>> {
        Headers::get_optional_as(self.headers(), &ACCOUNT_KIND)
    }

    /// Version 2019-07-07 and newer. 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)
    }

    /// Identifies 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> {
    /// This header is returned if it was previously specified for the blob.
    fn cache_control(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CACHE_CONTROL)
    }

    /// This header returns the value that was specified for the 'x-ms-blob-content-disposition' header. The Content-Disposition
    /// response header field conveys additional information about how to process the response payload, and also can be used to
    /// attach additional metadata. For example, if set to attachment, it indicates that the user-agent should not display the
    /// response, but instead show a Save As dialog with a filename other than the blob name specified.
    fn content_disposition(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_DISPOSITION)
    }

    /// This header returns the value that was specified for the Content-Encoding request header
    fn content_encoding(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &CONTENT_ENCODING)
    }

    /// This header returns the value that was specified for the Content-Language request header.
    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)
    }

    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    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)
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 tier of page blob on a premium storage account or tier of block blob on blob storage LRS accounts. For a list of allowed
    /// premium page blob tiers, see <https://learn.microsoft.com/azure/virtual-machines/disks-types#premium-ssd>. For blob storage
    /// LRS accounts, valid values are Hot/Cool/Archive.
    fn access_tier(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ACCESS_TIER)
    }

    /// The time the tier was changed on the object. This is only returned if the tier on the block 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())
        })
    }

    /// For page blobs on a premium storage account only. If the access tier is not explicitly set on the blob, the tier is inferred
    /// based on its content length and this header will be returned with true value.
    fn access_tier_inferred(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &ACCESS_TIER_INFERRED)
    }

    /// For blob storage LRS accounts, valid values are rehydrate-pending-to-hot/rehydrate-pending-to-cool. If the blob is being
    /// rehydrated and is not complete then this header is returned indicating that rehydrate is pending and also tells 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. This header is returned only for append blobs.
    fn blob_committed_block_count(&self) -> Result<Option<i32>> {
        Headers::get_optional_as(self.headers(), &BLOB_COMMITTED_BLOCK_COUNT)
    }

    /// If this blob has been sealed
    fn is_sealed(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEALED)
    }

    /// The current sequence number for a page blob. This header is not returned for block blobs or append blobs.
    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)
    }

    /// Conclusion time of the last attempted Copy Blob operation where this blob was the destination blob. This value can specify
    /// the time of a completed, aborted, or failed copy attempt. This header does not appear if a copy is pending, if this blob
    /// has never been the destination in a Copy Blob operation, or if this blob has been modified after a concluded Copy Blob
    /// operation using Set Blob Properties, Put Blob, or Put Block List.
    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. Snapshot time
    /// of the last successful incremental copy snapshot for this blob.
    fn destination_snapshot(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_DESTINATION_SNAPSHOT)
    }

    /// String identifier for this copy operation. Use with Get Blob Properties to check the status of this copy operation, or
    /// pass to Abort Copy Blob to abort a pending copy.
    fn copy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_ID)
    }

    /// Contains the number of bytes copied and the total bytes in the source in the last attempted Copy Blob operation where
    /// this blob was the destination blob. Can show between 0 and Content-Length bytes copied. This header does not appear if
    /// this blob has never been the destination in a Copy Blob operation, or if this blob has been modified after a concluded
    /// Copy Blob operation using Set Blob Properties, Put Blob, or Put Block List
    fn copy_progress(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_PROGRESS)
    }

    /// URL up to 2 KB in length that specifies the source blob or file used in the last attempted Copy Blob operation where this
    /// blob was the destination blob. This header does not appear if this blob has never been the destination in a Copy Blob
    /// operation, or if this blob has been modified after a concluded Copy Blob operation using Set Blob Properties, Put Blob,
    /// or Put Block List.
    fn copy_source(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_SOURCE)
    }

    /// State of the copy operation identified by x-ms-copy-id.
    fn copy_status(&self) -> Result<Option<CopyStatus>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS)
    }

    /// Only appears when x-ms-copy-status is failed or pending. Describes the cause of the last fatal or non-fatal copy operation
    /// failure. This header does not appear if this blob has never been the destination in a Copy Blob operation, or if this
    /// blob has been modified after a concluded Copy Blob operation using Set Blob Properties, Put Blob, or Put Block List
    fn copy_status_description(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &COPY_STATUS_DESCRIPTION)
    }

    /// Returns the date and 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The 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)
    }

    /// UTC date/time value generated by the service 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)
    }

    /// The value of this header indicates whether version of this blob is a current version, see also x-ms-version-id header.
    fn is_current_version(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &IS_CURRENT_VERSION)
    }

    /// UTC date/time value generated by the service that indicates the time at which the blob was last read or written to
    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, in seconds, or negative one (-1) for a lease that never expires. A non-infinite lease
    /// can be between 15 and 60 seconds. A lease duration cannot be changed using renew or change.
    fn duration(&self) -> Result<Option<LeaseDuration>> {
        Headers::get_optional_as(self.headers(), &LEASE_DURATION)
    }

    /// 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)
    }

    /// Optional. Only valid when Object Replication is enabled for the storage container and on the source blob of the replication.
    /// When retrieving this header, it will return the header with the policy id and rule id (e.g. x-ms-or-policyid_ruleid),
    /// and the value will be the status of the replication (e.g. complete, failed).
    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)
    }

    /// Optional. Only valid when Object Replication is enabled for the storage container and on the destination blob of the replication.
    fn object_replication_policy_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &OR_POLICY_ID)
    }

    /// If an object is in rehydrate pending state then this header is returned with priority of rehydrate. Valid values are High
    /// and Standard.
    fn rehydrate_priority(&self) -> Result<Option<RehydratePriority>> {
        Headers::get_optional_as(self.headers(), &REHYDRATE_PRIORITY)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 blobs' lease
    fn lease_id(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &LEASE_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>
{
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 blobs' 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>
{
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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>
{
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 blobs' 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>
{
    /// Identifies the account kind
    fn account_kind(&self) -> Result<Option<AccountKind>> {
        Headers::get_optional_as(self.headers(), &ACCOUNT_KIND)
    }

    /// Version 2019-07-07 and newer. 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)
    }

    /// Identifies 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>
{
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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)
    }

    /// If a blob has a lease and the lease is of infinite duration then the value of this header is set to true, otherwise it
    /// is set to false.
    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 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, in seconds, or negative one (-1) for a lease that never expires. A non-infinite lease
    /// can be between 15 and 60 seconds. A lease duration cannot be changed using renew or change.
    fn duration(&self) -> Result<Option<LeaseDuration>> {
        Headers::get_optional_as(self.headers(), &LEASE_DURATION)
    }

    /// 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>
{
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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>
{
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 blobs' 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>
{
    /// Identifies the account kind
    fn account_kind(&self) -> Result<Option<AccountKind>> {
        Headers::get_optional_as(self.headers(), &ACCOUNT_KIND)
    }

    /// Version 2019-07-07 and newer. 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)
    }

    /// Identifies 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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

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

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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
///
/// ```no_run
/// 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 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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

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

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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> {
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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. This header is not returned for block blobs or append blobs.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// This response header is returned so that the client can check for the integrity of the copied 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> {
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    fn is_server_encrypted(&self) -> Result<Option<bool>> {
        Headers::get_optional_as(self.headers(), &REQUEST_SERVER_ENCRYPTED)
    }

    /// A DateTime value returned by the service that uniquely identifies the blob. The value of this header indicates the blob
    /// version, and may be used in subsequent requests to access this version 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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. This header is not returned for block blobs or append blobs.
    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>
{
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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. This header is not returned for block blobs or append blobs.
    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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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. This header is not returned for block blobs or append blobs.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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>
{
    /// If the blob has an MD5 hash and this operation is to read the full blob, this response header is returned so that the
    /// client can check for message content integrity.
    fn content_md5(&self) -> Result<Option<Vec<u8>>> {
        Headers::get_optional_with(self.headers(), &CONTENT_MD5, |h| base64::decode(h.as_str()))
    }

    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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. This header is not returned for block blobs or append blobs.
    fn blob_sequence_number(&self) -> Result<Option<i64>> {
        Headers::get_optional_as(self.headers(), &BLOB_SEQUENCE_NUMBER)
    }

    /// This response header is returned so that the client can check for the integrity of the copied 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 encryption key used to encrypt the blob. This header is only returned when the blob was encrypted
    /// with a customer-provided key.
    fn encryption_key_sha256(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_KEY_SHA256)
    }

    /// If the blob has a MD5 hash, and if request contains range header (Range or x-ms-range), this response header is returned
    /// with the value of the whole blob's MD5 value. This value may or may not be equal to the value returned in Content-MD5
    /// header, with the latter calculated from the requested range
    fn encryption_scope(&self) -> Result<Option<String>> {
        Headers::get_optional_as(self.headers(), &ENCRYPTION_SCOPE)
    }

    /// The value of this header is set to true if the contents of the request are successfully encrypted using the specified
    /// algorithm, and false otherwise.
    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::get_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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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> {
    /// The ETag contains a value that you can use to perform operations conditionally.
    fn etag(&self) -> Result<Option<Etag>> {
        Headers::get_optional_as(self.headers(), &ETAG)
    }

    /// The date/time that the container 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,
        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<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> {}
}