taolib.testing.file_storage.repository.chunk_repo

目录

taolib.testing.file_storage.repository.chunk_repo#

分片记录 Repository。

提供分片记录的数据访问操作。

Classes#

ChunkRepository

分片记录 Repository。

Module Contents#

class taolib.testing.file_storage.repository.chunk_repo.ChunkRepository(collection)#

Bases: taolib.testing._base.repository.AsyncRepository[taolib.testing.file_storage.models.upload.ChunkRecord]

分片记录 Repository。

async find_by_session(session_id: str) → list[taolib.testing.file_storage.models.upload.ChunkRecord]#: 查找会话的所有分片。

async find_by_session_and_index(session_id: str, chunk_index: int) → taolib.testing.file_storage.models.upload.ChunkRecord | None#: 查找指定分片。

async count_by_session(session_id: str) → int#: 统计会话的分片数量。

async delete_by_session(session_id: str) → int#: 删除会话的所有分片记录。

async create_indexes() → None#: 创建索引。