Differential D3383 Diff 12007 swh/storage/cassandra/storage.py

Changeset View

Standalone View

swh/storage/cassandra/storage.py

Show First 20 Lines • Show All 1,045 Lines • ▼ Show 20 Lines	def content_metadata_get(
after: Optional[datetime.datetime] = None,		after: Optional[datetime.datetime] = None,
page_token: Optional[bytes] = None,		page_token: Optional[bytes] = None,
limit: int = 1000,		limit: int = 1000,
) -> Dict[str, Any]:		) -> Dict[str, Any]:
return self._object_metadata_get(		return self._object_metadata_get(
"content", id, authority, after, page_token, limit,		"content", id, authority, after, page_token, limit,
)		)

		def directory_metadata_add(
		self,
		id: str,
		context: Dict[str, Union[str, bytes, int]],
		discovery_date: datetime.datetime,
		authority: Dict[str, Any],
		fetcher: Dict[str, Any],
		format: str,
		metadata: bytes,
		) -> None:
		self._object_metadata_add(
		"directory",
		id,
		discovery_date,
		authority,
		fetcher,
		format,
		metadata,
		context,
		)

		def directory_metadata_get(
		self,
		id: str,
		authority: Dict[str, str],
		after: Optional[datetime.datetime] = None,
		page_token: Optional[bytes] = None,
		limit: int = 1000,
		) -> Dict[str, Any]:
		return self._object_metadata_get(
		"directory", id, authority, after, page_token, limit,
		)

		def revision_metadata_add(
		self,
		id: str,
		context: Dict[str, Union[str, bytes, int]],
		discovery_date: datetime.datetime,
		authority: Dict[str, Any],
		fetcher: Dict[str, Any],
		format: str,
		metadata: bytes,
		) -> None:
		self._object_metadata_add(
		"revision",
		id,
		discovery_date,
		authority,
		fetcher,
		format,
		metadata,
		context,
		)

		def revision_metadata_get(
		self,
		id: str,
		authority: Dict[str, str],
		after: Optional[datetime.datetime] = None,
		page_token: Optional[bytes] = None,
		limit: int = 1000,
		) -> Dict[str, Any]:
		return self._object_metadata_get(
		"revision", id, authority, after, page_token, limit,
		)

		def release_metadata_add(
		self,
		id: str,
		context: Dict[str, Union[str, bytes, int]],
		discovery_date: datetime.datetime,
		authority: Dict[str, Any],
		fetcher: Dict[str, Any],
		format: str,
		metadata: bytes,
		) -> None:
		self._object_metadata_add(
		"release",
		id,
		discovery_date,
		authority,
		fetcher,
		format,
		metadata,
		context,
		)

		def release_metadata_get(
		self,
		id: str,
		authority: Dict[str, str],
		after: Optional[datetime.datetime] = None,
		page_token: Optional[bytes] = None,
		limit: int = 1000,
		) -> Dict[str, Any]:
		return self._object_metadata_get(
		"release", id, authority, after, page_token, limit,
		)

		def snapshot_metadata_add(
		self,
		id: str,
		context: Dict[str, Union[str, bytes, int]],
		discovery_date: datetime.datetime,
		authority: Dict[str, Any],
		fetcher: Dict[str, Any],
		format: str,
		metadata: bytes,
		) -> None:
		self._object_metadata_add(
		"snapshot",
		id,
		discovery_date,
		authority,
		fetcher,
		format,
		metadata,
		context,
		)

		def snapshot_metadata_get(
		self,
		id: str,
		authority: Dict[str, str],
		after: Optional[datetime.datetime] = None,
		page_token: Optional[bytes] = None,
		limit: int = 1000,
		) -> Dict[str, Any]:
		return self._object_metadata_get(
		"snapshot", id, authority, after, page_token, limit,
		)

def origin_metadata_add(		def origin_metadata_add(
self,		self,
origin_url: str,		origin_url: str,
discovery_date: datetime.datetime,		discovery_date: datetime.datetime,
authority: Dict[str, Any],		authority: Dict[str, Any],
fetcher: Dict[str, Any],		fetcher: Dict[str, Any],
format: str,		format: str,
metadata: bytes,		metadata: bytes,
▲ Show 20 Lines • Show All 197 Lines • Show Last 20 Lines