postmannen
|
c27a3dc188
|
updated comments
|
2021-08-16 13:01:12 +02:00 |
|
postmannen
|
0af326bba5
|
more tests
|
2021-08-10 07:41:30 +02:00 |
|
postmannen
|
e28eb3770d
|
initial test package created
|
2021-08-09 14:41:31 +02:00 |
|
postmannen
|
1a3e310cd1
|
changed error messages
|
2021-08-09 09:34:05 +02:00 |
|
postmannen
|
1523ae84c3
|
replaced struct{} with callback func for testing
|
2021-07-05 07:43:33 +02:00 |
|
postmannen
|
dd6d52f427
|
added delivered verification between buffer and buffer reader
|
2021-07-02 19:09:42 +02:00 |
|
postmannen
|
7791899e3d
|
Removed some errors via messages
|
2021-07-02 18:32:01 +02:00 |
|
postmannen
|
923fd4c611
|
exported type node to Node
|
2021-06-29 08:21:42 +02:00 |
|
postmannen
|
be8008b5a0
|
fixed bug where error message failed when kv store where missing
|
2021-05-21 08:21:17 +02:00 |
|
postmannen
|
0b44f1d339
|
changed config directories handling
|
2021-05-12 09:50:03 +02:00 |
|
postmannen
|
64a22c84e9
|
removed printf's, or made them into log's
|
2021-04-16 13:43:58 +02:00 |
|
postmannen
|
e538485b84
|
changed log output for commandorevent available
|
2021-04-16 12:45:14 +02:00 |
|
postmannen
|
8efecdb18e
|
renamed message timeout field to ACKTimeout
|
2021-04-15 10:33:44 +02:00 |
|
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 |
|