# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

import collections.abc
from datetime import datetime
from os import PathLike
from typing import Any, final

from typing_extensions import Unpack

from .capability import Capability
from .config import ServiceConfig
from .file import AsyncFile, File
from .layers import Layer
from .options import OpenKwargs
from .services import Scheme
from .types import Entry, Metadata, PresignedRequest

@final
class AsyncOperator:
    """
    The async equivalent of `Operator`.

    `AsyncOperator` is the entry point for all async APIs.

    See Also
    --------
    Operator
    """

    def __new__(cls, /, scheme: str | Scheme, **kwargs: str) -> AsyncOperator:
        """
        Create a new `AsyncOperator`.

        Parameters
        ----------
        scheme : str | Scheme
            The scheme of the service.
        **kwargs : dict
            The options for the service.

        Returns
        -------
        AsyncOperator
            The new async operator.
        """
    def __reduce__(self, /) -> Any: ...
    def capability(self, /) -> Capability:
        """
        Get all capabilities of this operator.

        Returns
        -------
        Capability
            The capability of the operator.
        """
    def check(self, /) -> collections.abc.Awaitable[None]:
        """
        Check if the operator is able to work correctly.

        Returns
        -------
        coroutine
            An awaitable that completes when the check is finished.

        Raises
        ------
        Exception
            If the operator is not able to work correctly.
        """
    def copy(
        self, /, source: str | PathLike[str], target: str | PathLike[str]
    ) -> collections.abc.Awaitable[None]:
        """
        Copy a file from one path to another.

        Parameters
        ----------
        source : str
            The path to the source file.
        target : str
            The path to the target file.

        Returns
        -------
        coroutine
            An awaitable that completes when the copy is finished.
        """
    def create_dir(
        self, /, path: str | PathLike[str]
    ) -> collections.abc.Awaitable[None]:
        """
        Create a directory at the given path.

        Notes
        -----
        To indicate that a path is a directory, it must end with a `/`.
        This operation is always recursive, like `mkdir -p`.

        Parameters
        ----------
        path : str
            The path to the directory.

        Returns
        -------
        coroutine
            An awaitable that completes when the directory is created.
        """
    def delete(
        self,
        /,
        path: str | PathLike[str],
        *,
        version: str | None = None,
        recursive: bool | None = None,
    ) -> collections.abc.Awaitable[None]:
        """
        Delete a file at the given path.

        Notes
        -----
        This operation will not return an error if the path does not exist.

        Parameters
        ----------
        path : str
            The path to the file.

        Returns
        -------
        coroutine
            An awaitable that completes when the file is deleted.
        version : str, optional
            The version of the file to delete. Only supported on version-aware backends.
        recursive : bool, optional
            If True, delete the path recursively.
            Only supported on backends that support recursive delete.
        """
    def exists(self, /, path: str | PathLike[str]) -> collections.abc.Awaitable[bool]:
        """
        Check if a path exists.

        Parameters
        ----------
        path : str
            The path to check.

        Returns
        -------
        coroutine
            An awaitable that returns True if the path exists, False otherwise.
        """
    @classmethod
    def from_config(cls, /, config: ServiceConfig) -> AsyncOperator:
        """
        Create a new `AsyncOperator` from a typed service config.

        The config is an ``opendal.config.ServiceConfig`` (e.g. ``S3Config``); its
        ``scheme`` key selects the service, so a static type checker rejects a
        wrong scheme, a missing required key, an unknown key, and a wrong value
        type. Non-string values (``bool``, ``int``, ``os.PathLike``, ``list``)
        are converted to the string form core consumes.

        Parameters
        ----------
        config : ServiceConfig
            A service configuration such as ``opendal.config.S3Config``.

        Returns
        -------
        AsyncOperator
            The new async operator.

        Examples
        --------
        ```python
        import opendal
        from opendal.config import S3Config

        op = opendal.AsyncOperator.from_config(
            S3Config(scheme="s3", bucket="my-bucket")
        )
        ```
        """
    @classmethod
    def from_uri(cls, /, uri: str, **kwargs: str) -> AsyncOperator:
        """
        Create a new `AsyncOperator` from a URI string.

        The URI encodes the scheme and configuration in a single string, e.g.
        ``memory://`` or ``s3://bucket/path?region=us-east-1``. The scheme must
        belong to a service enabled in this build. Encode service options as
        query parameters; use ``urllib.parse.urlencode`` when building the URI
        dynamically.

        Parameters
        ----------
        uri : str
            The URI of the service, including any options as query parameters.
        **kwargs : dict
            Overrides for URI options. Prefer the URI query string.

        Returns
        -------
        AsyncOperator
            The new async operator.

        Examples
        --------
        ```python
        from urllib.parse import urlencode
        import opendal

        op = opendal.AsyncOperator.from_uri("memory://")
        query = urlencode({"region": "us-east-1"})
        op = opendal.AsyncOperator.from_uri(
            f"s3://bucket/path?{query}"
        )
        ```
        """
    def layer(self, /, layer: Layer) -> AsyncOperator:
        """
        Add a new layer to the operator.

        Parameters
        ----------
        layer : Layer
            The layer to add.

        Returns
        -------
        AsyncOperator
            A new operator with the layer added.
        """
    def list(
        self,
        /,
        path: str | PathLike[str],
        *,
        limit: int | None = None,
        start_after: str | None = None,
        recursive: bool | None = None,
        versions: bool | None = None,
        deleted: bool | None = None,
    ) -> collections.abc.Awaitable[collections.abc.AsyncIterable[Entry]]:
        """
        List entries in the given directory.

        Parameters
        ----------
        path : str
            The path to the directory.
        limit : int, optional
            The maximum number of entries to return.
        start_after : str, optional
            The entry to start after.
        recursive : bool, optional
            Whether to list recursively.
        versions : bool, optional
            Whether to list versions.
        deleted : bool, optional
            Whether to list deleted entries.

        Returns
        -------
        coroutine
            An awaitable that returns an async iterator over the entries.
        """
    def open(
        self, /, path: str | PathLike[str], mode: str, **kwargs: Unpack[OpenKwargs]
    ) -> collections.abc.Awaitable[AsyncFile]:
        """
        Open an async file-like object for the given path.

        The returning async file-like object is a context manager.

        Parameters
        ----------
        path : str
            The path to the file.
        mode : str
            The mode to open the file in. Only "rb" and "wb" are supported.
        **kwargs : dict
            Additional options for the underlying reader or writer.

        Returns
        -------
        coroutine
            An awaitable that returns a file-like object.
        """
    def presign_delete(
        self,
        /,
        path: str | PathLike[str],
        expire_second: int,
        *,
        version: str | None = None,
    ) -> collections.abc.Awaitable[PresignedRequest]:
        """
        Create a presigned request for a delete operation.

        Parameters
        ----------
        path : str
            The path of the object to delete.
        expire_second : int
            The number of seconds until the presigned URL expires.
        version : str, optional
            The version of the file to delete.

        Returns
        -------
        coroutine
            An awaitable that returns a presigned request object.
        """
    def presign_read(
        self,
        /,
        path: str | PathLike[str],
        expire_second: int,
        *,
        version: str | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_modified_since: datetime | None = None,
        if_unmodified_since: datetime | None = None,
        content_type: str | None = None,
        cache_control: str | None = None,
        content_disposition: str | None = None,
    ) -> collections.abc.Awaitable[PresignedRequest]:
        """
        Create a presigned request for a read operation.

        Parameters
        ----------
        path : str
            The path of the object to read.
        expire_second : int
            The number of seconds until the presigned URL expires.
        version : str, optional
            The version of the file.
        if_match : str, optional
            The ETag to match.
        if_none_match : str, optional
            The ETag to not match.
        if_modified_since : datetime, optional
            Only return if modified since this time.
        if_unmodified_since : datetime, optional
            Only return if unmodified since this time.
        content_type : str, optional
            Override the content type in the presigned response.
        cache_control : str, optional
            Override the cache control in the presigned response.
        content_disposition : str, optional
            Override the content disposition in the presigned response.

        Returns
        -------
        coroutine
            An awaitable that returns a presigned request object.
        """
    def presign_stat(
        self,
        /,
        path: str | PathLike[str],
        expire_second: int,
        *,
        version: str | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_modified_since: datetime | None = None,
        if_unmodified_since: datetime | None = None,
        content_type: str | None = None,
        cache_control: str | None = None,
        content_disposition: str | None = None,
    ) -> collections.abc.Awaitable[PresignedRequest]:
        """
        Create a presigned request for a stat operation.

        Parameters
        ----------
        path : str
            The path of the object to stat.
        expire_second : int
            The number of seconds until the presigned URL expires.
        version : str, optional
            The version of the file.
        if_match : str, optional
            The ETag to match.
        if_none_match : str, optional
            The ETag to not match.
        if_modified_since : datetime, optional
            Only return if modified since this time.
        if_unmodified_since : datetime, optional
            Only return if unmodified since this time.
        content_type : str, optional
            Override the content type in the presigned response.
        cache_control : str, optional
            Override the cache control in the presigned response.
        content_disposition : str, optional
            Override the content disposition in the presigned response.

        Returns
        -------
        coroutine
            An awaitable that returns a presigned request object.
        """
    def presign_write(
        self,
        /,
        path: str | PathLike[str],
        expire_second: int,
        *,
        content_type: str | None = None,
        content_disposition: str | None = None,
        content_encoding: str | None = None,
        cache_control: str | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_not_exists: bool | None = None,
        user_metadata: dict[str, str] | None = None,
    ) -> collections.abc.Awaitable[PresignedRequest]:
        """
        Create a presigned request for a write operation.

        Parameters
        ----------
        path : str
            The path of the object to write to.
        expire_second : int
            The number of seconds until the presigned URL expires.
        content_type : str, optional
            The content type header to set on the file.
        content_disposition : str, optional
            The content disposition header to set on the file.
        content_encoding : str, optional
            The content encoding header to set on the file.
        cache_control : str, optional
            The cache control header to set on the file.
        if_match : str, optional
            The ETag to match when writing the file.
        if_none_match : str, optional
            The ETag to not match when writing the file.
        if_not_exists : bool, optional
            Whether to fail if the file already exists.
        user_metadata : dict, optional
            The user metadata to set on the file.

        Returns
        -------
        coroutine
            An awaitable that returns a presigned request object.
        """
    def read(
        self,
        /,
        path: str | PathLike[str],
        *,
        version: str | None = None,
        concurrent: int | None = None,
        chunk: int | None = None,
        gap: int | None = None,
        offset: int | None = None,
        prefetch: int | None = None,
        size: int | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_modified_since: datetime | None = None,
        if_unmodified_since: datetime | None = None,
        content_type: str | None = None,
        cache_control: str | None = None,
        content_disposition: str | None = None,
    ) -> collections.abc.Awaitable[bytes]:
        """
        Read the entire contents of a file at the given path.

        Parameters
        ----------
        path : str
            The path to the file.
        version : str, optional
            The version of the file.
        concurrent : int, optional
            The number of concurrent readers.
        chunk : int, optional
            The size of each chunk.
        gap : int, optional
            The gap between each chunk.
        offset : int, optional
            The offset of the file.
        prefetch : int, optional
            The number of bytes to prefetch.
        size : int, optional
            The size of the file.
        if_match : str, optional
            The ETag of the file.
        if_none_match : str, optional
            The ETag of the file.
        if_modified_since : str, optional
            The last modified time of the file.
        if_unmodified_since : str, optional
            The last modified time of the file.
        content_type : str, optional
            The content type of the file.
        cache_control : str, optional
            The cache control of the file.
        content_disposition : str, optional
            The content disposition of the file.

        Returns
        -------
        coroutine
            An awaitable that returns the contents of the file as bytes.
        """
    def remove_all(
        self, /, path: str | PathLike[str]
    ) -> collections.abc.Awaitable[None]:
        """
        Recursively remove all files and directories at the given path.

        Parameters
        ----------
        path : str
            The path to remove.

        Returns
        -------
        coroutine
            An awaitable that completes when the removal is finished.
        """
    def rename(
        self, /, source: str | PathLike[str], target: str | PathLike[str]
    ) -> collections.abc.Awaitable[None]:
        """
        Rename (move) a file from one path to another.

        Parameters
        ----------
        source : str
            The path to the source file.
        target : str
            The path to the target file.

        Returns
        -------
        coroutine
            An awaitable that completes when the rename is finished.
        """
    def scan(
        self,
        /,
        path: str | PathLike[str],
        *,
        limit: int | None = None,
        start_after: str | None = None,
        versions: bool | None = None,
        deleted: bool | None = None,
    ) -> collections.abc.Awaitable[collections.abc.AsyncIterable[Entry]]:
        """
        Recursively list entries in the given directory.

        Deprecated
        ----------
            Use `list()` with `recursive=True` instead.

        Parameters
        ----------
        path : str
            The path to the directory.
        limit : int, optional
            The maximum number of entries to return.
        start_after : str, optional
            The entry to start after.
        versions : bool, optional
            Whether to list versions.
        deleted : bool, optional
            Whether to list deleted entries.

        Returns
        -------
        coroutine
            An awaitable that returns an async iterator over the entries.
        """
    def stat(
        self,
        /,
        path: str | PathLike[str],
        *,
        version: str | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_modified_since: datetime | None = None,
        if_unmodified_since: datetime | None = None,
        content_type: str | None = None,
        cache_control: str | None = None,
        content_disposition: str | None = None,
    ) -> collections.abc.Awaitable[Metadata]:
        """
        Get the metadata of a file at the given path.

        Parameters
        ----------
        path : str
            The path to the file.
        version : str, optional
            The version of the file.
        if_match : str, optional
            The ETag of the file.
        if_none_match : str, optional
            The ETag of the file.
        if_modified_since : datetime, optional
            The last modified time of the file.
        if_unmodified_since : datetime, optional
            The last modified time of the file.
        content_type : str, optional
            The content type of the file.
        cache_control : str, optional
            The cache control of the file.
        content_disposition : str, optional
            The content disposition of the file.

        Returns
        -------
        coroutine
            An awaitable that returns the metadata of the file.
        """
    def to_operator(self, /) -> Operator:
        """
        Create a new blocking `Operator` from this async operator.

        Returns
        -------
        Operator
            The blocking operator.
        """
    def write(
        self,
        /,
        path: str | PathLike[str],
        bs: bytes,
        *,
        append: bool | None = None,
        chunk: int | None = None,
        concurrent: int | None = None,
        cache_control: str | None = None,
        content_type: str | None = None,
        content_disposition: str | None = None,
        content_encoding: str | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_not_exists: bool | None = None,
        user_metadata: dict[str, str] | None = None,
    ) -> collections.abc.Awaitable[None]:
        """
        Write bytes to a file at the given path.

        This function will create a file if it does not exist, and will
        overwrite its contents if it does.

        Parameters
        ----------
        path : str
            The path to the file.
        bs : bytes
            The contents to write to the file.
        append : bool, optional
            Whether to append to the file instead of overwriting it.
        chunk : int, optional
            The chunk size to use when writing the file.
        concurrent : int, optional
            The number of concurrent requests to make when writing the file.
        cache_control : str, optional
            The cache control header to set on the file.
        content_type : str, optional
            The content type header to set on the file.
        content_disposition : str, optional
            The content disposition header to set on the file.
        content_encoding : str, optional
            The content encoding header to set on the file.
        if_match : str, optional
            The ETag to match when writing the file.
        if_none_match : str, optional
            The ETag to not match when writing the file.
        if_not_exists : bool, optional
            Whether to fail if the file already exists.
        user_metadata : dict, optional
            The user metadata to set on the file.

        Returns
        -------
        coroutine
            An awaitable that completes when the write is finished.
        """

