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 |
|