swh.storage.cassandra package

Submodules

• swh.storage.cassandra.common module
  • TOKEN_BEGIN
  • TOKEN_END
  • hash_url()
• swh.storage.cassandra.converters module
• swh.storage.cassandra.cql module
  • PARTITION_KEY_RESTRICTION_MAX_SIZE
  • get_execution_profiles()
  • create_keyspace()
  • create_table()
  • mark_all_migrations_completed()
  • CqlRunner
    • CqlRunner.register_user_types()
    • CqlRunner.MAX_RETRIES
    • CqlRunner.execute_with_retries()
    • CqlRunner.execute_many_with_retries()
    • CqlRunner.execute_many_statements_with_retries()
    • CqlRunner.migration_add_one()
    • CqlRunner.migration_add_concurrent()
    • CqlRunner.migration_get()
    • CqlRunner.migration_list()
    • CqlRunner.content_add_prepare()
    • CqlRunner.content_get_from_pk()
    • CqlRunner.content_missing_from_all_hashes()
    • CqlRunner.content_get_from_tokens()
    • CqlRunner.content_get_random()
    • CqlRunner.content_get_token_range()
    • CqlRunner.content_delete()
    • CqlRunner.content_index_add_one()
    • CqlRunner.content_get_tokens_from_single_algo()
    • CqlRunner.skipped_content_add_prepare()
    • CqlRunner.skipped_content_get_from_pk()
    • CqlRunner.skipped_content_get_from_token()
    • CqlRunner.skipped_content_delete()
    • CqlRunner.skipped_content_index_add_one()
    • CqlRunner.skipped_content_get_tokens_from_single_hash()
    • CqlRunner.directory_missing()
    • CqlRunner.directory_add_one()
    • CqlRunner.directory_get_random()
    • CqlRunner.directory_get()
    • CqlRunner.directory_get_token_range()
    • CqlRunner.directory_delete()
    • CqlRunner.directory_entry_add_one()
    • CqlRunner.directory_entry_add_concurrent()
    • CqlRunner.directory_entry_add_batch()
    • CqlRunner.directory_entry_get()
    • CqlRunner.directory_entry_get_from_name()
    • CqlRunner.directory_entry_delete()
    • CqlRunner.revision_missing()
    • CqlRunner.revision_add_one()
    • CqlRunner.revision_get_ids()
    • CqlRunner.revision_get()
    • CqlRunner.revision_get_random()
    • CqlRunner.revision_get_token_range()
    • CqlRunner.revision_delete()
    • CqlRunner.revision_parent_add_one()
    • CqlRunner.revision_parent_get()
    • CqlRunner.revision_parent_delete()
    • CqlRunner.release_missing()
    • CqlRunner.release_add_one()
    • CqlRunner.release_get()
    • CqlRunner.release_get_random()
    • CqlRunner.release_get_token_range()
    • CqlRunner.release_delete()
    • CqlRunner.snapshot_missing()
    • CqlRunner.snapshot_add_one()
    • CqlRunner.snapshot_get_random()
    • CqlRunner.snapshot_get_token_range()
    • CqlRunner.snapshot_delete()
    • CqlRunner.snapshot_branch_add_one()
    • CqlRunner.snapshot_count_branches_from_name()
    • CqlRunner.snapshot_count_branches_before_name()
    • CqlRunner.snapshot_count_branches()
    • CqlRunner.snapshot_branch_get_from_name()
    • CqlRunner.snapshot_branch_get_range()
    • CqlRunner.snapshot_branch_get()
    • CqlRunner.snapshot_branch_delete()
    • CqlRunner.origin_add_one()
    • CqlRunner.origin_get_by_sha1()
    • CqlRunner.origin_get_by_url()
    • CqlRunner.origin_list()
    • CqlRunner.origin_iter_all()
    • CqlRunner.origin_bump_next_visit_id()
    • CqlRunner.origin_generate_unique_visit_id()
    • CqlRunner.origin_delete()
    • CqlRunner.origin_visit_get()
    • CqlRunner.origin_visit_add_one()
    • CqlRunner.origin_visit_get_one()
    • CqlRunner.origin_visit_iter_all()
    • CqlRunner.origin_visit_iter()
    • CqlRunner.origin_visit_delete()
    • CqlRunner.origin_visit_status_get_range()
    • CqlRunner.origin_visit_status_get_all_range()
    • CqlRunner.origin_visit_status_add_one()
    • CqlRunner.origin_visit_status_get_latest()
    • CqlRunner.origin_visit_status_get()
    • CqlRunner.origin_snapshot_get_all()
    • CqlRunner.origin_visit_status_delete()
    • CqlRunner.raw_extrinsic_metadata_by_id_add()
    • CqlRunner.raw_extrinsic_metadata_get_by_ids()
    • CqlRunner.raw_extrinsic_metadata_by_id_delete()
    • CqlRunner.raw_extrinsic_metadata_add()
    • CqlRunner.raw_extrinsic_metadata_get_after_date()
    • CqlRunner.raw_extrinsic_metadata_get_after_date_and_id()
    • CqlRunner.raw_extrinsic_metadata_get()
    • CqlRunner.raw_extrinsic_metadata_get_authorities()
    • CqlRunner.raw_extrinsic_metadata_delete()
    • CqlRunner.metadata_authority_add()
    • CqlRunner.metadata_authority_get()
    • CqlRunner.metadata_fetcher_add()
    • CqlRunner.metadata_fetcher_get()
    • CqlRunner.extid_add_prepare()
    • CqlRunner.extid_get_from_pk()
    • CqlRunner.extid_get_from_token()
    • CqlRunner.extid_get_from_token_and_extid_version()
    • CqlRunner.extid_get_from_extid()
    • CqlRunner.extid_get_from_extid_and_version()
    • CqlRunner.extid_get_from_target()
    • CqlRunner.extid_delete()
    • CqlRunner.extid_index_add_one()
    • CqlRunner.extid_delete_from_by_target_table()
    • CqlRunner.object_reference_add_concurrent()
    • CqlRunner.object_reference_get()
    • CqlRunner.object_references_list_tables()
    • CqlRunner.object_references_create_table()
    • CqlRunner.object_references_drop_table()
    • CqlRunner.stat_counters()
    • CqlRunner.check_read()
