Edward Tsang
1a14621969
add more span tags
2018-11-14 11:51:37 -08:00
Edward Tsang
a6eaeb2bfa
need to add context as first parameter to pass through, fixed tests and readme
2018-11-07 15:45:13 -08:00
Prometheus
d058203b6e
Make what aws error to trigger retry decided by caller ( #52 )
...
* remove ValidateCheckpoint
* make retrying on error decided by caller
2018-06-04 20:07:58 -07:00
Prometheus
9a7e102a05
remove ValidateCheckpoint ( #51 )
2018-06-01 19:34:46 -07:00
Prometheus
992cc42419
DDB uses default AWS config settings to ping table; won't work with WithDyanmoClient. Misc update on example and README ( #50 )
2018-06-01 16:14:42 -07:00
Prometheus
9e0a97916d
Use AWS resource iface, overwrite default dynamodb, more explicit in example about overwrite default AWS resrouce client ( #49 )
...
* use custom kinesis client
* use aws sdk interface, add missing api for ddb
* add overwrite default dynamodbclien usage
2018-05-31 17:41:14 -07:00
Harlow Ward
64cdf69249
Add interval flush for DDB checkpoint ( #40 )
...
Add interval flush for DDB checkpoint
* Allow checkpointing on a specified interval
* Add shutdown method to checkpoint to force flush
Minor changes:
* Swap order of input params for checkpoint (app, table)
Addresses: https://github.com/harlow/kinesis-consumer/issues/39
2017-12-30 20:21:10 -08:00
Harlow Ward
6401371727
Simplify checkpoint interface; reduce input vars
2017-11-22 20:01:31 -08:00
Harlow Ward
4d6a85e901
Make the Checkpoint a required input for Consumer
...
The Checkpoint functionality is an important part of the library and
previously it wasn't obvious that the Consumer was defaulting to Redis
for this functionality.
* Add Checkpoint as required param for new consumer
2017-11-21 08:58:16 -08:00
Harlow Ward
6ee965ec0a
Add DDB as consumer checkpoint option ( #37 )
...
* Simplify the checkpoint interface
* Add DDB backend for checkpoint persistence
Implements: https://github.com/harlow/kinesis-consumer/issues/26
2017-11-20 09:37:30 -08:00
