1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00
Commit graph

947 commits

Author SHA1 Message Date
postmannen
8ec6372565 fixed returns and error msgs for copy handlers 2022-06-21 07:45:36 +02:00
postmannen
2688f2ba2c implemented ch for handling messages locally 2022-06-20 14:22:42 +02:00
postmannen
c8e5dd6904 fixed calling executeHandler() for startup folder messages 2022-06-20 13:34:20 +02:00
postmannen
2d76e06274 updated readme 2022-06-20 12:40:24 +02:00
postmannen
87b0d71a25 schedule all request types seems to initially work 2022-06-20 12:28:28 +02:00
postmannen
113481775c initial scheduler implementation 2022-06-20 11:17:23 +02:00
postmannen
6c900296c9 defering subReply.Unsubscribe 2022-06-18 08:12:14 +02:00
postmannen
988bd04d7f limited allocactions for copyReady 2022-06-18 07:35:59 +02:00
postmannen
0d4bfd4471 fixed logging with copy handlers 2022-06-18 00:43:42 +02:00
postmannen
efc5df5b16 logging and comments 2022-06-18 00:15:18 +02:00
postmannen
b1bcefb949 terminating subproc publishers if inactive for given amount of time 2022-06-18 00:03:25 +02:00
postmannen
1dadc0df64 replaced validator with strings package 2022-06-17 13:13:01 +02:00
postmannen
74f38e9ba2 defered closing of subscrybe sync 2022-06-17 09:54:20 +02:00
postmannen
c5d6ea0cb7 subscribers, added handling of individual error types 2022-06-17 08:22:19 +02:00
postmannen
7e9a7638aa added message.RetryWait field, upgrader nats-server package 2022-06-17 00:39:15 +02:00
postmannen
b8a2d3d5e7 removed copyFile<from/to> and relay request types 2022-06-16 23:32:44 +02:00
postmannen
a03ff25da4 fixed using the MaxTotalCopyTime from message 2022-06-16 23:00:27 +02:00
postmannen
800bd16d33 on dst chunk files are read in correct order 2022-06-16 12:18:21 +02:00
postmannen
3df909bbe1 updated readme 2022-06-16 07:43:10 +02:00
postmannen
dcbd5ad031 updated readme 2022-06-16 07:35:03 +02:00
postmannen
f3f5e64c45 added seprata timwe for MaxAllowedCopy time which can be specified in the original message 2022-06-16 07:12:03 +02:00
postmannen
1bdee3872b ending both src and dst sub procs when done copy 2022-06-16 06:42:34 +02:00
postmannen
fab3fa38dd simplified chunk write with Write(b[:n]) 2022-06-16 06:15:18 +02:00
postmannen
0b4356b548 removed debug 2022-06-15 21:08:54 +02:00
postmannen
2d36e0195b fixed wrong file size when writing at dst 2022-06-15 20:55:20 +02:00
postmannen
e010a1633a removing tmp files when done 2022-06-15 20:12:48 +02:00
postmannen
97ef587a0e resend on error, retries, preserve file permissions 2022-06-15 14:47:20 +02:00
postmannen
2745374da3 initial implementation of hash check for copy messages 2022-06-15 10:38:53 +02:00
postmannen
69e0bd3696 copy, src defines and sets the split chunk size 2022-06-15 09:48:32 +02:00
postmannen
036894a3fe writing tmp and final destinaton files 2022-06-15 07:51:58 +02:00
postmannen
23c22210a5 comments 2022-06-15 05:31:46 +02:00
postmannen
df0c2ddc90 receiving copy data at dst 2022-06-15 05:06:44 +02:00
postmannen
8d39c3c746 initial sending of chunks seems to work 2022-06-14 15:05:38 +02:00
postmannen
10579e0e5d putting all elements into cia at src at creation 2022-06-14 14:58:50 +02:00
postmannen
c7eec5a196 reading from file 2022-06-14 14:32:35 +02:00
postmannen
f2fe8606ec copySrcSubProcFunc receiving rdy from dst 2022-06-14 11:31:19 +02:00
postmannen
7c4fd58b04 srcSubHandler checking status value 2022-06-14 10:34:18 +02:00
postmannen
be181ec572 serializing data in sub req 2022-06-14 10:17:09 +02:00
postmannen
fe78d6c070 sub procs req use the same logic as normal req's for validation 2022-06-14 08:45:34 +02:00
postmannen
c4e384b987 Renamed REQSub to REQSUB 2022-06-14 07:09:20 +02:00
postmannen
1895fcb398 Changed message logic to handle REQSub sub requests 2022-06-14 07:05:38 +02:00
postmannen
537e7886dd added handler to type process 2022-06-11 06:30:58 +02:00
postmannen
237b946cf0 added copyInitialData to copy procFunc 2022-06-10 10:38:11 +02:00
postmannen
95ce5fed3b changed copy sub subjects to use "." for uuid 2022-06-10 06:34:39 +02:00
postmannen
c86e513cc0 copy, added proc info to reply message 2022-06-10 06:17:11 +02:00
postmannen
f78647196d added initial procFunc for methodREQCopyDst 2022-06-09 11:40:53 +02:00
postmannen
cd3618c5ea cbor marshaling data in initial copy message 2022-06-09 11:25:59 +02:00
postmannen
f1e1577a03 fixed copySrc reply message 2022-06-09 10:27:20 +02:00
postmannen
680cb1f4dd moved naming of process into newProcess 2022-06-09 10:18:09 +02:00
postmannen
731f628233 fixed wrong handling newpki when db is missing 2022-06-09 08:42:49 +02:00