• swh.storage.cassandra.diagram module
• swh.storage.cassandra.model module
  • MAGIC_NULL_PK
  • content_index_table_name()
  • BaseRow
    • BaseRow.TABLE
    • BaseRow.PARTITION_KEY
    • BaseRow.CLUSTERING_KEY
    • BaseRow.denullify_clustering_key()
    • BaseRow.from_dict()
    • BaseRow.cols()
    • BaseRow.to_dict()
  • MigrationRow
    • MigrationRow.TABLE
    • MigrationRow.PARTITION_KEY
    • MigrationRow.id
    • MigrationRow.dependencies
    • MigrationRow.min_read_version
    • MigrationRow.status
  • ContentRow
    • ContentRow.TABLE
    • ContentRow.PARTITION_KEY
    • ContentRow.CLUSTERING_KEY
    • ContentRow.sha1
    • ContentRow.sha1_git
    • ContentRow.sha256
    • ContentRow.blake2s256
    • ContentRow.length
    • ContentRow.ctime
    • ContentRow.status
  • SkippedContentRow
    • SkippedContentRow.TABLE
    • SkippedContentRow.PARTITION_KEY
    • SkippedContentRow.sha1
    • SkippedContentRow.sha1_git
    • SkippedContentRow.sha256
    • SkippedContentRow.blake2s256
    • SkippedContentRow.length
    • SkippedContentRow.ctime
    • SkippedContentRow.status
    • SkippedContentRow.reason
    • SkippedContentRow.origin
    • SkippedContentRow.denullify_clustering_key()
    • SkippedContentRow.from_dict()
  • DirectoryRow
    • DirectoryRow.TABLE
    • DirectoryRow.PARTITION_KEY
    • DirectoryRow.id
    • DirectoryRow.raw_manifest
  • DirectoryEntryRow
    • DirectoryEntryRow.TABLE
    • DirectoryEntryRow.PARTITION_KEY
    • DirectoryEntryRow.CLUSTERING_KEY
    • DirectoryEntryRow.directory_id
    • DirectoryEntryRow.name
    • DirectoryEntryRow.target
    • DirectoryEntryRow.perms
    • DirectoryEntryRow.type
  • RevisionRow
    • RevisionRow.TABLE
    • RevisionRow.PARTITION_KEY
    • RevisionRow.id
    • RevisionRow.date
    • RevisionRow.committer_date
    • RevisionRow.type
    • RevisionRow.directory
    • RevisionRow.message
    • RevisionRow.author
    • RevisionRow.committer
    • RevisionRow.synthetic
    • RevisionRow.metadata
    • RevisionRow.extra_headers
    • RevisionRow.raw_manifest
  • RevisionParentRow
    • RevisionParentRow.TABLE
    • RevisionParentRow.PARTITION_KEY
    • RevisionParentRow.CLUSTERING_KEY
    • RevisionParentRow.id
    • RevisionParentRow.parent_rank
    • RevisionParentRow.parent_id
  • ReleaseRow
    • ReleaseRow.TABLE
    • ReleaseRow.PARTITION_KEY
    • ReleaseRow.id
    • ReleaseRow.target_type
    • ReleaseRow.target
    • ReleaseRow.date
    • ReleaseRow.name
    • ReleaseRow.message
    • ReleaseRow.author
    • ReleaseRow.synthetic
    • ReleaseRow.raw_manifest
  • SnapshotRow
    • SnapshotRow.TABLE
    • SnapshotRow.PARTITION_KEY
    • SnapshotRow.id
  • SnapshotBranchRow
    • SnapshotBranchRow.TABLE
    • SnapshotBranchRow.PARTITION_KEY
    • SnapshotBranchRow.CLUSTERING_KEY
    • SnapshotBranchRow.snapshot_id
    • SnapshotBranchRow.name
    • SnapshotBranchRow.target_type
    • SnapshotBranchRow.target
  • OriginVisitRow
    • OriginVisitRow.TABLE
    • OriginVisitRow.PARTITION_KEY
    • OriginVisitRow.CLUSTERING_KEY
    • OriginVisitRow.origin
    • OriginVisitRow.visit
    • OriginVisitRow.date
    • OriginVisitRow.type
  • OriginVisitStatusRow
    • OriginVisitStatusRow.TABLE
    • OriginVisitStatusRow.PARTITION_KEY
    • OriginVisitStatusRow.CLUSTERING_KEY
    • OriginVisitStatusRow.origin
    • OriginVisitStatusRow.visit
    • OriginVisitStatusRow.date
    • OriginVisitStatusRow.type
    • OriginVisitStatusRow.status
    • OriginVisitStatusRow.metadata
    • OriginVisitStatusRow.snapshot
    • OriginVisitStatusRow.from_dict()
  • OriginRow
    • OriginRow.TABLE
    • OriginRow.PARTITION_KEY
    • OriginRow.sha1
    • OriginRow.url
    • OriginRow.next_visit_id
  • MetadataAuthorityRow
    • MetadataAuthorityRow.TABLE
    • MetadataAuthorityRow.PARTITION_KEY
    • MetadataAuthorityRow.CLUSTERING_KEY
    • MetadataAuthorityRow.url
    • MetadataAuthorityRow.type
  • MetadataFetcherRow
    • MetadataFetcherRow.TABLE
    • MetadataFetcherRow.PARTITION_KEY
    • MetadataFetcherRow.CLUSTERING_KEY
    • MetadataFetcherRow.name
    • MetadataFetcherRow.version
  • RawExtrinsicMetadataRow
    • RawExtrinsicMetadataRow.TABLE
    • RawExtrinsicMetadataRow.PARTITION_KEY
    • RawExtrinsicMetadataRow.CLUSTERING_KEY
    • RawExtrinsicMetadataRow.id
    • RawExtrinsicMetadataRow.type
    • RawExtrinsicMetadataRow.target
    • RawExtrinsicMetadataRow.authority_type
    • RawExtrinsicMetadataRow.authority_url
    • RawExtrinsicMetadataRow.discovery_date
    • RawExtrinsicMetadataRow.fetcher_name
    • RawExtrinsicMetadataRow.fetcher_version
    • RawExtrinsicMetadataRow.format
    • RawExtrinsicMetadataRow.metadata
    • RawExtrinsicMetadataRow.origin
    • RawExtrinsicMetadataRow.visit
    • RawExtrinsicMetadataRow.snapshot
    • RawExtrinsicMetadataRow.release
    • RawExtrinsicMetadataRow.revision
    • RawExtrinsicMetadataRow.path
    • RawExtrinsicMetadataRow.directory
  • RawExtrinsicMetadataByIdRow
    • RawExtrinsicMetadataByIdRow.TABLE
    • RawExtrinsicMetadataByIdRow.PARTITION_KEY
    • RawExtrinsicMetadataByIdRow.CLUSTERING_KEY
    • RawExtrinsicMetadataByIdRow.id
    • RawExtrinsicMetadataByIdRow.target
    • RawExtrinsicMetadataByIdRow.authority_type
    • RawExtrinsicMetadataByIdRow.authority_url
  • ObjectCountRow
    • ObjectCountRow.TABLE
    • ObjectCountRow.PARTITION_KEY
    • ObjectCountRow.CLUSTERING_KEY
    • ObjectCountRow.partition_key
    • ObjectCountRow.object_type
    • ObjectCountRow.count
  • ExtIDRow
    • ExtIDRow.TABLE
    • ExtIDRow.PARTITION_KEY
    • ExtIDRow.CLUSTERING_KEY
    • ExtIDRow.extid_type
    • ExtIDRow.extid
    • ExtIDRow.extid_version
    • ExtIDRow.target_type
    • ExtIDRow.target
  • ExtIDByTargetRow
    • ExtIDByTargetRow.TABLE
    • ExtIDByTargetRow.PARTITION_KEY
    • ExtIDByTargetRow.CLUSTERING_KEY
    • ExtIDByTargetRow.target_type
    • ExtIDByTargetRow.target
    • ExtIDByTargetRow.target_token
  • ObjectReferenceRow
    • ObjectReferenceRow.TABLE
    • ObjectReferenceRow.PARTITION_KEY
    • ObjectReferenceRow.CLUSTERING_KEY
    • ObjectReferenceRow.target_type
    • ObjectReferenceRow.target
    • ObjectReferenceRow.source_type
    • ObjectReferenceRow.source
  • ObjectReferencesTableRow
    • ObjectReferencesTableRow.TABLE
    • ObjectReferencesTableRow.PARTITION_KEY
    • ObjectReferencesTableRow.CLUSTERING_KEY
    • ObjectReferencesTableRow.pk
    • ObjectReferencesTableRow.name
    • ObjectReferencesTableRow.year
    • ObjectReferencesTableRow.week
    • ObjectReferencesTableRow.start
    • ObjectReferencesTableRow.end
• swh.storage.cassandra.schema module
• swh.storage.cassandra.storage module

Module contents