temporalio.contrib.gcp.gcsdriver.gcloud_aio._GcloudAioStorageDriverClient

class documentation

class _GcloudAioStorageDriverClient(GCSStorageDriverClient): (source)

Constructor: _GcloudAioStorageDriverClient(client)

View In Hierarchy

Adapter for an application-owned gcloud-aio-storage client.

Method __init__ Wrap the async storage client.
Async Method get_object Download the object's bytes.
Async Method object_exists Check existence via object metadata.
Async Method put_object Upload bytes using conditional object creation.
Instance Variable _client Undocumented
def __init__(self, client: Storage): (source)

Wrap the async storage client.

async def get_object(self, *, bucket: str, object_name: str) -> bytes: (source)

Download the object's bytes.

async def object_exists(self, *, bucket: str, object_name: str) -> bool: (source)

Check existence via object metadata.

async def put_object(self, *, bucket: str, object_name: str, data: bytes): (source)

Upload bytes using conditional object creation.

_client = (source)

Undocumented