Commit Graph

45 Commits

Author SHA1 Message Date
Timothy Pogue db8cf6c957 disable ping interval in client 2022-10-09 18:51:52 -06:00
Timothy Pogue 71bbffd10a update ws channel send to add data to queue 2022-10-09 18:49:04 -06:00
Timothy Pogue 2c76dd9e39 change wait timeout to 30 seconds to better support reverse proxies 2022-10-09 15:23:56 -06:00
Matthias ac229b7a42 Reduce message consumer verbosity 2022-09-29 07:10:00 +02:00
Matthias 873eb5f2ca Improve EMC config validations 2022-09-24 16:43:58 +02:00
Matthias 50dfde7048 Remove unnecessary typing import 2022-09-24 16:11:15 +02:00
Matthias 53c8e0923f Improve typing in message_consumer 2022-09-24 16:10:42 +02:00
Timothy Pogue 6b5d71049e add sleep 2022-09-23 13:10:45 -06:00
Timothy Pogue 4c7cef570f typo in exception 2022-09-23 12:58:26 -06:00
Timothy Pogue b8e1d29a1b catch connectionclosederror 2022-09-23 12:36:05 -06:00
Matthias e6c5c22ea0 Update websocket/follower docs 2022-09-22 20:31:42 +02:00
Timothy Pogue 77ed713232 add catch for invalid message error 2022-09-21 16:04:25 -06:00
Timothy Pogue 4422ac7f45 constrain port in config, catch value error 2022-09-16 19:22:24 -06:00
Timothy Pogue 7d1645ac20 fix tests and warning message 2022-09-15 17:54:31 -06:00
Timothy Pogue 8e75852ff3 fix constants, update config example, add emc config validation 2022-09-15 11:12:05 -06:00
Timothy Pogue 6126925dbe message size limit in mb, default to 8mb 2022-09-14 16:42:14 -06:00
Timothy Pogue 06350a13cb support specifying message size in emc config 2022-09-13 16:39:53 -06:00
Timothy Pogue d75d5a7dad debug ping error message 2022-09-13 16:06:25 -06:00
Matthias d2abc9417f Simplify ws imports 2022-09-13 20:51:13 +02:00
Timothy Pogue 07aa206f71 real fix for reconnecting 2022-09-13 12:36:40 -06:00
Timothy Pogue 6d0dfd4dc8 continue trying connect on ping error 2022-09-13 12:27:41 -06:00
Timothy Pogue bf2e5dee75 add running false on shutdown, fix dp typing 2022-09-12 14:21:39 -06:00
Timothy Pogue 0697041f14 remove copy statement where not needed 2022-09-12 14:09:12 -06:00
Timothy Pogue c19a5fbe06 copy data being transferred, remove debug messages in emc 2022-09-12 13:57:29 -06:00
Matthias 867d59b930 Improve type specifitivity 2022-09-12 20:00:01 +02:00
Matthias 0052e58917 emc: Fix potential startup timing issue 2022-09-12 19:50:22 +02:00
Timothy Pogue d6205e6cfb test logging lines 2022-09-12 07:36:11 -06:00
Timothy Pogue ed4ba8801f more emc tests 2022-09-10 23:57:17 -06:00
Timothy Pogue 2afd5c202c update message parsing, tests 2022-09-10 14:29:15 -06:00
Timothy Pogue a7baccdb7d update log messages in emc, more tests 2022-09-10 13:44:27 -06:00
Timothy Pogue 866a564958 update emc start/shutdown, initial emc tests 2022-09-10 12:51:29 -06:00
Timothy Pogue 426f8f37e9 change var names 2022-09-09 10:45:49 -06:00
Timothy Pogue 2b9c8550b0 moved ws_schemas, first ws tests 2022-09-08 13:58:28 -06:00
Timothy Pogue fac6626459 update default timeouts 2022-09-08 10:54:31 -06:00
Timothy Pogue 5934495dda add websocket request/message schemas 2022-09-07 15:08:01 -06:00
Timothy Pogue b1c0267449 mypy fixes 2022-09-06 12:40:58 -06:00
Timothy Pogue 3535aa7724 add last_analyzed to emitted dataframe 2022-09-06 12:12:05 -06:00
Timothy Pogue a0d774fdc4 change default initial candle limit to 1500 2022-09-05 20:23:00 -06:00
Timothy Pogue 07f806a314 minor improvements, fixes, old config+constant removal 2022-09-04 10:22:10 -06:00
Timothy Pogue 05cbcf834c minor logging changes 2022-09-02 16:01:33 -06:00
Timothy Pogue cf917ad2f5 initial candle request limit, better error reporting, split up _handle_producer_connection 2022-09-02 15:05:16 -06:00
Timothy Pogue eb4cd6ba82 split initial data into separate requests 2022-09-01 23:52:13 -06:00
Timothy Pogue dccde88c83 fix dataframe serializing 2022-09-01 23:15:03 -06:00
Timothy Pogue 00f35f4870 remove old constant, add initial_data requesting, minor changes 2022-09-01 20:06:36 -06:00
Timothy Pogue 865b34cd6f add producer names 2022-08-31 11:43:02 -06:00