README.md
pyproject.toml
src/midstream/__init__.py
src/midstream/config.py
src/midstream/protocol_logging.py
src/midstream/scale.py
src/midstream/table_names.py
src/midstream/version.py
src/midstream/handlers/__init__.py
src/midstream/handlers/identity.py
src/midstream/handlers/maintenance.py
src/midstream/handlers/request_intake.py
src/midstream/handlers/resource_observation.py
src/midstream/handlers/runtime_status.py
src/midstream/handlers/settings.py
src/midstream/handlers/table_events.py
src/midstream/handlers/workflow_apply.py
src/midstream/identity/__init__.py
src/midstream/identity/access_tokens.py
src/midstream/identity/authorization.py
src/midstream/identity/directory.py
src/midstream/identity/passwords.py
src/midstream/identity/permissions.py
src/midstream/identity/principals.py
src/midstream/identity/secrets.py
src/midstream/identity/tokens.py
src/midstream/identity/validation.py
src/midstream/kafka/__init__.py
src/midstream/kafka/admin.py
src/midstream/kafka/metadata.py
src/midstream/kubernetes/__init__.py
src/midstream/kubernetes/client.py
src/midstream/kubernetes/kaspr_apps.py
src/midstream/lakehouse/__init__.py
src/midstream/lakehouse/catalog.py
src/midstream/lakehouse/commits.py
src/midstream/lakehouse/files.py
src/midstream/lakehouse/gcs.py
src/midstream/lakehouse/io.py
src/midstream/lakehouse/lifecycle.py
src/midstream/lakehouse/maintenance.py
src/midstream/lakehouse/offsets.py
src/midstream/lakehouse/parquet.py
src/midstream/lakehouse/pointer.py
src/midstream/lakehouse/rest.py
src/midstream/lakehouse/rows.py
src/midstream/lakehouse/tables.py
src/midstream/lakehouse/schema/__init__.py
src/midstream/lakehouse/schema/conform.py
src/midstream/lakehouse/schema/forkmap.py
src/midstream/lakehouse/schema/index.py
src/midstream/lakehouse/schema/infer.py
src/midstream/lakehouse/schema/policy.py
src/midstream/lakehouse/schema/render.py
src/midstream/maintenance_app/__init__.py
src/midstream/maintenance_app/compact_worker.py
src/midstream/maintenance_app/config.py
src/midstream/maintenance_app/handlers.py
src/midstream/maintenance_app/worker.py
src/midstream/models/__init__.py
src/midstream/models/autoscale.py
src/midstream/models/binding.py
src/midstream/models/envelopes.py
src/midstream/models/events.py
src/midstream/models/identity.py
src/midstream/models/live_tail.py
src/midstream/models/maintenance.py
src/midstream/models/materialization.py
src/midstream/models/offsets.py
src/midstream/models/settings.py
src/midstream/models/status.py
src/midstream/models/table.py
src/midstream/observation/__init__.py
src/midstream/observation/mapping.py
src/midstream/observation/policy.py
src/midstream/observation/progress.py
src/midstream/observation/reader.py
src/midstream/observation/restarts.py
src/midstream/runtime/__init__.py
src/midstream/runtime/bindings.py
src/midstream/runtime/naming.py
src/midstream/runtime/templates.py
src/midstream/runtime_app/__init__.py
src/midstream/runtime_app/acks.py
src/midstream/runtime_app/committer.py
src/midstream/runtime_app/config.py
src/midstream/runtime_app/flow.py
src/midstream/runtime_app/live_settings.py
src/midstream/runtime_app/outbox.py
src/midstream/runtime_app/performance.py
src/midstream/runtime_app/pipeline.py
src/midstream/runtime_app/state.py
src/midstream/runtime_app/table_state.py
src/midstream/runtime_app/handlers/__init__.py
src/midstream/runtime_app/handlers/runtime_settings.py
src/midstream/runtime_app/handlers/status.py
src/midstream/runtime_app/handlers/writer.py
src/midstream/runtime_app/models/__init__.py
src/midstream/runtime_app/models/processing_state.py
src/midstream/runtime_app/schema/__init__.py
src/midstream/runtime_app/schema/drift.py
src/midstream/runtime_app/templates/commit-timer-task.yaml.j2
src/midstream/runtime_app/templates/committer-agent.yaml.j2
src/midstream/runtime_app/templates/kaspr-app.yaml.j2
src/midstream/runtime_app/templates/pipeline-task.yaml.j2
src/midstream/runtime_app/templates/settings-agent.yaml.j2
src/midstream/runtime_app/templates/state-table.yaml.j2
src/midstream/runtime_app/templates/status-task.yaml.j2
src/midstream/runtime_app/templates/writer-agent.yaml.j2
src/midstream/runtime_app/writer/__init__.py
src/midstream/runtime_app/writer/batches.py
src/midstream/runtime_app/writer/context.py
src/midstream/runtime_app/writer/seal.py
src/midstream/runtime_app/writer/seal_worker.py
src/midstream/runtime_app/writer/upload.py
src/midstream/scheduler/__init__.py
src/midstream/schema/__init__.py
src/midstream/schema/discovery.py
src/midstream/services/__init__.py
src/midstream/services/autoscaling.py
src/midstream/services/consumer_lag.py
src/midstream/services/identity.py
src/midstream/services/live_tail.py
src/midstream/services/observation.py
src/midstream/services/request_intake.py
src/midstream/services/retention.py
src/midstream/services/schema_projection.py
src/midstream/services/settings.py
src/midstream/services/sweep_cursor.py
src/midstream/services/table_claims.py
src/midstream/services/table_events.py
src/midstream/services/table_maintenance.py
src/midstream/services/topic_analysis.py
src/midstream/services/topic_catalog.py
src/midstream/services/topic_changes.py
src/midstream/services/workflow.py
src/midstream/settings/__init__.py
src/midstream/settings/catalog.py
src/midstream/settings/effective.py
src/midstream/storage/__init__.py
src/midstream/storage/autoscale.py
src/midstream/storage/bindings.py
src/midstream/storage/envelopes.py
src/midstream/storage/identity.py
src/midstream/storage/keys.py
src/midstream/storage/materializations.py
src/midstream/storage/objects.py
src/midstream/storage/operations.py
src/midstream/storage/resolve.py
src/midstream/storage/schemas.py
src/midstream/storage/settings.py
src/midstream/storage/status.py
src/midstream/storage/table.py
src/midstream/storage/tables.py
src/midstream/tail_app/__init__.py
src/midstream/tail_app/auth.py
src/midstream/tail_app/buffer.py
src/midstream/tail_app/config.py
src/midstream/tail_app/consumer.py
src/midstream/tail_app/control_plane.py
src/midstream/tail_app/events.py
src/midstream/tail_app/handlers.py
src/midstream/tail_app/http.py
src/midstream/tail_app/ingest.py
src/midstream/tail_app/peek.py
src/midstream/tail_app/routing.py
src/midstream/tail_app/serve.py
src/midstream/tail_app/table_tail.py
src/midstream/tail_app/views.py
src/midstream/tail_app/worker.py
src/midstream/utils/__init__.py
src/midstream/utils/background_loop.py
src/midstream/web/__init__.py
src/midstream/web/auth.py
src/midstream/web/catalog.py
src/midstream/web/datasets.py
src/midstream/web/errors.py
src/midstream/web/http.py
src/midstream/web/identity.py
src/midstream/web/materializations.py
src/midstream/web/responses.py
src/midstream/web/settings.py
src/midstream/web/system.py
src/midstream/web/tokens.py
src/midstream/web/topics.py
src/midstream_platform.egg-info/PKG-INFO
src/midstream_platform.egg-info/SOURCES.txt
src/midstream_platform.egg-info/dependency_links.txt
src/midstream_platform.egg-info/requires.txt
src/midstream_platform.egg-info/top_level.txt
tests/test_agent_manifests.py
tests/test_autoscaling.py
tests/test_batched_destination_deletes.py
tests/test_catalog.py
tests/test_config.py
tests/test_datasets.py
tests/test_identity.py
tests/test_kafka_admin.py
tests/test_kubernetes_client.py
tests/test_lakehouse_catalog.py
tests/test_lakehouse_commits.py
tests/test_lakehouse_conform.py
tests/test_lakehouse_maintenance.py
tests/test_lakehouse_schema_policy.py
tests/test_live_tail_scheduler.py
tests/test_maintenance.py
tests/test_maintenance_app.py
tests/test_models.py
tests/test_observation.py
tests/test_package_layout.py
tests/test_request_intake.py
tests/test_row_builder.py
tests/test_runtime_acks.py
tests/test_runtime_committer.py
tests/test_runtime_config.py
tests/test_runtime_flow.py
tests/test_runtime_multi_topic.py
tests/test_runtime_seal.py
tests/test_runtime_settings.py
tests/test_runtime_status.py
tests/test_runtime_templates.py
tests/test_runtime_writer.py
tests/test_scheduler_routing.py
tests/test_schema_discovery.py
tests/test_settings.py
tests/test_storage.py
tests/test_table_events.py
tests/test_table_maintenance.py
tests/test_table_names.py
tests/test_tail_app.py
tests/test_tail_buffer.py
tests/test_tail_exactly_once.py
tests/test_tail_failures.py
tests/test_tail_http.py
tests/test_tail_parity.py
tests/test_tail_routing.py
tests/test_tail_security.py
tests/test_topic_catalog.py
tests/test_topic_changes.py
tests/test_versioning.py
tests/test_web.py
tests/test_workflow.py
tests/test_workflow_topic_changes.py