luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

update for checkpoint can not customize retryer

Browse source
This commit is contained in:
Edward Tsang 2018-06-05 11:52:12 -07:00
parent cba40aeeb8
commit 4c2864ef56
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
README.md
View file

@ -105,6 +105,9 @@ ck, err := checkpoint.New(*app, *table, checkpoint.WithDynamoClient(myDynamoDbCl
if err != nil { if err != nil {
log.Fatalf("new checkpoint error: %v", err) log.Fatalf("new checkpoint error: %v", err)
} }
// Or we can provide your own Retryer to customize what triggers a retry inside checkpoint
// See code in examples
// ck, err := checkpoint.New(*app, *table, checkpoint.WithDynamoClient(myDynamoDbClient), checkpoint.WithRetryer(&MyRetryer{}))
``` ```
To leverage the DDB checkpoint we'll also need to create a table: To leverage the DDB checkpoint we'll also need to create a table: