From a80006510130c6c241889571f4e8aab43d98dd9b Mon Sep 17 00:00:00 2001 From: Edward Tsang Date: Fri, 1 Jun 2018 18:25:08 -0700 Subject: [PATCH] remove ValidateCheckpoint --- checkpoint/ddb/ddb.go | 12 ------------ examples/consumer/main.go | 4 ---- 2 files changed, 16 deletions(-) diff --git a/checkpoint/ddb/ddb.go b/checkpoint/ddb/ddb.go index 20fbc33..b01d290 100644 --- a/checkpoint/ddb/ddb.go +++ b/checkpoint/ddb/ddb.go @@ -127,18 +127,6 @@ func (c *Checkpoint) Set(streamName, shardID, sequenceNumber string) error { 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. func (c *Checkpoint) Shutdown() error { c.done <- struct{}{} diff --git a/examples/consumer/main.go b/examples/consumer/main.go index 4343378..5c8bc99 100644 --- a/examples/consumer/main.go +++ b/examples/consumer/main.go @@ -52,10 +52,6 @@ func main() { if err != nil { log.Fatalf("checkpoint error: %v", err) } - err = ck.ValidateCheckpoint() - if err != nil { - log.Fatalf("checkpoint validation error: %v", err) - } var ( counter = expvar.NewMap("counters") logger = log.New(os.Stdout, "", log.LstdFlags)