swh.storage.cassandra.storage module¶
-
class
swh.storage.cassandra.storage.
CassandraStorage
(hosts, keyspace, objstorage, port=9042, journal_writer=None)[source]¶ Bases:
object
-
content_add
(content: List[swh.model.model.Content]) → Dict[source]¶
-
content_add_metadata
(content: List[swh.model.model.Content]) → Dict[source]¶
-
content_get_partition
(partition_id: int, nb_partitions: int, page_token: Optional[str] = None, limit: int = 1000) → swh.core.api.classes.PagedResult[swh.model.model.Content, str][source]¶
-
content_get
(contents: List[bytes]) → List[Optional[swh.model.model.Content]][source]¶
-
content_find
(content: Dict[str, Any]) → List[swh.model.model.Content][source]¶
-
skipped_content_add
(content: List[swh.model.model.SkippedContent]) → Dict[source]¶
-
directory_add
(directories: List[swh.model.model.Directory]) → Dict[source]¶
-
directory_entry_get_by_path
(directory: bytes, paths: List[bytes]) → Optional[Dict[str, Any]][source]¶
-
revision_add
(revisions: List[swh.model.model.Revision]) → Dict[source]¶
-
revision_get
(revision_ids: List[bytes]) → List[Optional[swh.model.model.Revision]][source]¶
-
revision_log
(revisions: List[bytes], limit: Optional[int] = None) → Iterable[Optional[Dict[str, Any]]][source]¶
-
revision_shortlog
(revisions: List[bytes], limit: Optional[int] = None) → Iterable[Optional[Tuple[bytes, Tuple[bytes, …]]]][source]¶
-
release_add
(releases: List[swh.model.model.Release]) → Dict[source]¶
-
release_get
(releases: List[bytes]) → List[Optional[swh.model.model.Release]][source]¶
-
snapshot_add
(snapshots: List[swh.model.model.Snapshot]) → Dict[source]¶
-
snapshot_get_branches
(snapshot_id: bytes, branches_from: bytes = b'', branches_count: int = 1000, target_types: Optional[List[str]] = None) → Optional[swh.storage.interface.PartialBranches][source]¶
-
origin_get
(origins: List[str]) → Iterable[Optional[swh.model.model.Origin]][source]¶
-
origin_get_one
(origin_url: str) → Optional[swh.model.model.Origin][source]¶ Given an origin url, return the origin if it exists, None otherwise
-
origin_list
(page_token: Optional[str] = None, limit: int = 100) → swh.core.api.classes.PagedResult[swh.model.model.Origin, str][source]¶
-
origin_search
(url_pattern: str, page_token: Optional[str] = None, limit: int = 50, regexp: bool = False, with_visit: bool = False) → swh.core.api.classes.PagedResult[swh.model.model.Origin, str][source]¶
-
origin_add
(origins: List[swh.model.model.Origin]) → Dict[str, int][source]¶
-
origin_visit_add
(visits: List[swh.model.model.OriginVisit]) → Iterable[swh.model.model.OriginVisit][source]¶
-
origin_visit_status_add
(visit_statuses: List[swh.model.model.OriginVisitStatus]) → None[source]¶
-
origin_visit_get
(origin: str, page_token: Optional[str] = None, order: swh.storage.interface.ListOrder = <ListOrder.ASC: 'asc'>, limit: int = 10) → swh.core.api.classes.PagedResult[swh.model.model.OriginVisit, str][source]¶
-
origin_visit_status_get
(origin: str, visit: int, page_token: Optional[str] = None, order: swh.storage.interface.ListOrder = <ListOrder.ASC: 'asc'>, limit: int = 10) → swh.core.api.classes.PagedResult[swh.model.model.OriginVisitStatus, str][source]¶
-
origin_visit_find_by_date
(origin: str, visit_date: datetime.datetime) → Optional[swh.model.model.OriginVisit][source]¶
-
origin_visit_get_by
(origin: str, visit: int) → Optional[swh.model.model.OriginVisit][source]¶
-
origin_visit_get_latest
(origin: str, type: Optional[str] = None, allowed_statuses: Optional[List[str]] = None, require_snapshot: bool = False) → Optional[swh.model.model.OriginVisit][source]¶
-
origin_visit_status_get_latest
(origin_url: str, visit: int, allowed_statuses: Optional[List[str]] = None, require_snapshot: bool = False) → Optional[swh.model.model.OriginVisitStatus][source]¶
-
origin_visit_status_get_random
(type: str) → Optional[Tuple[swh.model.model.OriginVisit, swh.model.model.OriginVisitStatus]][source]¶
-
raw_extrinsic_metadata_add
(metadata: List[swh.model.model.RawExtrinsicMetadata]) → None[source]¶
-
raw_extrinsic_metadata_get
(type: swh.model.model.MetadataTargetType, target: Union[str, swh.model.identifiers.SWHID], authority: swh.model.model.MetadataAuthority, after: Optional[datetime.datetime] = None, page_token: Optional[bytes] = None, limit: int = 1000) → swh.core.api.classes.PagedResult[swh.model.model.RawExtrinsicMetadata, str][source]¶
-
metadata_fetcher_add
(fetchers: List[swh.model.model.MetadataFetcher]) → None[source]¶
-
metadata_fetcher_get
(name: str, version: str) → Optional[swh.model.model.MetadataFetcher][source]¶
-