primus.storage package

Submodules

• primus.storage.FileStorageBackend module
  • FileStorageBackend
    • FileStorageBackend.compute_file_path()
    • FileStorageBackend.save_file()
• primus.storage.StorageBackend module
  • StorageBackend
    • StorageBackend.__init__()
    • StorageBackend.compute_file_path()
    • StorageBackend.save_file()
• primus.storage.graphql_artifact_store module
  • ArtifactAuthorizationError
  • ArtifactIntegrityError
  • ArtifactTicketError
  • ArtifactTransferError
  • ArtifactTransferRequest
    • ArtifactTransferRequest.__init__()
    • ArtifactTransferRequest.artifact_type
    • ArtifactTransferRequest.as_graphql_input()
    • ArtifactTransferRequest.content_type
    • ArtifactTransferRequest.filename
    • ArtifactTransferRequest.operation
    • ArtifactTransferRequest.resource_id
    • ArtifactTransferRequest.resource_type
    • ArtifactTransferRequest.sha256
    • ArtifactTransferRequest.size_bytes
  • ArtifactTransferTicket
    • ArtifactTransferTicket.__init__()
    • ArtifactTransferTicket.expires_at
    • ArtifactTransferTicket.from_graphql()
    • ArtifactTransferTicket.is_expired()
    • ArtifactTransferTicket.method
    • ArtifactTransferTicket.object_key
    • ArtifactTransferTicket.required_headers
    • ArtifactTransferTicket.url
  • ArtifactUpload
    • ArtifactUpload.__init__()
    • ArtifactUpload.content
    • ArtifactUpload.existing_metadata
    • ArtifactUpload.request
  • GraphQLArtifactStore
    • GraphQLArtifactStore.__init__()
    • GraphQLArtifactStore.build_metadata()
    • GraphQLArtifactStore.download_batch()
    • GraphQLArtifactStore.download_bytes()
    • GraphQLArtifactStore.request_tickets()
    • GraphQLArtifactStore.upload_batch()
    • GraphQLArtifactStore.upload_bytes()
  • GraphQLArtifactStoreError
  • GraphQLExecutor
    • GraphQLExecutor.__init__()
    • GraphQLExecutor.execute()
  • HTTPSession
    • HTTPSession.__init__()
    • HTTPSession.request()
• primus.storage.test_graphql_artifact_store module
  • FakeCAHTTPSession
    • FakeCAHTTPSession.request()
  • FakeExecutor
    • FakeExecutor.__init__()
    • FakeExecutor.execute()
  • FakeHTTPSession
    • FakeHTTPSession.__init__()
    • FakeHTTPSession.request()
  • FakeResponse
    • FakeResponse.__init__()
  • read_request()
  • test_authorization_failure_does_not_request_a_replacement_ticket()
  • test_configured_local_ca_bundle_is_used_for_https_verification()
  • test_decodes_required_headers_returned_as_graphql_awsjson()
  • test_download_batch_requests_all_tickets_once_and_verifies_each_payload()
  • test_download_checksum_failure_fails_closed_without_retries()
  • test_expired_signed_url_reissues_one_ticket_and_retries_once()
  • test_missing_configured_local_ca_bundle_fails_closed()
  • test_non_retryable_upload_client_status_fails_closed_without_fresh_ticket()
  • test_requests_batched_tickets_with_frozen_contract_fields()
  • test_retryable_download_failure_does_not_request_a_fresh_ticket()
  • test_retryable_upload_request_exception_gets_one_fresh_ticket_for_identical_bytes()
  • test_retryable_upload_status_gets_one_fresh_ticket_for_identical_bytes()
  • test_second_retryable_upload_failure_fails_closed_without_a_third_ticket()
  • test_standard_s3_expiry_message_reissues_one_ticket_and_retries_once()
  • test_ticket_requires_an_https_host()
  • test_upload_batch_requests_all_tickets_once_before_uploading_each_verified_artifact()
  • test_upload_omits_only_a_redundant_unsigned_checksum_header_already_bound_in_the_url()
  • test_upload_preserves_checksum_header_when_query_binding_is_absent_inconsistent_or_signed()
  • test_upload_rejects_mismatched_declared_bytes_before_requesting_ticket()
  • test_upload_transfers_verified_bytes_before_returning_metadata_without_s3()
  • ticket()
  • write_request()