LICENSE
LICENSE.txt
MANIFEST.in
README.md
pyproject.toml
setup.py
stub_generation.py
typecheck.ini
src/matrice_streaming/__init__.py
src/matrice_streaming/__init__.pyi
src/matrice_streaming/_mp_patch.py
src/matrice_streaming/_mp_patch.pyi
src/matrice_streaming/local_decoder.py
src/matrice_streaming/local_decoder.pyi
src/matrice_streaming/py.typed
src/matrice_streaming/secure_cache.py
src/matrice_streaming/secure_cache.pyi
src/matrice_streaming/stream_credentials.py
src/matrice_streaming/stream_credentials.pyi
src/matrice_streaming/url_redact.py
src/matrice_streaming/url_redact.pyi
src/matrice_streaming.egg-info/PKG-INFO
src/matrice_streaming.egg-info/SOURCES.txt
src/matrice_streaming.egg-info/dependency_links.txt
src/matrice_streaming.egg-info/not-zip-safe
src/matrice_streaming.egg-info/requires.txt
src/matrice_streaming.egg-info/top_level.txt
src/matrice_streaming/contracts/__init__.py
src/matrice_streaming/contracts/__init__.pyi
src/matrice_streaming/contracts/async_messages.py
src/matrice_streaming/contracts/async_messages.pyi
src/matrice_streaming/contracts/heartbeat_dataclass_builder.py
src/matrice_streaming/contracts/heartbeat_dataclass_builder.pyi
src/matrice_streaming/contracts/message_format.py
src/matrice_streaming/contracts/message_format.pyi
src/matrice_streaming/contracts/metrics_dataclass_builder.py
src/matrice_streaming/contracts/metrics_dataclass_builder.pyi
src/matrice_streaming/databus/__init__.py
src/matrice_streaming/databus/__init__.pyi
src/matrice_streaming/databus/_cuda_attach.py
src/matrice_streaming/databus/_cuda_attach.pyi
src/matrice_streaming/databus/_cuda_commit.py
src/matrice_streaming/databus/_cuda_commit.pyi
src/matrice_streaming/databus/_cuda_common.py
src/matrice_streaming/databus/_cuda_common.pyi
src/matrice_streaming/databus/_cuda_consumers.py
src/matrice_streaming/databus/_cuda_consumers.pyi
src/matrice_streaming/databus/_cuda_frame_counter.py
src/matrice_streaming/databus/_cuda_frame_counter.pyi
src/matrice_streaming/databus/_cuda_introspect.py
src/matrice_streaming/databus/_cuda_introspect.pyi
src/matrice_streaming/databus/_cuda_io.py
src/matrice_streaming/databus/_cuda_io.pyi
src/matrice_streaming/databus/_cuda_ipc.py
src/matrice_streaming/databus/_cuda_ipc.pyi
src/matrice_streaming/databus/_cuda_slots.py
src/matrice_streaming/databus/_cuda_slots.pyi
src/matrice_streaming/databus/_databus_common.py
src/matrice_streaming/databus/_databus_common.pyi
src/matrice_streaming/databus/_databus_consumer.py
src/matrice_streaming/databus/_databus_consumer.pyi
src/matrice_streaming/databus/_databus_consumer_attach.py
src/matrice_streaming/databus/_databus_consumer_attach.pyi
src/matrice_streaming/databus/_databus_consumer_recv.py
src/matrice_streaming/databus/_databus_consumer_recv.pyi
src/matrice_streaming/databus/_databus_producer.py
src/matrice_streaming/databus/_databus_producer.pyi
src/matrice_streaming/databus/_matrice_stream_messaging.py
src/matrice_streaming/databus/_matrice_stream_messaging.pyi
src/matrice_streaming/databus/_matrice_stream_metrics.py
src/matrice_streaming/databus/_matrice_stream_metrics.pyi
src/matrice_streaming/databus/_matrice_stream_types.py
src/matrice_streaming/databus/_matrice_stream_types.pyi
src/matrice_streaming/databus/_redis_async_batch.py
src/matrice_streaming/databus/_redis_async_batch.pyi
src/matrice_streaming/databus/_redis_async_codec.py
src/matrice_streaming/databus/_redis_async_codec.pyi
src/matrice_streaming/databus/_redis_async_consume.py
src/matrice_streaming/databus/_redis_async_consume.pyi
src/matrice_streaming/databus/_redis_async_metrics.py
src/matrice_streaming/databus/_redis_async_metrics.pyi
src/matrice_streaming/databus/_redis_async_produce.py
src/matrice_streaming/databus/_redis_async_produce.pyi
src/matrice_streaming/databus/_redis_async_setup.py
src/matrice_streaming/databus/_redis_async_setup.pyi
src/matrice_streaming/databus/_redis_async_shm.py
src/matrice_streaming/databus/_redis_async_shm.pyi
src/matrice_streaming/databus/_redis_async_subscribe.py
src/matrice_streaming/databus/_redis_async_subscribe.pyi
src/matrice_streaming/databus/_redis_common.py
src/matrice_streaming/databus/_redis_common.pyi
src/matrice_streaming/databus/_redis_deployment.py
src/matrice_streaming/databus/_redis_deployment.pyi
src/matrice_streaming/databus/_redis_deployment_metrics.py
src/matrice_streaming/databus/_redis_deployment_metrics.pyi
src/matrice_streaming/databus/_redis_shutdown.py
src/matrice_streaming/databus/_redis_shutdown.pyi
src/matrice_streaming/databus/_redis_sync_batch.py
src/matrice_streaming/databus/_redis_sync_batch.pyi
src/matrice_streaming/databus/_redis_sync_codec.py
src/matrice_streaming/databus/_redis_sync_codec.pyi
src/matrice_streaming/databus/_redis_sync_consume.py
src/matrice_streaming/databus/_redis_sync_consume.pyi
src/matrice_streaming/databus/_redis_sync_metrics.py
src/matrice_streaming/databus/_redis_sync_metrics.pyi
src/matrice_streaming/databus/_redis_sync_produce.py
src/matrice_streaming/databus/_redis_sync_produce.pyi
src/matrice_streaming/databus/_redis_sync_setup.py
src/matrice_streaming/databus/_redis_sync_setup.pyi
src/matrice_streaming/databus/_shm_common.py
src/matrice_streaming/databus/_shm_common.pyi
src/matrice_streaming/databus/_shm_consumers.py
src/matrice_streaming/databus/_shm_consumers.pyi
src/matrice_streaming/databus/_shm_geometry.py
src/matrice_streaming/databus/_shm_geometry.pyi
src/matrice_streaming/databus/_shm_introspect.py
src/matrice_streaming/databus/_shm_introspect.pyi
src/matrice_streaming/databus/_shm_io.py
src/matrice_streaming/databus/_shm_io.pyi
src/matrice_streaming/databus/_shm_lifecycle.py
src/matrice_streaming/databus/_shm_lifecycle.pyi
src/matrice_streaming/databus/_shm_path.py
src/matrice_streaming/databus/_shm_path.pyi
src/matrice_streaming/databus/_shm_slots.py
src/matrice_streaming/databus/_shm_slots.pyi
src/matrice_streaming/databus/app_warning.py
src/matrice_streaming/databus/app_warning.pyi
src/matrice_streaming/databus/autoshm.py
src/matrice_streaming/databus/autoshm.pyi
src/matrice_streaming/databus/cuda_shm_ring_buffer.py
src/matrice_streaming/databus/cuda_shm_ring_buffer.pyi
src/matrice_streaming/databus/databus.py
src/matrice_streaming/databus/databus.pyi
src/matrice_streaming/databus/databus_batch_consumer.py
src/matrice_streaming/databus/databus_batch_consumer.pyi
src/matrice_streaming/databus/databus_status.py
src/matrice_streaming/databus/databus_status.pyi
src/matrice_streaming/databus/device_topology.py
src/matrice_streaming/databus/device_topology.pyi
src/matrice_streaming/databus/gpu_camera_map.py
src/matrice_streaming/databus/gpu_camera_map.pyi
src/matrice_streaming/databus/gpu_placement_registry.py
src/matrice_streaming/databus/gpu_placement_registry.pyi
src/matrice_streaming/databus/matrice_stream.py
src/matrice_streaming/databus/matrice_stream.pyi
src/matrice_streaming/databus/redis_stream.py
src/matrice_streaming/databus/redis_stream.pyi
src/matrice_streaming/databus/shm_ring_buffer.py
src/matrice_streaming/databus/shm_ring_buffer.pyi
src/matrice_streaming/databus/zmq_databus.py
src/matrice_streaming/databus/zmq_databus.pyi
src/matrice_streaming/databus/zmq_databus_consumer.py
src/matrice_streaming/databus/zmq_databus_consumer.pyi
src/matrice_streaming/databus/zmq_databus_shared.py
src/matrice_streaming/databus/zmq_databus_shared.pyi
src/matrice_streaming/databus/zmq_handover.py
src/matrice_streaming/databus/zmq_handover.pyi
src/matrice_streaming/databus/zmq_local_bridge.py
src/matrice_streaming/databus/zmq_local_bridge.pyi
src/matrice_streaming/streaming_gateway/__init__.py
src/matrice_streaming/streaming_gateway/__init__.pyi
src/matrice_streaming/streaming_gateway/constants.py
src/matrice_streaming/streaming_gateway/constants.pyi
src/matrice_streaming/streaming_gateway/dynamic_camera_manager.py
src/matrice_streaming/streaming_gateway/dynamic_camera_manager.pyi
src/matrice_streaming/streaming_gateway/gateway_builder.py
src/matrice_streaming/streaming_gateway/gateway_builder.pyi
src/matrice_streaming/streaming_gateway/health_monitor.py
src/matrice_streaming/streaming_gateway/health_monitor.pyi
src/matrice_streaming/streaming_gateway/instance_event_listener.py
src/matrice_streaming/streaming_gateway/instance_event_listener.pyi
src/matrice_streaming/streaming_gateway/metrics_reporter.py
src/matrice_streaming/streaming_gateway/metrics_reporter.pyi
src/matrice_streaming/streaming_gateway/percentiles.py
src/matrice_streaming/streaming_gateway/percentiles.pyi
src/matrice_streaming/streaming_gateway/streaming_action.py
src/matrice_streaming/streaming_gateway/streaming_action.pyi
src/matrice_streaming/streaming_gateway/streaming_gateway.py
src/matrice_streaming/streaming_gateway/streaming_gateway.pyi
src/matrice_streaming/streaming_gateway/streaming_gateway_utils.py
src/matrice_streaming/streaming_gateway/streaming_gateway_utils.pyi
src/matrice_streaming/streaming_gateway/streaming_status_listener.py
src/matrice_streaming/streaming_gateway/streaming_status_listener.pyi
src/matrice_streaming/streaming_gateway/tampering_audit_client.py
src/matrice_streaming/streaming_gateway/tampering_audit_client.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/__init__.py
src/matrice_streaming/streaming_gateway/camera_streamer/__init__.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/backend.py
src/matrice_streaming/streaming_gateway/camera_streamer/backend.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/camera_tampering_detector.py
src/matrice_streaming/streaming_gateway/camera_streamer/camera_tampering_detector.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/codec_detect.py
src/matrice_streaming/streaming_gateway/camera_streamer/codec_detect.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/databus_backpressure.py
src/matrice_streaming/streaming_gateway/camera_streamer/databus_backpressure.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/frame_optimizer.py
src/matrice_streaming/streaming_gateway/camera_streamer/frame_optimizer.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/frame_pool.py
src/matrice_streaming/streaming_gateway/camera_streamer/frame_pool.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/hotadd_policy.py
src/matrice_streaming/streaming_gateway/camera_streamer/hotadd_policy.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/memory_admission.py
src/matrice_streaming/streaming_gateway/camera_streamer/memory_admission.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/restart_supervisor.py
src/matrice_streaming/streaming_gateway/camera_streamer/restart_supervisor.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/rtp_correlation.py
src/matrice_streaming/streaming_gateway/camera_streamer/rtp_correlation.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/shm_liveness.py
src/matrice_streaming/streaming_gateway/camera_streamer/shm_liveness.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/__init__.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/__init__.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/config.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/config.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/frame_rate.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/frame_rate.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/gstreamer_rtp_demuxer.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/gstreamer_rtp_demuxer.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/gstreamer_subprocess_demuxer.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/gstreamer_subprocess_demuxer.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/nvdec.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/nvdec.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/nvdec_worker_manager.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/nvdec_worker_manager.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/orin_nvdec.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/orin_nvdec.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/sink.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/sink.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/timestamps.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/timestamps.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/video_source.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/video_source.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/demuxers/__init__.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/demuxers/__init__.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/demuxers/base.py
src/matrice_streaming/streaming_gateway/camera_streamer/nvdec/demuxers/base.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/__init__.py
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/__init__.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/async_camera_worker.py
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/async_camera_worker.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/frame_processor.py
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/frame_processor.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/video_capture_manager.py
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/video_capture_manager.pyi
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/worker_manager.py
src/matrice_streaming/streaming_gateway/camera_streamer/opencv/worker_manager.pyi
src/matrice_streaming/streaming_gateway/events/__init__.py
src/matrice_streaming/streaming_gateway/events/__init__.pyi
src/matrice_streaming/streaming_gateway/events/instance_listener.py
src/matrice_streaming/streaming_gateway/events/instance_listener.pyi
src/matrice_streaming/streaming_gateway/events/status_listener.py
src/matrice_streaming/streaming_gateway/events/status_listener.pyi
src/matrice_streaming/streaming_gateway/metrics/__init__.py
src/matrice_streaming/streaming_gateway/metrics/__init__.pyi
src/matrice_streaming/streaming_gateway/metrics/_kafka_sink.py
src/matrice_streaming/streaming_gateway/metrics/_kafka_sink.pyi
src/matrice_streaming/streaming_gateway/metrics/calculator.py
src/matrice_streaming/streaming_gateway/metrics/calculator.pyi
src/matrice_streaming/streaming_gateway/metrics/collector.py
src/matrice_streaming/streaming_gateway/metrics/collector.pyi
src/matrice_streaming/streaming_gateway/metrics/config.py
src/matrice_streaming/streaming_gateway/metrics/config.pyi
src/matrice_streaming/streaming_gateway/metrics/heartbeat.py
src/matrice_streaming/streaming_gateway/metrics/heartbeat.pyi
src/matrice_streaming/streaming_gateway/metrics/manager.py
src/matrice_streaming/streaming_gateway/metrics/manager.pyi
src/matrice_streaming/streaming_gateway/metrics/models.py
src/matrice_streaming/streaming_gateway/metrics/models.pyi
src/matrice_streaming/streaming_gateway/metrics/reporter.py
src/matrice_streaming/streaming_gateway/metrics/reporter.pyi
src/matrice_streaming/support/__init__.py
src/matrice_streaming/support/__init__.pyi
src/matrice_streaming/support/circuit_breaker.py
src/matrice_streaming/support/circuit_breaker.pyi
src/matrice_streaming/support/config.py
src/matrice_streaming/support/config.pyi
src/matrice_streaming/support/jitter.py
src/matrice_streaming/support/jitter.pyi
src/matrice_streaming/support/kafka_security.py
src/matrice_streaming/support/kafka_security.pyi
src/matrice_streaming/support/outage.py
src/matrice_streaming/support/outage.pyi