LICENSE
MANIFEST.in
README.md
pyproject.toml
examples/discovery/mcast_discovery.py
examples/discovery/zconf_discovery.py
examples/mcp/mqtt_mcp_client.py
examples/mcp/mqtt_mcp_server.py
examples/mcp/webrtc_mcp_client.py
examples/mcp/webrtc_mcp_server.py
examples/mcp/zmq_mcp_client.py
examples/mcp/zmq_mcp_server.py
examples/mqtt/mqtt_reader.py
examples/mqtt/mqtt_requester.py
examples/mqtt/mqtt_responder.py
examples/mqtt/mqtt_writer.py
examples/nodes/base_node.py
examples/nodes/pub_sub_node.py
examples/nodes/zmq_server_node.py
examples/nodes/zmq_sink_node.py
examples/nodes/zmq_source_node.py
examples/nodes/zmq_source_sink_node.py
examples/schema/zmq_schema_requester.py
examples/schema/zmq_schema_responder.py
examples/webrtc/webrtc_audio_reader.py
examples/webrtc/webrtc_audio_writer.py
examples/webrtc/webrtc_multi_media.py
examples/webrtc/webrtc_reader.py
examples/webrtc/webrtc_rpc_requester.py
examples/webrtc/webrtc_rpc_responder.py
examples/webrtc/webrtc_video_reader.py
examples/webrtc/webrtc_video_writer.py
examples/webrtc/webrtc_writer.py
examples/zmq/zmq_multi_requester.py
examples/zmq/zmq_reader.py
examples/zmq/zmq_requester.py
examples/zmq/zmq_responder.py
examples/zmq/zmq_writer.py
src/luxai/magpie/__init__.py
src/luxai/magpie/adapters/__init__.py
src/luxai/magpie/adapters/mcp/__init__.py
src/luxai/magpie/adapters/mcp/transport.py
src/luxai/magpie/assets/magpie.png
src/luxai/magpie/discovery/__init__.py
src/luxai/magpie/discovery/mcast_discovery.py
src/luxai/magpie/discovery/zconf_discovery.py
src/luxai/magpie/frames/__init__.py
src/luxai/magpie/frames/audio.py
src/luxai/magpie/frames/frame.py
src/luxai/magpie/frames/image.py
src/luxai/magpie/frames/primitive.py
src/luxai/magpie/nodes/__init__.py
src/luxai/magpie/nodes/base_node.py
src/luxai/magpie/nodes/process_node.py
src/luxai/magpie/nodes/server_node.py
src/luxai/magpie/nodes/sink_node.py
src/luxai/magpie/nodes/source_node.py
src/luxai/magpie/schema/__init__.py
src/luxai/magpie/schema/base_schema.py
src/luxai/magpie/schema/json_rpc_schema.py
src/luxai/magpie/schema/mcp_schema.py
src/luxai/magpie/serializer/__init__.py
src/luxai/magpie/serializer/base_serializer.py
src/luxai/magpie/serializer/msgpack_serializer.py
src/luxai/magpie/tools/__init__.py
src/luxai/magpie/tools/_mqtt_tools_common.py
src/luxai/magpie/tools/_webrtc_tools_common.py
src/luxai/magpie/tools/mqtt_read.py
src/luxai/magpie/tools/mqtt_request.py
src/luxai/magpie/tools/mqtt_write.py
src/luxai/magpie/tools/webrtc_audio_capture.py
src/luxai/magpie/tools/webrtc_audio_player.py
src/luxai/magpie/tools/webrtc_read.py
src/luxai/magpie/tools/webrtc_request.py
src/luxai/magpie/tools/webrtc_video_capture.py
src/luxai/magpie/tools/webrtc_video_viewer.py
src/luxai/magpie/tools/webrtc_write.py
src/luxai/magpie/tools/zconf_discovery.py
src/luxai/magpie/tools/zmq_audio_capture.py
src/luxai/magpie/tools/zmq_audio_player.py
src/luxai/magpie/tools/zmq_read.py
src/luxai/magpie/tools/zmq_request.py
src/luxai/magpie/tools/zmq_video_capture.py
src/luxai/magpie/tools/zmq_video_viewer.py
src/luxai/magpie/tools/zmq_write.py
src/luxai/magpie/transport/__init__.py
src/luxai/magpie/transport/rpc_requester.py
src/luxai/magpie/transport/rpc_responder.py
src/luxai/magpie/transport/stream_reader.py
src/luxai/magpie/transport/stream_writer.py
src/luxai/magpie/transport/local/__init__.py
src/luxai/magpie/transport/local/memory_pushpull.py
src/luxai/magpie/transport/mqtt/__init__.py
src/luxai/magpie/transport/mqtt/mqtt_connection.py
src/luxai/magpie/transport/mqtt/mqtt_options.py
src/luxai/magpie/transport/mqtt/mqtt_rpc_requester.py
src/luxai/magpie/transport/mqtt/mqtt_rpc_responder.py
src/luxai/magpie/transport/mqtt/mqtt_stream_reader.py
src/luxai/magpie/transport/mqtt/mqtt_stream_writer.py
src/luxai/magpie/transport/webrtc/__init__.py
src/luxai/magpie/transport/webrtc/webrtc_connection.py
src/luxai/magpie/transport/webrtc/webrtc_options.py
src/luxai/magpie/transport/webrtc/webrtc_rpc_requester.py
src/luxai/magpie/transport/webrtc/webrtc_rpc_responder.py
src/luxai/magpie/transport/webrtc/webrtc_signaler.py
src/luxai/magpie/transport/webrtc/webrtc_stream_reader.py
src/luxai/magpie/transport/webrtc/webrtc_stream_writer.py
src/luxai/magpie/transport/zmq/__init__.py
src/luxai/magpie/transport/zmq/zmq_rpc_requester.py
src/luxai/magpie/transport/zmq/zmq_rpc_responder.py
src/luxai/magpie/transport/zmq/zmq_stream_reader.py
src/luxai/magpie/transport/zmq/zmq_stream_writer.py
src/luxai/magpie/transport/zmq/zmq_utils.py
src/luxai/magpie/utils/__init__.py
src/luxai/magpie/utils/common.py
src/luxai/magpie/utils/logger.py
src/luxai_magpie.egg-info/PKG-INFO
src/luxai_magpie.egg-info/SOURCES.txt
src/luxai_magpie.egg-info/dependency_links.txt
src/luxai_magpie.egg-info/entry_points.txt
src/luxai_magpie.egg-info/requires.txt
src/luxai_magpie.egg-info/top_level.txt
tests/test_audio_frames.py
tests/test_base_node.py
tests/test_frame.py
tests/test_image_frames.py
tests/test_mcast_discovery.py
tests/test_mqtt_transport.py
tests/test_primitive_frames.py
tests/test_process_node.py
tests/test_rpc.py
tests/test_schema.py
tests/test_server_node.py
tests/test_sink_source_nodes.py
tests/test_zmq_pubsub.py
tests/test_zmq_rpc.py