Rafael Garcia
|
7b18d1bab4
|
write failed log message to file
|
2017-11-03 18:03:39 +00:00 |
|
Rafael Garcia
|
945ed317c2
|
remove logger as parameter
|
2017-11-03 17:48:50 +00:00 |
|
Rafael Garcia
|
221743b3e2
|
write errors to stderr
|
2017-11-02 21:50:46 +00:00 |
|
Xavi Ramirez
|
8f7cbf9952
|
Fixed case checkpoints would only occur on shutdown. The archive consumer fell victim of this bug.
|
2017-08-20 23:41:28 +00:00 |
|
Xavi Ramirez
|
55aeecddd7
|
Renamed IsEmpty to IsNil on SequencePair
|
2017-08-10 20:16:41 +00:00 |
|
Xavi Ramirez
|
45fad863d0
|
Made config object that's specific to BatcherManager
|
2017-08-10 20:11:24 +00:00 |
|
Xavi Ramirez
|
6102f9c752
|
Added comment to why a channel is taking a channel.
|
2017-08-10 19:56:17 +00:00 |
|
Xavi Ramirez
|
68a16cfe6a
|
Added an external go routine to ensure stale batches get flushed
|
2017-08-10 19:47:08 +00:00 |
|
Xavi Ramirez
|
27cce44140
|
Made constructors of private structs private
|
2017-08-10 19:21:46 +00:00 |
|
Xavi Ramirez
|
b7743c9ea7
|
Added a more coherent shutdown pathway
|
2017-08-09 01:22:11 +00:00 |
|
Xavi Ramirez
|
eb230b94f7
|
Added stats to base kinesis client
|
2017-08-07 19:20:56 +00:00 |
|
Xavi Ramirez
|
6a30e0eb8a
|
Huge refactor. Batchers no longer run in their own go-routines, which allowed us to a lot of concurrency and simplify model.
|
2017-08-07 19:20:56 +00:00 |
|