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

remove ValidateCheckpoint

Browse source
This commit is contained in:
Edward Tsang 2018-06-01 18:25:08 -07:00
parent 992cc42419
commit a800065101
2 changed files with 0 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
checkpoint/ddb/ddb.go
View file

@ -127,18 +127,6 @@ func (c *Checkpoint) Set(streamName, shardID, sequenceNumber string) error {
return nil return nil
} }
// ValidaCheckpoint validate the checkpoint table exits, shut down
func (c *Checkpoint) ValidateCheckpoint() error {
// ping table to verify it exists
_, err := c.client.DescribeTable(&dynamodb.DescribeTableInput{
TableName: aws.String(c.tableName),
})
if err != nil {
c.done <- struct{}{}
}
return err
}
// Shutdown the checkpoint. Save any in-flight data. // Shutdown the checkpoint. Save any in-flight data.
func (c *Checkpoint) Shutdown() error { func (c *Checkpoint) Shutdown() error {
c.done <- struct{}{} c.done <- struct{}{}

4
examples/consumer/main.go
View file

@ -52,10 +52,6 @@ func main() {
if err != nil { if err != nil {
log.Fatalf("checkpoint error: %v", err) log.Fatalf("checkpoint error: %v", err)
} }
err = ck.ValidateCheckpoint()
if err != nil {
log.Fatalf("checkpoint validation error: %v", err)
}
var ( var (
counter = expvar.NewMap("counters") counter = expvar.NewMap("counters")
logger = log.New(os.Stdout, "", log.LstdFlags) logger = log.New(os.Stdout, "", log.LstdFlags)