Arne Claus
Arne Claus
## 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`...
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 spooling producer is still build with a custom batch implementation. Move it over to the BatchedWriterAssembly like producer.File.
During the check for struct tags, nested components are iterated, too (if they are not pointers). If a component has a configure method it is called. However this does only...
The size of the parameter buffer is set fixed to 8KB, see https://github.com/FastCGI-Archives/fcgi2/blob/856ac8362affcc5e1aaafe587db9a56c89fc4c83/cgi-fcgi/cgi-fcgi.c#L814 Using more then ~8KB of parameters will cause malformed requests. In our case we were sending around...
Since go 1.9 (?) treflect.SetValue does not work for interface types. Reason behind this is apparently a different in type passing/conversion leading to the function not being able to generate...
**Overview** We encountered a strange behavior when a memcached host out of a ketama pool is taken down (by pulling the network cable). Twemproxy is returning timeouts directly after the...