918 commits

This branch

This branch

All branches

Author	SHA1	Message	Date
postmannen	4c97d26035	updated readme	2022-06-23 13:37:00 +02:00
postmannen	3458e655c0	fixed proper stop and removal of subscriber procs	2022-06-23 11:40:17 +02:00
postmannen	11b0444929	up toml pkg to v2, added comments to config file	2022-06-23 09:36:46 +02:00
postmannen	fb4cf5de79	updated comments	2022-06-22 14:50:26 +02:00
postmannen	4b0a156ae1	updated comments	2022-06-22 14:43:01 +02:00
postmannen	b3bb2e44a1	updated comments	2022-06-22 14:32:58 +02:00
postmannen	433541fcc1	REQToFile<x> now honor the directory path specified	2022-06-22 11:03:59 +02:00
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