@final
class Operator:
    """
    The blocking equivalent of `AsyncOperator`.

    `Operator` is the entry point for all blocking APIs.

    See Also
    --------
    AsyncOperator
    """

    def __new__(cls, /, scheme: str | Scheme, **kwargs: str) -> Operator:
        """
        Create a new blocking `Operator`.

        Parameters
        ----------
        scheme : str | Scheme
            The scheme of the service.
        **kwargs : dict
            The options for the service.

        Returns
        -------
        Operator
            The new operator.
        """
    def __reduce__(self, /) -> Any: ...
    def capability(self, /) -> Capability:
        """
        Get all capabilities of this operator.

        Returns
        -------
        Capability
            The capability of the operator.
        """
    def check(self, /) -> None:
        """
        Check if the operator is able to work correctly.

        Raises
        ------
        Exception
            If the operator is not able to work correctly.
        """
    def copy(self, /, source: str | PathLike[str], target: str | PathLike[str]) -> None:
        """
        Copy a file from one path to another.

        Parameters
        ----------
        source : str
            The path to the source file.
        target : str
            The path to the target file.
        """
    def create_dir(self, /, path: str | PathLike[str]) -> None:
        """
        Create a directory at the given path.

        Notes
        -----
        To indicate that a path is a directory, it must end with a `/`.
        This operation is always recursive, like `mkdir -p`.

        Parameters
        ----------
        path : str
            The path to the directory.
        """
    def delete(
        self,
        /,
        path: str | PathLike[str],
        *,
        version: str | None = None,
        recursive: bool | None = None,
    ) -> None:
        """
        Delete a file at the given path.

        Notes
        -----
        This operation will not return an error if the path does not exist.

        Parameters
        ----------
        path : str
            The path to the file.
        version : str, optional
            The version of the file to delete. Only supported on version-aware backends.
        recursive : bool, optional
            If True, delete the path recursively.
            Only supported on backends that support recursive delete.
        """
    def exists(self, /, path: str | PathLike[str]) -> bool:
        """
        Check if a path exists.

        Parameters
        ----------
        path : str
            The path to check.

        Returns
        -------
        bool
            True if the path exists, False otherwise.
        """
    @classmethod
    def from_config(cls, /, config: ServiceConfig) -> Operator:
        """
        Create a new blocking `Operator` from a typed service config.

        The config is an ``opendal.config.ServiceConfig`` (e.g. ``S3Config``); its
        ``scheme`` key selects the service, so a static type checker rejects a
        wrong scheme, a missing required key, an unknown key, and a wrong value
        type. Non-string values (``bool``, ``int``, ``os.PathLike``, ``list``)
        are converted to the string form core consumes.

        Parameters
        ----------
        config : ServiceConfig
            A service configuration such as ``opendal.config.S3Config``.

        Returns
        -------
        Operator
            The new operator.

        Examples
        --------
        ```python
        import opendal
        from opendal.config import S3Config

        op = opendal.Operator.from_config(
            S3Config(scheme="s3", bucket="my-bucket")
        )
        ```
        """
    @classmethod
    def from_uri(cls, /, uri: str, **kwargs: str) -> Operator:
        """
        Create a new blocking `Operator` from a URI string.

        The URI encodes the scheme and configuration in a single string, e.g.
        ``memory://`` or ``s3://bucket/path?region=us-east-1``. The scheme must
        belong to a service enabled in this build. Encode service options as
        query parameters; use ``urllib.parse.urlencode`` when building the URI
        dynamically.

        Parameters
        ----------
        uri : str
            The URI of the service, including any options as query parameters.
        **kwargs : dict
            Overrides for URI options. Prefer the URI query string.

        Returns
        -------
        Operator
            The new operator.

        Examples
        --------
        ```python
        from urllib.parse import urlencode
        import opendal

        op = opendal.Operator.from_uri("memory://")
        query = urlencode({"region": "us-east-1"})
        op = opendal.Operator.from_uri(f"s3://bucket/path?{query}")
        ```
        """
    def layer(self, /, layer: Layer) -> Operator:
        """
        Add a new layer to this operator.

        Parameters
        ----------
        layer : Layer
            The layer to add.

        Returns
        -------
        Operator
            A new operator with the layer added.
        """
    def list(
        self,
        /,
        path: str | PathLike[str],
        *,
        limit: int | None = None,
        start_after: str | None = None,
        recursive: bool | None = None,
        versions: bool | None = None,
        deleted: bool | None = None,
    ) -> collections.abc.Iterable[Entry]:
        """
        List entries in the given directory.

        Parameters
        ----------
        path : str
            The path to the directory.
        limit : int, optional
            The maximum number of entries to return.
        start_after : str, optional
            The entry to start after.
        recursive : bool, optional
            Whether to list recursively.
        versions : bool, optional
            Whether to list versions.
        deleted : bool, optional
            Whether to list deleted entries.

        Returns
        -------
        BlockingLister
            An iterator over the entries in the directory.
        """
    def open(
        self, /, path: str | PathLike[str], mode: str, **kwargs: Unpack[OpenKwargs]
    ) -> File:
        """
        Open a file-like object for the given path.

        The returning file-like object is a context manager.

        Parameters
        ----------
        path : str
            The path to the file.
        mode : str
            The mode to open the file in. Only "rb" and "wb" are supported.
        **kwargs
            Additional options for the underlying reader or writer.

        Returns
        -------
        File
            A file-like object.
        """
    def read(
        self,
        /,
        path: str | PathLike[str],
        *,
        version: str | None = None,
        concurrent: int | None = None,
        chunk: int | None = None,
        gap: int | None = None,
        offset: int | None = None,
        prefetch: int | None = None,
        size: int | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_modified_since: datetime | None = None,
        if_unmodified_since: datetime | None = None,
        content_type: str | None = None,
        cache_control: str | None = None,
        content_disposition: str | None = None,
    ) -> bytes:
        """
        Read the entire contents of a file at the given path.

        Parameters
        ----------
        path : str
            The path to the file.
        version : str, optional
            The version of the file.
        concurrent : int, optional
            The number of concurrent readers.
        chunk : int, optional
            The size of each chunk.
        gap : int, optional
            The gap between each chunk.
        offset : int, optional
            The offset of the file.
        prefetch : int, optional
            The number of bytes to prefetch.
        size : int, optional
            The size of the file.
        if_match : str, optional
            The ETag of the file.
        if_none_match : str, optional
            The ETag of the file.
        if_modified_since : str, optional
            The last modified time of the file.
        if_unmodified_since : str, optional
            The last modified time of the file.
        content_type : str, optional
            The content type of the file.
        cache_control : str, optional
            The cache control of the file.
        content_disposition : str, optional
            The content disposition of the file.

        Returns
        -------
        bytes
            The contents of the file as bytes.
        """
    def remove_all(self, /, path: str | PathLike[str]) -> None:
        """
        Recursively remove all files and directories at the given path.

        Parameters
        ----------
        path : str
            The path to remove.
        """
    def rename(
        self, /, source: str | PathLike[str], target: str | PathLike[str]
    ) -> None:
        """
        Rename (move) a file from one path to another.

        Parameters
        ----------
        source : str
            The path to the source file.
        target : str
            The path to the target file.
        """
    def scan(
        self,
        /,
        path: str | PathLike[str],
        *,
        limit: int | None = None,
        start_after: str | None = None,
        versions: bool | None = None,
        deleted: bool | None = None,
    ) -> collections.abc.Iterable[Entry]:
        """
        Recursively list entries in the given directory.

        Deprecated
        ----------
            Use `list()` with `recursive=True` instead.

        Parameters
        ----------
        path : str
            The path to the directory.
        limit : int, optional
            The maximum number of entries to return.
        start_after : str, optional
            The entry to start after.
        versions : bool, optional
            Whether to list versions.
        deleted : bool, optional
            Whether to list deleted entries.

        Returns
        -------
        BlockingLister
            An iterator over the entries in the directory.
        """
    def stat(
        self,
        /,
        path: str | PathLike[str],
        *,
        version: str | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_modified_since: datetime | None = None,
        if_unmodified_since: datetime | None = None,
        content_type: str | None = None,
        cache_control: str | None = None,
        content_disposition: str | None = None,
    ) -> Metadata:
        """
        Get the metadata of a file at the given path.

        Parameters
        ----------
        path : str
            The path to the file.
        version : str, optional
            The version of the file.
        if_match : str, optional
            The ETag of the file.
        if_none_match : str, optional
            The ETag of the file.
        if_modified_since : datetime, optional
            The last modified time of the file.
        if_unmodified_since : datetime, optional
            The last modified time of the file.
        content_type : str, optional
            The content type of the file.
        cache_control : str, optional
            The cache control of the file.
        content_disposition : str, optional
            The content disposition of the file.

        Returns
        -------
        Metadata
            The metadata of the file.
        """
    def to_async_operator(self, /) -> AsyncOperator:
        """
        Create a new `AsyncOperator` from this blocking operator.

        Returns
        -------
        AsyncOperator
            The async operator.
        """
    def write(
        self,
        /,
        path: str | PathLike[str],
        bs: bytes,
        *,
        append: bool | None = None,
        chunk: int | None = None,
        concurrent: int | None = None,
        cache_control: str | None = None,
        content_type: str | None = None,
        content_disposition: str | None = None,
        content_encoding: str | None = None,
        if_match: str | None = None,
        if_none_match: str | None = None,
        if_not_exists: bool | None = None,
        user_metadata: dict[str, str] | None = None,
    ) -> None:
        """
        Write bytes to a file at the given path.

        This function will create a file if it does not exist, and will
        overwrite its contents if it does.

        Parameters
        ----------
        path : str
            The path to the file.
        bs : bytes
            The contents to write to the file.
        append : bool, optional
            Whether to append to the file instead of overwriting it.
        chunk : int, optional
            The chunk size to use when writing the file.
        concurrent : int, optional
            The number of concurrent requests to make when writing the file.
        cache_control : str, optional
            The cache control header to set on the file.
        content_type : str, optional
            The content type header to set on the file.
        content_disposition : str, optional
            The content disposition header to set on the file.
        content_encoding : str, optional
            The content encoding header to set on the file.
        if_match : str, optional
            The ETag to match when writing the file.
        if_none_match : str, optional
            The ETag to not match when writing the file.
        if_not_exists : bool, optional
            Whether to fail if the file already exists.
        user_metadata : dict, optional
            The user metadata to set on the file.
        """
