httk.store.store_common

Backend-neutral save-path machinery shared by storage backends.

Exceptions

EntryMetadataConflictError	Stored identity-excluded metadata differs from a repeated save.
EntryDispatchIntegrityError	A persisted entry dispatch row does not name exactly its expected backing.

Classes

EntryStore	The store surface consumed by httk.store.db.stored_federation.
SaveProjection	One-save projection cache shared by core identity and SQL encoding.
IdentityCaches	Weak identity caches shared by storage backends.

Functions

reject_cursor_proxy(obj)

Reject a lazy cursor row before a backend attempts to save it.

Module Contents

class httk.store.store_common.EntryStore

Bases: Protocol

The store surface consumed by httk.store.db.stored_federation.

This protocol deliberately describes the small backend seam used by the federation. The stored-property plan and candidate-stream objects remain backend-specific; their SQL implementations use searcher().

property entry_layout: tuple[Any, Ellipsis]

Return the configured entry-family layouts in stable order.

searcher()

Return a backend searcher used to build candidate ID streams.

fetch(cls, sid)

Fetch the stored record of cls identified by sid.

stored_property_plan(family)

Return the backend-specific stored-property plan for one family.

Parameters:

family (type) – The logical entry-family class to plan.

Returns:

The validated stored-property plan consumed by federation.

Return type:

Any

exception httk.store.store_common.EntryMetadataConflictError

Bases: ValueError

Stored identity-excluded metadata differs from a repeated save.

exception httk.store.store_common.EntryDispatchIntegrityError

Bases: RuntimeError

A persisted entry dispatch row does not name exactly its expected backing.

class httk.store.store_common.SaveProjection

One-save projection cache shared by core identity and SQL encoding.

values_by_source: dict[tuple[type, int], collections.abc.Mapping[str, object]]

validated: set[tuple[type, int]]

metadata_rows: dict[tuple[type, int], collections.abc.Mapping[str, Any]]

metadata_children: dict[tuple[type, int, str], Any]

metadata_content_ids: dict[tuple[type, int], str]

active: set[tuple[type, int]]

inserted: list[tuple[type, int]] = []

projector(record_type, source)

content_id(record_type, source)

httk.store.store_common.reject_cursor_proxy(obj)

Reject a lazy cursor row before a backend attempts to save it.

class httk.store.store_common.IdentityCaches

Weak identity caches shared by storage backends.