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

961 commits

Author SHA1 Message Date
postmannen
fc3d69a94b added printing to stderr for REQToConsole 2022-06-22 10:02:56 +02:00
postmannen
8c1f870d1e updated bbolt 2022-06-22 09:09:02 +02:00
postmannen
545c111fb2 updated go-toml 2022-06-22 09:07:26 +02:00
postmannen
bc0b38a3bb updated nats client and cbor 2022-06-22 09:04:53 +02:00
postmannen
b187fc8a13 updated readme 2022-06-22 08:59:03 +02:00
postmannen
f6477f9509 updated Dockerfile 2022-06-22 08:43:58 +02:00
postmannen
03d6efdc6b update 2022-06-22 07:44:58 +02:00
postmannen
0d8a2f1e18 updated gitignore 2022-06-22 07:43:59 +02:00
postmannen
edccbea1b3 added test for file copy 2022-06-22 07:31:43 +02:00
postmannen
bcc5eb35b6 removed pub sleep which kept allocs for too long. 2022-06-22 05:31:40 +02:00
postmannen
a04e96706a updated prometheus 2022-06-22 05:19:05 +02:00
postmannen
c6013a2968 fixed race+allocation in copySrcSubProcFunc 2022-06-22 05:03:11 +02:00
postmannen
9c6ede458a added feature to turn of message persist to disk 2022-06-21 16:44:39 +02:00
postmannen
93a61d8ef3 tested flushing nats.Conn 2022-06-21 10:40:32 +02:00
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