Skip to content

Add mock adapter crate with live system demo #2486

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 21 commits into from
Apr 28, 2025
Merged

Conversation

twitu
Copy link
Collaborator

@twitu twitu commented Mar 31, 2025

Pull Request

Mock live system demo shows an actor communicating with a websocket and http server to receive two streams of data. It uses nautilus components like DataClient, DataClientAdapter and DataEngine and LiveRunner to demonstrate a realistic PoC for a live system.

Type of change

  • Demonstration + test

How has this change been tested?

Runs with expected logs using cargo run --bin network_stream -p nautilus-demo --features python

Received positive value: 3
Received subscribe command
Received negative value: -9
Received get data request
Error sending log event (receiver closed): [DEBUG] hyper_util::client::legacy::pool: reuse idle connection for ("http", 127.0.0.1:40523)
Error sending log event (receiver closed): [DEBUG] hyper_util::client::legacy::pool: pooling idle connection for ("http", 127.0.0.1:40523)
Received positive value: 8
Received custom data response: CustomDataResponse { correlation_id: UUID4('01f1f6bc-e23c-46ac-b8ce-c9a466bad0dc'), client_id: u!("mock_data_client"), venue: u!("http positive stream"), data_type: DataType(type_name=positive_stream, metadata=None), data: Any { .. }, ts_init: UnixNanos(0), params: None }
Received positive value: 8
Received negative value: -10
Received get data request
Error sending log event (receiver closed): [DEBUG] hyper_util::client::legacy::pool: reuse idle connection for ("http", 127.0.0.1:40523)
Error sending log event (receiver closed): [DEBUG] hyper_util::client::legacy::pool: pooling idle connection for ("http", 127.0.0.1:40523)
Received positive value: 9
Received custom data response: CustomDataResponse { correlation_id: UUID4('6a81c56a-5c98-46e8-a834-f49868663137'), client_id: u!("mock_data_client"), venue: u!("http positive stream"), data_type: DataType(type_name=positive_stream, metadata=None), data: Any { .. }, ts_init: UnixNanos(0), params: None }
Received positive value: 9
Received unsubscribe command

@twitu twitu marked this pull request as draft April 15, 2025 10:41
@twitu twitu marked this pull request as ready for review April 27, 2025 22:09
@twitu twitu changed the title Add simplified live system demo Live system demo with mock adaptor Apr 27, 2025
@twitu twitu force-pushed the live-system-demo branch from 79b6cc8 to d333698 Compare April 27, 2025 22:44
@cjdsellers cjdsellers changed the title Live system demo with mock adaptor Add live system demo with mock adapter crate Apr 28, 2025
@cjdsellers cjdsellers merged commit f8313c5 into develop Apr 28, 2025
17 checks passed
@cjdsellers cjdsellers deleted the live-system-demo branch April 28, 2025 21:42
@cjdsellers cjdsellers changed the title Add live system demo with mock adapter crate Add mock adapter crate with live system demo Apr 28, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants