175 commits

Author	SHA1	Message	Date
postmannen	13fd48843d	removed procfunc type definition	2022-03-31 14:57:30 +02:00
postmannen	3386a1d12c	removed debug printing	2022-03-24 05:56:23 +01:00
postmannen	a0d5be3580	zstdConcurrency=1, added publish messages ctx	2022-03-09 14:06:56 +01:00
postmannen	596b7e818c	starting publishAMessage as a go routine	2022-03-09 07:40:22 +01:00
postmannen	d6f7bd1048	added timeout when no responders available	2022-03-09 07:11:48 +01:00
postmannen	f2f7be5c11	removed not needed comments	2022-02-18 11:13:54 +01:00
postmannen	29c0ab8c52	added debug for fromNode on received nats messages	2022-02-18 10:46:26 +01:00
postmannen	7e71064adf	replaced log statements with errorKernel logger	2022-02-18 09:51:11 +01:00
postmannen	c94213fe36	removed log statements from process.go	2022-02-18 06:17:06 +01:00
postmannen	209fb572be	added fromNode to the nats header	2022-02-18 05:22:53 +01:00
postmannen	34c30d492d	removed debug printing	2022-02-17 13:01:21 +01:00
postmannen	cd348b5a0c	debugging gob encoding	2022-02-17 08:14:56 +01:00
postmannen	9e9a48ee35	changed error output	2022-02-16 13:09:55 +01:00
postmannen	b36cb08277	adjusted gob error output	2022-02-16 12:50:45 +01:00
postmannen	fa7e639223	added subject to gob decode error output	2022-02-16 09:30:50 +01:00
postmannen	cbba482371	debugging	2022-02-15 15:47:14 +01:00
postmannen	def4bd8e58	removed debug printing	2022-02-11 09:04:14 +01:00
postmannen	9ba211d2fc	added centralAuth struct, renamed flag allowEmptySignature to enableSignatureCheck	2022-02-09 14:59:40 +01:00
postmannen	52fff1a225	fixed comments	2022-02-09 05:29:34 +01:00
postmannen	d748dcaec8	tuned down debug output	2022-02-07 11:53:49 +01:00
postmannen	5fa3f593e7	removed errorCh from newProcess arguments	2022-02-07 06:42:17 +01:00
postmannen	b3630f62c4	moved signatures into signatures.go	2022-02-07 04:23:13 +01:00
postmannen	426b98941e	moved the ownership of signatures server from processes	2022-02-04 10:33:31 +01:00
postmannen	521702fa53	initial signature verification	2022-02-04 06:24:34 +01:00
postmannen	f19f164773	added flag for allowing empty signature	2022-02-03 11:41:46 +01:00
postmannen	5b211b6fac	implemented initial subscriber verify signature	2022-02-03 11:02:35 +01:00
postmannen	6724753e62	signing methodArgs	2022-02-03 07:04:10 +01:00
postmannen	130f9fc57e	restructured function logic for sending messages	2022-02-01 07:22:06 +01:00
postmannen	4390d494f4	updated comments with references to command to just have for the event type	2022-01-27 14:25:24 +01:00
postmannen	e7e5726095	renamed commandorevent field name in subject struct	2022-01-27 10:06:06 +01:00
postmannen	d7bee9d361	removed command type	2022-01-27 07:19:04 +01:00
postmannen	48500aa1fb	sendInfo also now via error kernel	2022-01-21 06:15:26 +01:00
postmannen	91bfb8510f	replaced sendError with errorKernel.errSend all over	2022-01-19 10:55:03 +01:00
postmannen	09a42d9442	errkrnl initial logic setup	2022-01-18 19:26:36 +01:00
postmannen	c4aa08711a	zstd removed speedbestcompression opt	2022-01-03 13:00:23 +01:00
postmannen	f6e667dd82	added gzip compression	2022-01-03 12:30:28 +01:00
postmannen	f63ee4eb7c	reusing zstd encoder	2022-01-03 11:36:05 +01:00
postmannen	5698623724	comments	2022-01-03 10:40:27 +01:00
postmannen	56cfd50e8b	removed fixed or no longer needed todo's	2022-01-03 07:36:38 +01:00
postmannen	e961111d96	add procFuncCh creation part of start the procFunc	2022-01-02 11:57:25 +01:00
postmannen	dea0c094fd	procFunc comments	2022-01-01 10:26:16 +01:00
postmannen	4ead73e091	updated comments for procfuncs	2022-01-01 10:13:35 +01:00
postmannen	0d0cd8c0b6	del console output, add flag for block profiling	2021-12-31 06:59:09 +01:00
postmannen	31ce2e978c	removed subscribesync pub with NACK msgs	2021-12-30 17:03:42 +01:00
postmannen	b8d21420ed	Comments	2021-12-30 06:28:21 +01:00
postmannen	8e87caf30a	added cbor toarray	2021-12-29 08:29:11 +01:00
postmannen	3bf5fca5cd	added cbor subscriber decoding	2021-12-29 08:11:43 +01:00
postmannen	574bed573a	added publishing of cbor payload	2021-12-29 07:28:09 +01:00
postmannen	d20b4eb64c	prepared encoding logic for chosing of serialization	2021-12-29 07:18:11 +01:00
postmannen	ce053fc651	moved setting of cmp nats header value	2021-12-29 06:40:42 +01:00
postmannen	973842f728	added return if failed gob decoding	2021-12-28 12:08:34 +01:00
postmannen	35b4462cf4	added zstd decoder to subscriber	2021-12-28 12:05:09 +01:00
postmannen	f543127cb6	initiallly implemented compression on publisher	2021-12-27 11:40:29 +01:00
postmannen	6d237ffcde	moved gob encoding to messageDeliverNats	2021-12-25 19:21:10 +01:00
postmannen	9b07eaa44b	comments	2021-11-22 08:32:45 +01:00
postmannen	38e286ab7d	removed debug printing	2021-11-22 08:25:50 +01:00
postmannen	3b37df638d	setting correct method for reply to origin.	2021-11-22 04:24:15 +01:00
postmannen	307695842f	removed the inner map of procsmap	2021-11-16 19:07:24 +01:00
postmannen	37d120950e	removed old code	2021-11-16 11:30:05 +01:00
postmannen	883f824325	put back proc active map with mutexes	2021-11-16 10:21:44 +01:00
postmannen	22b3e4fbe5	relay working, but cmd cont failing output	2021-11-11 13:43:32 +01:00
postmannen	3d8d082fd2	answer of relayed messages seems to work	2021-11-11 09:35:01 +01:00
postmannen	4fe066aebd	cleaned up old comments	2021-11-09 14:01:42 +01:00
postmannen	92047c9851	procsMap seems to work	2021-10-08 12:07:10 +02:00
postmannen	86c3f3a847	added MethodArgs to max retries error message	2021-10-01 08:37:00 +02:00
postmannen	8239c76bda	added sendInfoLogMessage function	2021-09-23 08:31:30 +02:00
postmannen	de7a6c0dda	removed message from error messages	2021-09-23 08:19:53 +02:00
postmannen	8d0b4420c9	initial implementation clicommand as reply method	2021-09-22 15:25:40 +02:00
postmannen	71f4007e31	disabled reaming code with allowedReceivers	2021-09-20 12:22:34 +02:00
postmannen	903383a529	removed the option for unlimited retries	2021-09-16 11:20:08 +02:00
postmannen	d8169841e0	fixed memory leak not unsubscribing reply messages	2021-09-16 08:13:24 +02:00
postmannen	aba7324ba6	fixed bug with hang caused by the of mutex	2021-09-13 13:15:21 +02:00
postmannen	254e522092	debug print statements	2021-09-13 09:24:38 +02:00
postmannen	0b61e510b4	added debug output	2021-09-13 07:02:14 +02:00
postmannen	d0f1ed32d1	removed the values field from flagslice	2021-09-08 17:57:21 +02:00
postmannen	8a49afa9ad	disabled the allow receivers functionality	2021-09-08 04:29:11 +02:00
postmannen	0f93e9a439	added error message timeouts and retries	2021-09-07 09:43:54 +02:00
postmannen	18272d73ab	metrics on error messages	2021-08-26 12:26:08 +02:00
postmannen	a669472c03	more metrics	2021-08-26 11:41:46 +02:00
postmannen	9846a9eb2f	moved registering of metrics into newMetrics	2021-08-26 10:50:40 +02:00
postmannen	c9e095ff5b	more metrics	2021-08-18 15:41:53 +02:00
postmannen	26afb87705	moved promProccessesVec into metrics	2021-08-18 12:28:26 +02:00
postmannen	b50cab487c	put in custom prometheus registry	2021-08-18 12:16:21 +02:00
postmannen	c27a3dc188	updated comments	2021-08-16 13:01:12 +02:00
postmannen	7791899e3d	Removed some errors via messages	2021-07-02 18:32:01 +02:00
postmannen	684b3f896f	Added main ctx, and child ctx derived from main to procs	2021-07-02 11:26:52 +02:00
postmannen	923fd4c611	exported type node to Node	2021-06-29 08:21:42 +02:00
postmannen	63c043e0ff	Unique process naming with id's used in active map to be able to control all individual processes	2021-06-08 13:56:31 +02:00
postmannen	c57c2ffc6f	changed the logging of processes	2021-06-08 06:02:08 +02:00
postmannen	2561c1266c	postfixed the reply part of the subject naming instead of having it prefixed	2021-06-08 04:45:01 +02:00
postmannen	aa20687d76	more specific error message	2021-06-08 03:11:22 +02:00
postmannen	be8008b5a0	fixed bug where error message failed when kv store where missing	2021-05-21 08:21:17 +02:00
postmannen	64a22c84e9	removed printf's, or made them into log's	2021-04-16 13:43:58 +02:00
postmannen	fde053a0cb	error handling on newserver	2021-04-16 13:18:10 +02:00
postmannen	a335c8c33a	fixed error in log node directory creation	2021-04-16 12:38:48 +02:00
postmannen	8efecdb18e	renamed message timeout field to ACKTimeout	2021-04-15 10:33:44 +02:00
postmannen	08f6f21691	rename REQTextToFile to REQToFile	2021-04-13 17:15:13 +02:00
postmannen	a6aa8fe4c8	added O_SYNC to log file opening	2021-04-13 13:25:44 +02:00
postmannen	30564f09ae	removed not used function	2021-04-13 07:45:14 +02:00
postmannen	f32dafc806	Added metric for running processes by name	2021-04-12 15:35:20 +02:00