1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-15 17:51:15 +00:00
Commit graph

25 commits

Author SHA1 Message Date
postmannen
ed00f247ae unix socket for new mesages, changed naming of channels 2021-03-29 13:36:30 +02:00
postmannen
f792675ebe cleaned up err console logging 2021-03-26 05:13:51 +01:00
postmannen
899d2e1f09 renamed inmsg to steward.sock 2021-03-25 12:33:53 +01:00
postmannen
18f6f2a6f1 centralNodeName flag 2021-03-12 10:41:03 +01:00
postmannen
8355f4154a sending errors from ringbuffer 2021-03-12 09:49:27 +01:00
postmannen
ca295d97d8 sending errors to central 2021-03-12 09:38:19 +01:00
postmannen
ae0e080f80 fixed procFuncs 2021-03-05 13:10:46 +01:00
postmannen
abf8c0d3c7 added procFunc concept, fixed race and timer issues 2021-03-04 16:27:55 +01:00
postmannen
4f106ea8cc rewrote the textlogger subscriber, fixed * in allowed publishers, cleaned up logging 2021-03-02 13:46:02 +01:00
postmannen
35e0c12109 removed the need for specifying the kind of event/command within a message. This is now picked from the generated subject 2021-03-01 17:08:40 +01:00
postmannen
f49b4b3cf6 implemented message timeout and retry options 2021-02-25 13:08:10 +01:00
postmannen
61e2343f18 refactored, and implemented error messages to central 2021-02-24 15:43:31 +01:00
postmannen
f812c4307e cleaning up restructuring 2021-02-24 10:58:02 +01:00
postmannen
65c3eaacb0 checking for valid command type in json input config 2021-02-18 08:25:13 +01:00
postmannen
8dea13b850 added types for ACK and NACK messages 2021-02-17 18:59:49 +01:00
postmannen
6a81c0e9db retreival and handling of previosly unhandled messages on program restart implemented 2021-02-17 12:02:34 +01:00
postmannen
c60699bce5 addeded permanent log storage 2021-02-17 10:27:39 +01:00
postmannen
08bb43a620 Updated comments 2021-02-16 14:58:59 +01:00
postmannen
1f998b3b6a changed types used for ringbuffer, and fixed mutex on message index 2021-02-16 14:29:32 +01:00
postmannen
a5b8df9ea6 split the message processing into it's own functions, and handle each message concurrently within the buffer 2021-02-16 12:59:37 +01:00
postmannen
f7cbbe3115 storing to message kv buffer seems to work 2021-02-16 12:29:15 +01:00
postmannen
5e44c4bbc4 printing db after message consumed 2021-02-16 06:43:09 +01:00
postmannen
3cb0c9f5c9 kv store for index and messages pu in 2021-02-16 04:57:54 +01:00
postmannen
993f89e2c6 implemented general store and get to kv store 2021-02-15 11:28:27 +01:00
postmannen
fb02962231 put in a ring buffer for new messages 2021-02-12 11:21:51 +01:00