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

185 commits

Author SHA1 Message Date
postmannen
f99af8e0ab moved all the procfunc definitions in the processes startup as separate functions defined after theyr respective request method where they belong 2024-12-13 16:49:21 +01:00
postmannen
3a31ced938 Squashed commit of the following:
implemented reading and embedding the content of a local file with {{CTRL_FILE}}

fixed error with not found filename in copy test, remove debug logs

seedfile: removed deletion, and changed file permissions to 600

created flags for profiling

renamed startup.subscriber to startup.startProcess

created a separate method for helloPublisher

removed processKind, og removed not needed file check in copy request

removed sams from channels

removed publisher channel on subject, and messages to publish are now directly published from the newMessagesCh

removed no longer needed compression and serialization flags.

all messaging are using zstd for compression, and cbor for serializing

added functions for handling cbor serializing and zstd compression, and swapped out json marshaling of jetstream message data with cbor and zstd

added flag for max jetstream messages to keep on broker per subject
2024-12-03 16:17:33 +01:00
postmannen
cdf660aa07 add NODES.all as jetstream subject, and updated doc
added handling of consumed jetstream messages, and fixed a read error with readFolder which sometimes read empty content

newMessagesCh now takes single sam instead of []sams

added jetstream publish channel
2024-11-27 08:34:49 +01:00
postmannen
6c615591a6 Squashed commit of the following:
commit 2a5cb441ff8c3f3f4404c49188c16afdb701cd42
Author: postmannen <postmannen@gmail.com>
Date:   Tue Nov 19 06:46:58 2024 +0100

    updated doc

commit a97d2dd4fd162a45dcf8f80d833a31bdc7e0b817
Author: postmannen <postmannen@gmail.com>
Date:   Tue Nov 19 06:25:57 2024 +0100

    renamed the various naming for channels where new messages are put to newMessagesCh

commit 3c840eb718358bb55d9e1c58692517e4bbbb5f4d
Author: postmannen <postmannen@gmail.com>
Date:   Tue Nov 19 05:08:55 2024 +0100

    Restructured configuration, and added a StartProcesses struct for the flags that are for starting processes
2024-11-19 20:28:26 +01:00
postmannen
b1a5406598 Squashed commit of the following:
commit ec6ea8158d5051010c25ef848a7b7b91fa40efef
Author: postmannen <postmannen@gmail.com>
Date:   Tue Nov 19 03:48:03 2024 +0100

    Removed remaining use of REQ in naming

commit b80bb06a47cf564a88d684c1d1d4fe2e408c3c0f
Author: postmannen <postmannen@gmail.com>
Date:   Mon Nov 18 23:15:32 2024 +0100

    removed REQ in more variable names, including methods

commit af7f6fef3e0093312d2ca12740f7b27840797800
Author: postmannen <postmannen@gmail.com>
Date:   Mon Nov 18 22:54:40 2024 +0100

    renamed all the method type variables

commit e657ecb37f
Author: postmannen <postmannen@gmail.com>
Date:   Mon Nov 18 22:32:13 2024 +0100

    renamed methods constant values and removed REQ
2024-11-19 03:48:42 +01:00
postmannen
2fb43591ce updated readme
removed example for no longer existing relay messages
cleaned up comments
Removed some remaings after REQToFileNACK
Implemented env variables for all flags, and removed config flag. Also added use of .env file.
removed configuration as input argument from all the loggers
replaced logging of new messages in read folder with a logDebug so we don't send those messages to the error kernel
2024-03-27 12:48:17 +01:00
postmannen
c098c623f1 cleaned up no longer used code 2024-03-08 22:55:21 +01:00
postmannen
69995f76ca updated package info
updated references
removed tui client
removed ringbuffer persist store
removed ringbuffer
enabled audit logging
moved audit logging to message readers
disabled goreleaser
update readme, cbor, zstd
removed request type ping and pong
update readme
testing with cmd.WaitDelay for clicommand
fixed readme
removed ringbuffer flag
default serialization set to cbor, default compression set to zstd, fixed race,
removed event type ack and nack, also removed from subject. Fixed file stat error for copy log file
removed remaining elements of the event type
removed comments
renamed toRingbufferCh to samToSendCh
renamed directSAMSCh ro samSendLocalCh
removed handler interface
agpl3 license
added license-change.md
2024-02-07 22:54:50 +01:00
postmannen
6922775107 fixed mutex passed wrongly by value 2023-05-31 09:30:39 +02:00
postmannen
e50d906be3 renabled ringbuffer done channel triggered by persiststore flag 2023-05-30 05:46:02 +02:00
postmannen
7d21af55e7 not terminating publisher services that should run at all times based on timer 2023-01-13 15:09:23 +01:00
postmannen
8c8061dc15 renamed logConsoleOnlyIfDebug to logDebug 2023-01-12 12:03:10 +01:00
postmannen
076abdef71 changed from log package to slog 2023-01-12 12:01:01 +01:00
postmannen
1dbff78c81 replaced log print with slog debug 2023-01-12 07:44:28 +01:00
postmannen
aa925329f7 fixed output of error logging 2023-01-12 07:12:35 +01:00
postmannen
807455119c Added x/slog for stderr logging 2023-01-11 08:38:15 +01:00
postmannen
215a4c387a split out start pub/sub process in separate func's 2023-01-11 07:03:01 +01:00
postmannen
f574d768cd added debug logging for received nack/ack messages 2023-01-06 08:32:42 +01:00
postmannen
eced76a85c initially removed dependency to NACK/ACK event type 2023-01-05 01:55:52 +01:00
postmannen
75126ce977 fixed double printing of successful send for NACK messages 2023-01-04 09:37:33 +01:00
postmannen
6a97d86ca0 removed done channel when publishing, and added make chan when creating sam 2023-01-04 09:14:04 +01:00
postmannen
2eff3c9cd3 restructured sync when publishing messages 2023-01-03 11:41:18 +01:00
postmannen
5865ad3701 using the same message ID locally as in the ringbuffer 2022-12-31 07:31:18 +01:00
postmannen
9e378295df restructured errors and retryWait in messageDeliverNats 2022-12-30 11:54:10 +01:00
postmannen
5c5f8100d0 made ACK/NACK selection more clear 2022-12-29 22:49:47 +01:00
postmannen
c12cf70620 handling of indivdual messages are now done in it's own goroutine, changed logic for ACK msg retries 2022-12-29 07:53:25 +01:00
postmannen
709bd219f7 stopping started tickers 2022-12-26 10:52:43 +01:00
postmannen
27b762e69b added debug logging for sending nats messages 2022-12-21 08:12:41 +01:00
postmannen
82303510cf removed gauge vector for sub processes 2022-11-30 06:18:19 +01:00
postmannen
b125e75094 fixed linter warnings 2022-10-05 09:24:49 +02:00
postmannen
0249a86040 fixed debug logging 2022-10-05 09:16:22 +02:00
postmannen
3458e655c0 fixed proper stop and removal of subscriber procs 2022-06-23 11:40:17 +02:00
postmannen
bcc5eb35b6 removed pub sleep which kept allocs for too long. 2022-06-22 05:31:40 +02:00
postmannen
c6013a2968 fixed race+allocation in copySrcSubProcFunc 2022-06-22 05:03:11 +02:00
postmannen
93a61d8ef3 tested flushing nats.Conn 2022-06-21 10:40:32 +02:00
postmannen
c8e5dd6904 fixed calling executeHandler() for startup folder messages 2022-06-20 13:34:20 +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
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
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
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
680cb1f4dd moved naming of process into newProcess 2022-06-09 10:18:09 +02:00
postmannen
8887fd4c2f turned off escaping when saving acl to file, cleaned up acl debug to console, acl distribution and verification seems to work 2022-06-02 06:29:37 +02:00
postmannen
da1ab140c1 disabled keys push update.. for now. 2022-05-31 11:05:21 +02:00