mempalace--mempalace
wehub-resource-sync
c3749daf48
Tests / test-linux (3.13) (push) Failing after 0s
Tests / test-linux (3.11) (push) Failing after 1s
Tests / lint (push) Failing after 0s
Tests / test-linux (3.9) (push) Failing after 1s
Docker / build (push) Failing after 1s
Docker / build-gpu (push) Failing after 2s
Tests / test-windows (push) Has been cancelled
Tests / test-macos (push) Has been cancelled
75 行
1.9 KiB
Python
75 行
1.9 KiB
Python
"""Source adapter subsystem (RFC 002).
|
|
|
|
Public surface:
|
|
|
|
* :class:`BaseSourceAdapter` — per-source read-side contract.
|
|
* Typed records: :class:`SourceRef`, :class:`SourceItemMetadata`,
|
|
:class:`DrawerRecord`, :class:`RouteHint`, :class:`SourceSummary`,
|
|
:class:`AdapterSchema`, :class:`FieldSpec`.
|
|
* Error classes: :class:`SourceNotFoundError`, :class:`AuthRequiredError`,
|
|
:class:`AdapterClosedError`, :class:`TransformationViolationError`,
|
|
:class:`SchemaConformanceError`.
|
|
* Registry: :func:`register`, :func:`get_adapter`, :func:`available_adapters`,
|
|
:func:`resolve_adapter_for_source`.
|
|
* :class:`PalaceContext` — facade core passes to adapters during ``ingest``.
|
|
* :mod:`transforms` — reference implementations of the reserved §1.4
|
|
transformations + :func:`get_transformation` resolver.
|
|
"""
|
|
|
|
from .base import (
|
|
AdapterClosedError,
|
|
AdapterSchema,
|
|
AuthRequiredError,
|
|
BaseSourceAdapter,
|
|
DrawerRecord,
|
|
FieldSpec,
|
|
IngestMode,
|
|
IngestResult,
|
|
RouteHint,
|
|
SchemaConformanceError,
|
|
SourceAdapterError,
|
|
SourceItemMetadata,
|
|
SourceNotFoundError,
|
|
SourceRef,
|
|
SourceSummary,
|
|
TransformationViolationError,
|
|
)
|
|
from .context import PalaceContext, ProgressHook
|
|
from .registry import (
|
|
available_adapters,
|
|
get_adapter,
|
|
get_adapter_class,
|
|
register,
|
|
reset_adapters,
|
|
resolve_adapter_for_source,
|
|
unregister,
|
|
)
|
|
|
|
__all__ = [
|
|
"AdapterClosedError",
|
|
"AdapterSchema",
|
|
"AuthRequiredError",
|
|
"BaseSourceAdapter",
|
|
"DrawerRecord",
|
|
"FieldSpec",
|
|
"IngestMode",
|
|
"IngestResult",
|
|
"PalaceContext",
|
|
"ProgressHook",
|
|
"RouteHint",
|
|
"SchemaConformanceError",
|
|
"SourceAdapterError",
|
|
"SourceItemMetadata",
|
|
"SourceNotFoundError",
|
|
"SourceRef",
|
|
"SourceSummary",
|
|
"TransformationViolationError",
|
|
"available_adapters",
|
|
"get_adapter",
|
|
"get_adapter_class",
|
|
"register",
|
|
"reset_adapters",
|
|
"resolve_adapter_for_source",
|
|
"unregister",
|
|
]
|