diff --git a/clientlibrary/checkpoint/checkpointer.go b/clientlibrary/checkpoint/checkpointer.go index c24f469..cfc6adf 100644 --- a/clientlibrary/checkpoint/checkpointer.go +++ b/clientlibrary/checkpoint/checkpointer.go @@ -20,7 +20,7 @@ // Package checkpoint // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // diff --git a/clientlibrary/checkpoint/dynamodb-checkpointer.go b/clientlibrary/checkpoint/dynamodb-checkpointer.go index f64e630..17c5cd7 100644 --- a/clientlibrary/checkpoint/dynamodb-checkpointer.go +++ b/clientlibrary/checkpoint/dynamodb-checkpointer.go @@ -20,7 +20,7 @@ // Package checkpoint // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // @@ -441,6 +441,12 @@ func (checkpointer *DynamoCheckpoint) syncLeases(shardStatus map[string]*par.Sha } scanOutput, err := checkpointer.svc.Scan(context.TODO(), input) + + if err != nil { + log.Debugf("Error performing DynamoDB Scan. Error: %+v ", err) + return err + } + results := scanOutput.Items for _, result := range results { shardId, foundShardId := result[LeaseKeyKey] diff --git a/clientlibrary/checkpoint/mock-dynamodb_test.go b/clientlibrary/checkpoint/mock-dynamodb_test.go index eb9e17c..d7d63bf 100644 --- a/clientlibrary/checkpoint/mock-dynamodb_test.go +++ b/clientlibrary/checkpoint/mock-dynamodb_test.go @@ -19,7 +19,7 @@ // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // diff --git a/clientlibrary/metrics/cloudwatch/cloudwatch.go b/clientlibrary/metrics/cloudwatch/cloudwatch.go index 1383bbb..b3ef20f 100644 --- a/clientlibrary/metrics/cloudwatch/cloudwatch.go +++ b/clientlibrary/metrics/cloudwatch/cloudwatch.go @@ -20,7 +20,7 @@ // Package cloudwatch // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // diff --git a/clientlibrary/metrics/interfaces.go b/clientlibrary/metrics/interfaces.go index 8762a49..b416a88 100644 --- a/clientlibrary/metrics/interfaces.go +++ b/clientlibrary/metrics/interfaces.go @@ -20,7 +20,7 @@ // Package metrics // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // diff --git a/clientlibrary/metrics/prometheus/prometheus.go b/clientlibrary/metrics/prometheus/prometheus.go index 07a6e7e..69e311e 100644 --- a/clientlibrary/metrics/prometheus/prometheus.go +++ b/clientlibrary/metrics/prometheus/prometheus.go @@ -20,7 +20,7 @@ // Package prometheus // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // diff --git a/clientlibrary/partition/partition.go b/clientlibrary/partition/partition.go index 6f75290..8eb31dc 100644 --- a/clientlibrary/partition/partition.go +++ b/clientlibrary/partition/partition.go @@ -20,7 +20,7 @@ // Package partition // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // diff --git a/clientlibrary/worker/polling-shard-consumer.go b/clientlibrary/worker/polling-shard-consumer.go index 0589a41..8ee8091 100644 --- a/clientlibrary/worker/polling-shard-consumer.go +++ b/clientlibrary/worker/polling-shard-consumer.go @@ -20,7 +20,7 @@ // Package worker // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // diff --git a/clientlibrary/worker/worker.go b/clientlibrary/worker/worker.go index 7807edd..31bb61b 100644 --- a/clientlibrary/worker/worker.go +++ b/clientlibrary/worker/worker.go @@ -20,7 +20,7 @@ // Package worker // The implementation is derived from https://github.com/patrobinson/gokini // -// Copyright 2018 Patrick robinson +// # Copyright 2018 Patrick robinson // // Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: // @@ -49,9 +49,9 @@ import ( par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" ) -//Worker is the high level class that Kinesis applications use to start processing data. It initializes and oversees -//different components (e.g. syncing shard and lease information, tracking shard assignments, and processing data from -//the shards). +// Worker is the high level class that Kinesis applications use to start processing data. It initializes and oversees +// different components (e.g. syncing shard and lease information, tracking shard assignments, and processing data from +// the shards). type Worker struct { streamName string regionName string diff --git a/logger/zap/zap.go b/logger/zap/zap.go index cebb5b6..8e75364 100644 --- a/logger/zap/zap.go +++ b/logger/zap/zap.go @@ -44,7 +44,6 @@ type ZapLogger struct { // // Base zap logger can be convert to SugaredLogger by calling to add a wrapper: // sugaredLogger := log.Sugar() -// func NewZapLogger(logger *uzap.SugaredLogger) logger.Logger { return &ZapLogger{ sugaredLogger: logger,