Commit Graph

532 Commits

Author SHA1 Message Date
James Wilson f5df1ef68b Merge pull request #356 from arshamparity/helm
Helm
2021-08-02 14:18:33 +01:00
James Wilson 4b00ac79bb Point sahrd to correct port for core 2021-08-02 14:16:20 +01:00
Arsham Teymourı 55537af6f5 extending the helm chart
exposing telemetry core service

adding hpa support for telemetry shard
2021-08-02 12:00:42 +03:00
James Wilson c2892286a6 Add a comment 2021-08-02 09:54:11 +01:00
James Wilson b79759a412 Tidy up close handling and allow either side to close 2021-08-02 09:50:31 +01:00
James Wilson 963ef576f3 add on_close to abstract and simplify ws_client socket closing 2021-08-02 09:30:29 +01:00
James Wilson 13afb96f93 Be more fussy with Soketto channel wrapper; Soketto might do otherwise, but we only explicitly close the connection when both ends of the channel handed out are closed (or we encounter a connection error) 2021-07-30 21:26:52 +01:00
James Wilson 18918e6d3e undo a previous change; close the connection if either side of the channel handed back is dropped/fails 2021-07-30 19:43:26 +01:00
James Wilson a5b04cb4f0 improve socket channel close handling, and test the node banning (roughly) 2021-07-30 18:58:10 +01:00
James Wilson 3f523178be Fix broken test (node being banned) and allow test config of new max-bytes option on shard 2021-07-30 16:55:06 +01:00
James Wilson a368553085 Add note and reduce max data per second default as we expect much less traffic than existing avg 2021-07-30 15:39:30 +01:00
James Wilson 0b1a6f45fa readme tweaks 2021-07-30 12:36:23 +01:00
James Wilson 3fa04f6a81 Update readme to bring into line with new shard/core split 2021-07-30 12:33:34 +01:00
James Wilson b70ab9ed3d Add license to the top of each source file 2021-07-29 17:34:40 +01:00
James Wilson 51e2330777 tweak a log message 2021-07-29 08:56:34 +01:00
James Wilson 8a23f342a4 add another test for the rolling total 2021-07-29 08:53:13 +01:00
James Wilson aa63e2960c block addresses from reconnecting if they send too much data 2021-07-28 16:43:51 +01:00
James Wilson 5f022069db cargo fmt 2021-07-28 16:15:34 +01:00
James Wilson 83d31ef0b3 Add rolling total and allow control over bytes per second allowed from node connections 2021-07-28 16:08:02 +01:00
arshamparity 4e5815ced9 adding liveness and rediness probes 2021-07-28 17:56:24 +03:00
arshamparity a0c434f238 set pipeline to manual 2021-07-28 16:37:00 +03:00
arshamparity d46e28e580 change the image tag 2021-07-28 16:22:48 +03:00
arshamparity cbca6a0974 change the ci 2021-07-28 16:17:39 +03:00
arshamparity fff38c1f38 change affinity rules 2021-07-28 15:23:04 +03:00
arshamparity 10647fe033 Merge remote-tracking branch 'origin/jsdw-sharding' into helm 2021-07-28 13:22:41 +03:00
arshamparity 99a3c474b9 deploying the shard alongside the core 2021-07-28 13:18:28 +03:00
James Wilson 9ec48adcaa Wee tidy up of test code 2021-07-27 14:45:45 +01:00
James Wilson 61fd903f55 Remove benchmark things for now and no need for release mode on a test 2021-07-27 14:28:27 +01:00
James Wilson 2ca5f6a1fb cargo fmt 2021-07-27 12:38:05 +01:00
James Wilson a44f39cfaf Add/test max_nodes_per_connection feature 2021-07-27 12:37:32 +01:00
arshamparity 3802c75830 fixing CI 2021-07-27 11:39:26 +03:00
arshamparity e7a7a7b237 fixing ci and replicas 2021-07-27 10:43:23 +03:00
James Wilson ecf5fccaab make possible to test, test, and fix feed cutoff 2021-07-26 16:38:24 +01:00
arshamparity 11972e3dc4 adding helm chart and configuring CI 2021-07-26 15:21:27 +03:00
James Wilson 50935b29fc put a deadline on message sending to feeds 2021-07-26 11:52:46 +01:00
James Wilson e043de8ddb Expose raw Soketto interface via ws_client for more control where needed (eg in tests) 2021-07-26 11:31:40 +01:00
James Wilson cf0e424803 Adapt shard to use hyper+soketto instead 2021-07-23 17:07:29 +01:00
James Wilson 480abd1e49 remove println 2021-07-23 16:21:30 +01:00
James Wilson 0eff32d10e Migrate telemetry_core to Hyper+Soketto 2021-07-23 15:57:50 +01:00
James Wilson 649fb966d2 Improve comment and bias select loop 2021-07-21 17:48:18 +01:00
James Wilson cedc2f9dbe tweak a comment 2021-07-21 13:59:44 +01:00
James Wilson 999d8ff0bd debounce feed polling a little to reduce CPU load when lots of messages are being sent out 2021-07-21 12:06:22 +01:00
James Wilson cca1df2e21 use ws_client in shard, too, and make it better at handling core disconnecting 2021-07-20 13:04:10 +01:00
James Wilson 36c4e7b0ef Remove flamegraph bits 2021-07-19 17:11:31 +01:00
James Wilson 73a4dbb095 Allow tests to hook up to running process to help with profiling 2021-07-19 15:57:39 +01:00
James Wilson f77afe0b75 avoid overquota in soak tests 2021-07-16 18:07:10 +01:00
James Wilson 582c49413b Make server able to run old or new binary so that we can compare the actix version with this one 2021-07-16 17:58:26 +01:00
James Wilson 81a0140c3b bump wait-time for port to be ready; build-host is slower to compile than my laptop.. 2021-07-16 10:03:38 +01:00
James Wilson fd79b3e85b Add some tests, and add a configurable soak test 2021-07-15 17:18:58 +01:00
James Wilson db8ea9a8f3 Add more tests, fix (and test for) a deadlock re overquota messages, more unbounded channels and less .awaiting 2021-07-15 10:53:02 +01:00