Commit graph

Select branches

Hide pull requests

bt1

bt3

bt4

bt6

bt7

bt7.1

bt7.1-notOK-only-updates-on-restart

bt8

bt8.1

bt8.2

bt8.3

cleanup1.2-various

cleanup1.5.removedProcessKind

cleanup1.6.filevar

jetstream1

jetstream1.1.1.1.1

jetstream1.1.1.1.1.1

jetstream1.1.1.1.1.1-squashed

keysacls1

main

v0.1.0

v0.2.0

Mono Color

• 84284eeee1 removed debug logging postmannen 2022-12-31 06:14:06 +01:00
• a77d1ad562 cleaned up os.Remove log postmannen 2022-12-31 06:02:26 +01:00
• ae6058d0af put in a timer to end stuck messages in ringbuffer postmannen 2022-12-30 16:52:50 +01:00
• 9e378295df restructured errors and retryWait in messageDeliverNats postmannen 2022-12-30 11:54:10 +01:00
• 5c5f8100d0 made ACK/NACK selection more clear postmannen 2022-12-29 22:49:47 +01:00
• c12cf70620 handling of indivdual messages are now done in it's own goroutine, changed logic for ACK msg retries postmannen 2022-12-29 07:53:25 +01:00
• 709bd219f7 stopping started tickers postmannen 2022-12-26 10:52:43 +01:00
• 98137b1df1 not creating a sub process before we check if it exists postmannen 2022-12-26 10:12:45 +01:00
• a737901c5d block profiling postmannen 2022-12-26 07:22:42 +01:00
• 8015c46cba removed printing of equal keys postmannen 2022-12-22 12:23:02 +01:00
• 3f5b58ffab fixed timeouts for copy messages postmannen 2022-12-21 09:27:52 +01:00
• 29a382838c fixed typo in debug message postmannen 2022-12-21 08:16:45 +01:00
• 27b762e69b added debug logging for sending nats messages postmannen 2022-12-21 08:12:41 +01:00
• e19f306146 always create tmp folder postmannen 2022-12-21 07:17:47 +01:00
• ec612101df only logging equal keys to console, and do not send to errorKernel postmannen 2022-12-21 07:07:21 +01:00
• 8d017c072d discard copy messages when more procs are started for the same copySrc request postmannen 2022-12-19 07:21:53 +01:00
• 2c1ed934dd allways delete tmpFolder when copyDstSubProcFunc is done. postmannen 2022-12-14 05:48:44 +01:00
• 33df0df948 added acktimeout and replies to the copysub messages postmannen 2022-12-02 10:04:20 +01:00
• 7c7f622044 fixed typo in comments postmannen 2022-11-30 08:35:13 +01:00
• 55c5560361 checking if fromNode is specified for startup messages postmannen 2022-11-30 07:58:41 +01:00
• 82303510cf removed gauge vector for sub processes postmannen 2022-11-30 06:18:19 +01:00
• 70408d24e9 write reply messages for copysub procs back to src node postmannen 2022-11-23 09:18:02 +01:00
• 198ba9503e Added message flow diagram postmannen 2022-11-08 08:44:24 +01:00
• d32bd09cd2 removed old debug information postmannen 2022-11-01 09:54:35 +01:00
• 852cd86c61 removed line feeds postmannen 2022-10-14 10:22:51 +02:00
• 757792c787 added creation of dst folder for copySrc postmannen 2022-10-14 10:12:50 +02:00
• 2f0cfa2294 replaced tui json with yaml postmannen 2022-10-05 11:22:41 +02:00
• b125e75094 fixed linter warnings postmannen 2022-10-05 09:24:49 +02:00
• 0249a86040 fixed debug logging postmannen 2022-10-05 09:16:22 +02:00
• 9c15e6dbfd added example kubernetes yaml file postmannen 2022-09-20 11:50:54 +02:00
• 0ad2763ad1 fixed block when reading startup folder postmannen 2022-09-08 07:37:44 +02:00
• 3cf8bd2ce8 removed references to deprecated ioutil postmannen 2022-09-06 10:59:07 +02:00
• f5e5e4337e added feature to copy file from remote to local postmannen 2022-09-06 10:43:27 +02:00
• f82146d72f boltdb todo's postmannen 2022-06-27 12:22:59 +02:00
• 3eb4414cca updated Dockerfile and env.env postmannen 2022-06-24 13:08:22 +02:00
• df8bae662d updated dockerfile postmannen 2022-06-24 10:16:10 +02:00
• 73b2363ea8 fixed docker file postmannen 2022-06-24 10:08:32 +02:00
• 4c97d26035 updated readme postmannen 2022-06-23 13:37:00 +02:00
• 3458e655c0 fixed proper stop and removal of subscriber procs postmannen 2022-06-23 11:40:17 +02:00
• 11b0444929 up toml pkg to v2, added comments to config file postmannen 2022-06-23 09:36:46 +02:00
• fb4cf5de79 updated comments postmannen 2022-06-22 14:50:26 +02:00
• 4b0a156ae1 updated comments postmannen 2022-06-22 14:43:01 +02:00
• b3bb2e44a1 updated comments postmannen 2022-06-22 14:32:58 +02:00
• 433541fcc1 REQToFile<x> now honor the directory path specified postmannen 2022-06-22 11:03:59 +02:00
• fc3d69a94b added printing to stderr for REQToConsole postmannen 2022-06-22 10:02:56 +02:00
• 8c1f870d1e updated bbolt postmannen 2022-06-22 09:09:02 +02:00
• 545c111fb2 updated go-toml postmannen 2022-06-22 09:07:26 +02:00
• bc0b38a3bb updated nats client and cbor postmannen 2022-06-22 09:04:53 +02:00
• b187fc8a13 updated readme postmannen 2022-06-22 08:59:03 +02:00
• f6477f9509 updated Dockerfile postmannen 2022-06-22 08:43:58 +02:00
• 03d6efdc6b update postmannen 2022-06-22 07:44:58 +02:00
• 0d8a2f1e18 updated gitignore postmannen 2022-06-22 07:43:59 +02:00
• edccbea1b3 added test for file copy postmannen 2022-06-22 07:31:43 +02:00
• bcc5eb35b6 removed pub sleep which kept allocs for too long. postmannen 2022-06-22 05:31:40 +02:00
• a04e96706a updated prometheus postmannen 2022-06-22 05:19:05 +02:00
• c6013a2968 fixed race+allocation in copySrcSubProcFunc postmannen 2022-06-22 05:03:11 +02:00
• 9c6ede458a added feature to turn of message persist to disk postmannen 2022-06-21 16:44:39 +02:00
• 93a61d8ef3 tested flushing nats.Conn postmannen 2022-06-21 10:40:32 +02:00
• 8ec6372565 fixed returns and error msgs for copy handlers postmannen 2022-06-21 07:45:36 +02:00
• 2688f2ba2c implemented ch for handling messages locally postmannen 2022-06-20 14:22:42 +02:00
• c8e5dd6904 fixed calling executeHandler() for startup folder messages postmannen 2022-06-20 13:34:20 +02:00
• 2d76e06274 updated readme postmannen 2022-06-20 12:40:24 +02:00
• 87b0d71a25 schedule all request types seems to initially work postmannen 2022-06-20 12:28:28 +02:00
• 113481775c initial scheduler implementation postmannen 2022-06-20 11:17:23 +02:00
• 6c900296c9 defering subReply.Unsubscribe postmannen 2022-06-18 08:12:14 +02:00
• 988bd04d7f limited allocactions for copyReady postmannen 2022-06-18 07:35:59 +02:00
• 0d4bfd4471 fixed logging with copy handlers postmannen 2022-06-18 00:43:42 +02:00
• efc5df5b16 logging and comments postmannen 2022-06-18 00:15:18 +02:00
• b1bcefb949 terminating subproc publishers if inactive for given amount of time postmannen 2022-06-18 00:03:25 +02:00
• 1dadc0df64 replaced validator with strings package postmannen 2022-06-17 13:13:01 +02:00
• 74f38e9ba2 defered closing of subscrybe sync postmannen 2022-06-17 09:54:20 +02:00
• c5d6ea0cb7 subscribers, added handling of individual error types postmannen 2022-06-17 08:22:19 +02:00
• 7e9a7638aa added message.RetryWait field, upgrader nats-server package postmannen 2022-06-17 00:39:15 +02:00
• b8a2d3d5e7 removed copyFile<from/to> and relay request types postmannen 2022-06-16 23:32:44 +02:00
• a03ff25da4 fixed using the MaxTotalCopyTime from message postmannen 2022-06-16 23:00:27 +02:00
• 800bd16d33 on dst chunk files are read in correct order postmannen 2022-06-16 12:18:21 +02:00
• 3df909bbe1 updated readme postmannen 2022-06-16 07:43:10 +02:00
• dcbd5ad031 updated readme postmannen 2022-06-16 07:35:03 +02:00
• f3f5e64c45 added seprata timwe for MaxAllowedCopy time which can be specified in the original message postmannen 2022-06-16 07:12:03 +02:00
• 1bdee3872b ending both src and dst sub procs when done copy postmannen 2022-06-16 06:42:34 +02:00
• fab3fa38dd simplified chunk write with Write(b[:n]) postmannen 2022-06-16 06:15:18 +02:00
• 0b4356b548 removed debug postmannen 2022-06-15 21:08:54 +02:00
• 2d36e0195b fixed wrong file size when writing at dst postmannen 2022-06-15 20:55:20 +02:00
• e010a1633a removing tmp files when done postmannen 2022-06-15 20:12:48 +02:00
• 97ef587a0e resend on error, retries, preserve file permissions postmannen 2022-06-15 14:47:20 +02:00
• 2745374da3 initial implementation of hash check for copy messages postmannen 2022-06-15 10:38:53 +02:00
• 69e0bd3696 copy, src defines and sets the split chunk size postmannen 2022-06-15 09:48:32 +02:00
• 036894a3fe writing tmp and final destinaton files postmannen 2022-06-15 07:51:58 +02:00
• 23c22210a5 comments postmannen 2022-06-15 05:31:46 +02:00
• df0c2ddc90 receiving copy data at dst postmannen 2022-06-15 05:06:44 +02:00
• 8d39c3c746 initial sending of chunks seems to work postmannen 2022-06-14 15:05:38 +02:00
• 10579e0e5d putting all elements into cia at src at creation postmannen 2022-06-14 14:58:50 +02:00
• c7eec5a196 reading from file postmannen 2022-06-14 14:32:35 +02:00
• f2fe8606ec copySrcSubProcFunc receiving rdy from dst postmannen 2022-06-14 11:31:19 +02:00
• 7c4fd58b04 srcSubHandler checking status value postmannen 2022-06-14 10:34:18 +02:00
• be181ec572 serializing data in sub req postmannen 2022-06-14 10:17:09 +02:00
• fe78d6c070 sub procs req use the same logic as normal req's for validation postmannen 2022-06-14 08:45:34 +02:00
• c4e384b987 Renamed REQSub to REQSUB postmannen 2022-06-14 07:09:20 +02:00
• 1895fcb398 Changed message logic to handle REQSub sub requests postmannen 2022-06-14 07:05:38 +02:00
• 537e7886dd added handler to type process postmannen 2022-06-11 06:30:58 +02:00