cterasdk.direct.client module

class cterasdk.direct.client.DirectIO(baseurl=None, access_key_id=None, secret_access_key=None, bearer=None)

Bases: object

async blocks(file_id, byte_range=None, max_workers=None)

Blocks API.

Parameters:

• file_id (int) – File ID.

• byte_range (cterasdk.direct.types.ByteRange, optional) – Byte range.

• max_workers (int, optional) – Max concurrent tasks.

Returns:

List of Blocks.

Return type:

list[cterasdk.direct.types.Block]

async close()

executor(metadata, file_id=None, byte_range=None, max_workers=None)

Download Executor.

Parameters:

• metadata (cterasdk.direct.types.Metadata) – Direct I/O file metadata.

• file_id (int, optional) – File ID.

• byte_range (cterasdk.direct.types.ByteRange, optional) – Byte range.

• max_workers (int, optional) – Max concurrent tasks.

Returns:

Callable downloader.

Return type:

function

async metadata(file_id)

Get File Metadata.

Parameters:

file_id (int) – File ID.

Returns:

Serialized file metadata.

async streamer(file_id, byte_range=None, max_workers=None)

Stream API.

Parameters:

• file_id (int) – File ID.

• byte_range (cterasdk.direct.types.ByteRange, optional) – Byte range.

• max_workers (int, optional) – Max concurrent tasks.

Returns:

Streamer object.

Return type:

cterasdk.direct.stream.Streamer