gollum
gollum copied to clipboard
trivago
An n:m message multiplexer written in Go
## The purpose of this pull request Fix invalidly indented code block in one of the doc files
Signed-off-by: Rui Chen ## The purpose of this pull request Update base images for security patches in the base image. ## Checklist - [x] `make test` executed successfully - [...
Just a heads up that Go 1.17 (and the just-released 1.16 without first changing `GO111MODULE`) won't support builds that aren't in module-aware mode. The master build should work but the...
## The purpose of this pull request This adds a producer for google stackdriver logs. ## Config to verify Messages passed to stdin have to be formatted as `severity: payload`,...
The StatsdMetrics producer still uses its on batching implementation.
Currently core.BatchedProducer, components.BatchedWriterAssembly and core.MessageBatch don't support flushing by size. This is one reason behind #140 and should be generalised for other batch producers, too.
There are several commonly used types that should be supported by config structs: - `map[MessageStreamID]bool` used for stream blacklists / whitelists - `core.GetAppliedContent` used by filters and core.SimpleFormatter - `tnet.URI`...
- If the configuration specifies a UNIX domain socket, and this socket already exists in the filesystem, consumer.Syslogd will fail with `[2017-07-24 00:26:19 CEST] ERROR Failed to open unix:///tmp/gol.sock PluginID=SyslogdConsumer...
There are a lot of resources that could be shared between producers and/or even consumers. E.g. if there are 3 kafka based plugins, we have 3 connections to each broker...
The socket producer is still build with a custom batch implementation. Move it over to the BatchedWriterAssembly like producer.File.
