.copier-answers.yml
.gitignore
.pre-commit-config.yaml
.python-version
CODE_OF_CONDUCT.md
CONTRIBUTING.md
LICENSE
MANIFEST.in
README.md
docker-compose-beamlime.yml
pyproject.toml
tox.ini
.github/dependabot.yml
.github/workflows/ci.yml
.github/workflows/docs.yml
.github/workflows/nightly_at_main.yml
.github/workflows/nightly_at_release.yml
.github/workflows/plugin.yml
.github/workflows/python-version-ci
.github/workflows/release.yml
.github/workflows/test.yml
.github/workflows/unpinned.yml
.github/workflows/weekly_windows_macos.yml
conda/meta.yaml
docs/conf.py
docs/index.md
docs/_static/anaconda-icon.js
docs/_static/favicon.svg
docs/_static/logo-dark.svg
docs/_static/logo.svg
docs/_templates/class-template.rst
docs/_templates/doc_version.html
docs/_templates/module-template.rst
docs/about/calculations.py
docs/about/data.py
docs/about/environments.py
docs/about/ess-instruments.ipynb
docs/about/ess_requirements.py
docs/about/index.md
docs/about/loader.py
docs/about/runner.py
docs/about/visualize.py
docs/api-reference/index.md
docs/developer/coding-conventions.md
docs/developer/dependency-management.md
docs/developer/getting-started.md
docs/developer/index.md
docs/environments/index.md
docs/environments/kafka.md
docs/environments/conda/dev-env.yaml
docs/environments/conda/test-env.yaml
docs/resources/diagram.py
docs/resources/draw_logo.py
docs/user-guide/adding-new-instruments.md
docs/user-guide/getting-started.ipynb
docs/user-guide/index.md
docs/user-guide/services.md
requirements/base.in
requirements/base.txt
requirements/basetest.in
requirements/basetest.txt
requirements/ci.in
requirements/ci.txt
requirements/dev.in
requirements/dev.txt
requirements/docs.in
requirements/docs.txt
requirements/make_base.py
requirements/mypy.in
requirements/mypy.txt
requirements/nightly.in
requirements/nightly.txt
requirements/plugin.in
requirements/plugin.txt
requirements/static.in
requirements/static.txt
requirements/stream.in
requirements/stream.txt
requirements/test.in
requirements/test.txt
requirements/wheels.in
requirements/wheels.txt
resources/draw_icon.py
resources/draw_logo.py
scripts/setup-kafka-topics.sh
src/beamlime/__init__.py
src/beamlime/_nexus_helpers.py
src/beamlime/_random_data_providers.py
src/beamlime/fakes.py
src/beamlime/py.typed
src/beamlime/service_factory.py
src/beamlime/sinks.py
src/beamlime/workflow_protocols.py
src/beamlime.egg-info/PKG-INFO
src/beamlime.egg-info/SOURCES.txt
src/beamlime.egg-info/dependency_links.txt
src/beamlime.egg-info/entry_points.txt
src/beamlime.egg-info/requires.txt
src/beamlime.egg-info/top_level.txt
src/beamlime/config/config_loader.py
src/beamlime/config/config_names.py
src/beamlime/config/models.py
src/beamlime/config/defaults/control_consumer.yaml
src/beamlime/config/defaults/data_reduction.yaml
src/beamlime/config/defaults/detector_data.yaml
src/beamlime/config/defaults/kafka_downstream_dev.yaml
src/beamlime/config/defaults/kafka_downstream_docker.yaml.jinja
src/beamlime/config/defaults/kafka_upstream_dev.yaml
src/beamlime/config/defaults/kafka_upstream_docker.yaml.jinja
src/beamlime/config/defaults/monitor_data.yaml
src/beamlime/config/defaults/raw_data_consumer.yaml
src/beamlime/config/defaults/reduced_data_consumer.yaml
src/beamlime/config/defaults/visualization.yaml
src/beamlime/config/raw_detectors/__init__.py
src/beamlime/config/raw_detectors/bifrost.py
src/beamlime/config/raw_detectors/dream.py
src/beamlime/config/raw_detectors/dummy.py
src/beamlime/config/raw_detectors/loki.py
src/beamlime/config/raw_detectors/nmx.py
src/beamlime/core/__init__.py
src/beamlime/core/config_service.py
src/beamlime/core/config_subscriber.py
src/beamlime/core/handler.py
src/beamlime/core/message.py
src/beamlime/core/processor.py
src/beamlime/core/service.py
src/beamlime/handlers/__init__.py
src/beamlime/handlers/accumulators.py
src/beamlime/handlers/data_reduction_handler.py
src/beamlime/handlers/detector_data_handler.py
src/beamlime/handlers/monitor_data_handler.py
src/beamlime/kafka/__init__.py
src/beamlime/kafka/consumer.py
src/beamlime/kafka/helpers.py
src/beamlime/kafka/message_adapter.py
src/beamlime/kafka/scipp_da00_compat.py
src/beamlime/kafka/sink.py
src/beamlime/kafka/source.py
src/beamlime/services/dashboard.py
src/beamlime/services/data_reduction.py
src/beamlime/services/detector_data.py
src/beamlime/services/fake_detectors.py
src/beamlime/services/fake_monitors.py
src/beamlime/services/local_demo_da00.py
src/beamlime/services/local_demo_ev44.py
src/beamlime/services/monitor_data.py
src/beamlime/services/plot_da00_to_png.py
src/beamlime/services/wsgi.py
tests/bifrost_test.py
tests/conftest.py
tests/message_test.py
tests/package_test.py
tests/processor_test.py
tests/service_test.py
tests/config/config_loader_test.py
tests/config/models_test.py
tests/handlers/accumulators_test.py
tests/handlers/detector_data_handler_test.py
tests/handlers/monitor_data_handler_test.py
tests/kafka/message_adapter_test.py
tests/kafka/scipp_da00_compat_test.py
tests/kafka/source_test.py
tests/services/data_service_test.py
tests/services/detector_data_test.py
tests/services/monitor_data_test.py