 Evan Huus
|
765b3b4f7d
Clean up aggregator via helper methods
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
49c475d433
Clean up the flusher via helper methods
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
9a9cdfe8b6
Structure the aggregator and flusher goroutines
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
b63a34d402
simplify goroutine constructor semantics slightly
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
071d28e684
Refactor producer goroutines somewhat
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
3e798fd0a3
Shrink the scope of the partition circuit-breaker
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
5ad52d8407
Don't retry messages until the broker is closed
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
6b85c47d32
Fix another hypothetical wait group issue
|
%!s(int64=9) %!d(string=hai) anos |
 Willem van Bergen
|
831d56178f
Ensure we always have called Add() on the inflight counter before we Wait() for it.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
26a20bdaff
Clear producer message retry field on success
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
42123dd0dd
Retry messages on shutdown
|
%!s(int64=9) %!d(string=hai) anos |
 Matt Perpick
|
cda92ba985
Fix async producer typo
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
52110d0cca
Producer logging tweaks
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
96702823f4
Improve memory of producer retry queue
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
509eef33e0
Rename some things
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
f86d40d963
producer: make Flush.Frequency behaviour better
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
4b2461f87a
producer: wrap partitioning in a circuit-breaker
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
a381b3667d
producer: bugfix for aggregators getting stuck
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
24b047c7ff
producer: bugfix for broker flushers getting stuck
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
3cd8fffe8a
Adjust producer flushing semantics
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
6be486f900
Only mention closing the Client on the FromClient constructors
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
1101246f70
Pass the topic to the partitioner constructor
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
a468f3ae10
Make Partition and Offset normal struct fields instead of functions.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
51060e6515
Rename Producer to AsyncProducer
|
%!s(int64=9) %!d(string=hai) anos |
