From 86cc5a1a64fa97fe58d517192b7660f447c62164 Mon Sep 17 00:00:00 2001 From: Tao Jiang Date: Tue, 21 Dec 2021 13:49:47 -0600 Subject: [PATCH] Update the libray reference path to new repo Signed-off-by: Tao Jiang --- README.md | 71 +++++++++---------- clientlibrary/checkpoint/checkpointer.go | 2 +- .../checkpoint/dynamodb-checkpointer.go | 6 +- .../checkpoint/dynamodb-checkpointer_test.go | 4 +- clientlibrary/config/config.go | 5 +- clientlibrary/config/config_test.go | 2 +- clientlibrary/config/initial-stream-pos.go | 1 + clientlibrary/config/kcl-config.go | 7 +- clientlibrary/interfaces/inputs.go | 1 + .../record-processor-checkpointer.go | 1 + clientlibrary/interfaces/sequence-number.go | 1 + .../metrics/cloudwatch/cloudwatch.go | 2 +- .../metrics/prometheus/prometheus.go | 2 +- clientlibrary/partition/partition.go | 2 +- clientlibrary/worker/common-shard-consumer.go | 12 ++-- .../worker/fan-out-shard-consumer.go | 4 +- .../worker/polling-shard-consumer.go | 6 +- .../worker/record-processor-checkpointer.go | 6 +- clientlibrary/worker/worker.go | 10 +-- go.mod | 2 +- internal/deaggregator/deaggregator.go | 2 +- internal/deaggregator/deaggregator_test.go | 4 +- logger/zap/zap.go | 2 +- logger/zap/zap_test.go | 4 +- logger/zerolog/zerolog.go | 2 +- logger/zerolog/zerolog_test.go | 2 +- test/lease_stealing_util_test.go | 6 +- test/logger_test.go | 4 +- test/record_processor_test.go | 2 +- test/record_publisher_test.go | 4 +- test/worker_custom_test.go | 8 +-- test/worker_lease_stealing_test.go | 8 +-- test/worker_test.go | 14 ++-- 33 files changed, 105 insertions(+), 104 deletions(-) diff --git a/README.md b/README.md index af388e4..4f899b6 100644 --- a/README.md +++ b/README.md @@ -1,25 +1,51 @@ -# vmware-go-kcl-v2 +# VMWare Go KCL v2 +[![Go Report Card](https://goreportcard.com/badge/github.com/vmware/vmware-go-kcl)](https://goreportcard.com/report/github.com/vmware/vmware-go-kcl) +[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT) [![vmware-go-kcl-v2](https://github.com/fafg/vmware-go-kcl/actions/workflows/vmware-go-kcl-v2-ci.yml/badge.svg)](https://github.com/fafg/vmware-go-kcl/actions/workflows/vmware-go-kcl-v2-ci.yml) ## Overview +VMware-Go-KCL is a native open-source Go library for Amazon Kinesis Data Stream (KDS) consumption. It allows developers +to program KDS consumers in lightweight Go language and still take advantage of the features presented by the native +KDS Java API libraries. + +[vmware-go-kcl](https://github.com/vmware/vmware-go-kcl) is a VMWare originated open-source project for AWS Kinesis +Client Library in Go. Within VMware, we have seen adoption in vSecureState and Carbon Black. In addition, Carbon Black +has contributed to the vmware-go-kcl codebase and heavily used it in the product. Besides, +[vmware-go-kcl](https://github.com/vmware/vmware-go-kcl) has got +[recognition](https://www.linkedin.com/posts/adityakrish_vmware-go-kcl-a-native-open-source-go-programming-activity-6810626798133616640-B6W8/), +and [contributions](https://github.com/vmware/vmware-go-kcl/graphs/contributors) from the industry. + +`vmware-go-kcl-v2` is the v2 version of VMWare KCL for the Go programming language by utilizing [AWS Go SDK V2](https://github.com/aws/aws-sdk-go-v2). + ## Try it out ### Prerequisites -* Prereq 1 -* Prereq 2 -* Prereq 3 +* [aws-sdk-go-v2](https://github.com/aws/aws-sdk-go-v2) +* The v2 SDK requires a minimum version of `Go 1.17`. +* [gosec](https://github.com/securego/gosec) ### Build & Run -1. Step 1 -2. Step 2 -3. Step 3 +1. Initialize Project +2. Build + +`make build` + +3. Test + +`make test` ## Documentation +VMware-Go-KCL matches exactly the same interface and programming model from original Amazon KCL, the best place for getting reference, tutorial is from Amazon itself: + +- [Developing Consumers Using the Kinesis Client Library](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-kcl.html) +- [Troubleshooting](https://docs.aws.amazon.com/streams/latest/dev/troubleshooting-consumers.html) +- [Advanced Topics](https://docs.aws.amazon.com/streams/latest/dev/advanced-consumers.html) + ## Contributing The vmware-go-kcl-v2 project team welcomes contributions from the community. Before you start working with vmware-go-kcl-v2, please @@ -29,35 +55,4 @@ as an open-source patch. For more detailed information, refer to [CONTRIBUTING.m ## License -### Build & Run - -```sh -hmake - -# security scan -hmake scanast - -# run test -hmake check - -# run integration test -# update the worker_test.go to let it point to your Kinesis stream -hmake test -``` - -## Documentation - -VMware-Go-KCL matches exactly the same interface and programming model from original Amazon KCL, the best place for getting reference, tutorial is from Amazon itself: - -- [Developing Consumers Using the Kinesis Client Library](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-kcl.html) -- [Troubleshooting](https://docs.aws.amazon.com/streams/latest/dev/troubleshooting-consumers.html) -- [Advanced Topics](https://docs.aws.amazon.com/streams/latest/dev/advanced-consumers.html) - - -## Contributing - -The vmware-go-kcl project team welcomes contributions from the community. Before you start working with vmware-go-kcl, please read our [Developer Certificate of Origin](https://cla.vmware.com/dco). All contributions to this repository must be signed as described on that page. Your signature certifies that you wrote the patch or have the right to pass it on as an open-source patch. For more detailed information, refer to [CONTRIBUTING.md](CONTRIBUTING.md). - -## License - MIT License diff --git a/clientlibrary/checkpoint/checkpointer.go b/clientlibrary/checkpoint/checkpointer.go index fff1a51..c24f469 100644 --- a/clientlibrary/checkpoint/checkpointer.go +++ b/clientlibrary/checkpoint/checkpointer.go @@ -33,7 +33,7 @@ import ( "errors" "fmt" - par "github.com/vmware/vmware-go-kcl/clientlibrary/partition" + par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" ) const ( diff --git a/clientlibrary/checkpoint/dynamodb-checkpointer.go b/clientlibrary/checkpoint/dynamodb-checkpointer.go index dc7e8cd..58d251a 100644 --- a/clientlibrary/checkpoint/dynamodb-checkpointer.go +++ b/clientlibrary/checkpoint/dynamodb-checkpointer.go @@ -42,9 +42,9 @@ import ( "github.com/aws/aws-sdk-go-v2/service/dynamodb" "github.com/aws/aws-sdk-go-v2/service/dynamodb/types" - "github.com/vmware/vmware-go-kcl/clientlibrary/config" - par "github.com/vmware/vmware-go-kcl/clientlibrary/partition" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" + "github.com/vmware/vmware-go-kcl-v2/logger" ) const ( diff --git a/clientlibrary/checkpoint/dynamodb-checkpointer_test.go b/clientlibrary/checkpoint/dynamodb-checkpointer_test.go index 1f0a8f1..5515390 100644 --- a/clientlibrary/checkpoint/dynamodb-checkpointer_test.go +++ b/clientlibrary/checkpoint/dynamodb-checkpointer_test.go @@ -39,8 +39,8 @@ import ( "github.com/aws/aws-sdk-go-v2/service/dynamodb/types" "github.com/stretchr/testify/assert" - cfg "github.com/vmware/vmware-go-kcl/clientlibrary/config" - par "github.com/vmware/vmware-go-kcl/clientlibrary/partition" + cfg "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" ) func TestDoesTableExist(t *testing.T) { diff --git a/clientlibrary/config/config.go b/clientlibrary/config/config.go index 35cb6ad..76293a3 100644 --- a/clientlibrary/config/config.go +++ b/clientlibrary/config/config.go @@ -33,6 +33,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ + package config import ( @@ -44,8 +45,8 @@ import ( "github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/credentials" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics" + "github.com/vmware/vmware-go-kcl-v2/logger" ) const ( diff --git a/clientlibrary/config/config_test.go b/clientlibrary/config/config_test.go index 1785e91..b53b6ac 100644 --- a/clientlibrary/config/config_test.go +++ b/clientlibrary/config/config_test.go @@ -23,7 +23,7 @@ import ( "github.com/stretchr/testify/assert" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/logger" ) func TestConfig(t *testing.T) { diff --git a/clientlibrary/config/initial-stream-pos.go b/clientlibrary/config/initial-stream-pos.go index 1cb0abd..f4f0a9e 100644 --- a/clientlibrary/config/initial-stream-pos.go +++ b/clientlibrary/config/initial-stream-pos.go @@ -33,6 +33,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ + package config import ( diff --git a/clientlibrary/config/kcl-config.go b/clientlibrary/config/kcl-config.go index ae4935c..656b044 100644 --- a/clientlibrary/config/kcl-config.go +++ b/clientlibrary/config/kcl-config.go @@ -33,6 +33,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ + package config import ( @@ -41,9 +42,9 @@ import ( "github.com/aws/aws-sdk-go-v2/credentials" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics" - "github.com/vmware/vmware-go-kcl/clientlibrary/utils" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/utils" + "github.com/vmware/vmware-go-kcl-v2/logger" ) // NewKinesisClientLibConfig creates a default KinesisClientLibConfiguration based on the required fields. diff --git a/clientlibrary/interfaces/inputs.go b/clientlibrary/interfaces/inputs.go index 2336af8..6275152 100644 --- a/clientlibrary/interfaces/inputs.go +++ b/clientlibrary/interfaces/inputs.go @@ -33,6 +33,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ + package interfaces import ( diff --git a/clientlibrary/interfaces/record-processor-checkpointer.go b/clientlibrary/interfaces/record-processor-checkpointer.go index cdb1f53..b8422ad 100644 --- a/clientlibrary/interfaces/record-processor-checkpointer.go +++ b/clientlibrary/interfaces/record-processor-checkpointer.go @@ -33,6 +33,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ + package interfaces type ( diff --git a/clientlibrary/interfaces/sequence-number.go b/clientlibrary/interfaces/sequence-number.go index 8cec8a9..aefc1f8 100644 --- a/clientlibrary/interfaces/sequence-number.go +++ b/clientlibrary/interfaces/sequence-number.go @@ -33,6 +33,7 @@ * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ + package interfaces // ExtendedSequenceNumber represents a two-part sequence number for records aggregated by the Kinesis Producer Library. diff --git a/clientlibrary/metrics/cloudwatch/cloudwatch.go b/clientlibrary/metrics/cloudwatch/cloudwatch.go index 144ce85..e8bf732 100644 --- a/clientlibrary/metrics/cloudwatch/cloudwatch.go +++ b/clientlibrary/metrics/cloudwatch/cloudwatch.go @@ -40,7 +40,7 @@ import ( cwatch "github.com/aws/aws-sdk-go-v2/service/cloudwatch" "github.com/aws/aws-sdk-go-v2/service/cloudwatch/types" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/logger" ) // DefaultCloudwatchMetricsBufferDuration Buffer metrics for at most this long before publishing to CloudWatch. diff --git a/clientlibrary/metrics/prometheus/prometheus.go b/clientlibrary/metrics/prometheus/prometheus.go index b2b4915..07a6e7e 100644 --- a/clientlibrary/metrics/prometheus/prometheus.go +++ b/clientlibrary/metrics/prometheus/prometheus.go @@ -35,7 +35,7 @@ import ( prom "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/logger" ) // MonitoringService publishes kcl metrics to Prometheus. diff --git a/clientlibrary/partition/partition.go b/clientlibrary/partition/partition.go index 5524416..6f75290 100644 --- a/clientlibrary/partition/partition.go +++ b/clientlibrary/partition/partition.go @@ -33,7 +33,7 @@ import ( "sync" "time" - "github.com/vmware/vmware-go-kcl/clientlibrary/config" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" ) type ShardStatus struct { diff --git a/clientlibrary/worker/common-shard-consumer.go b/clientlibrary/worker/common-shard-consumer.go index a638f5f..d384145 100644 --- a/clientlibrary/worker/common-shard-consumer.go +++ b/clientlibrary/worker/common-shard-consumer.go @@ -28,12 +28,12 @@ import ( "github.com/aws/aws-sdk-go-v2/service/kinesis" "github.com/aws/aws-sdk-go-v2/service/kinesis/types" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - "github.com/vmware/vmware-go-kcl/clientlibrary/config" - kcl "github.com/vmware/vmware-go-kcl/clientlibrary/interfaces" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics" - par "github.com/vmware/vmware-go-kcl/clientlibrary/partition" - deagg "github.com/vmware/vmware-go-kcl/internal/deaggregator" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + kcl "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics" + par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" + deagg "github.com/vmware/vmware-go-kcl-v2/internal/deaggregator" ) type shardConsumer interface { diff --git a/clientlibrary/worker/fan-out-shard-consumer.go b/clientlibrary/worker/fan-out-shard-consumer.go index 76827f3..ee0686f 100644 --- a/clientlibrary/worker/fan-out-shard-consumer.go +++ b/clientlibrary/worker/fan-out-shard-consumer.go @@ -29,8 +29,8 @@ import ( "github.com/aws/aws-sdk-go-v2/service/kinesis" "github.com/aws/aws-sdk-go-v2/service/kinesis/types" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - kcl "github.com/vmware/vmware-go-kcl/clientlibrary/interfaces" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + kcl "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" ) // FanOutShardConsumer is responsible for consuming data records of a (specified) shard. diff --git a/clientlibrary/worker/polling-shard-consumer.go b/clientlibrary/worker/polling-shard-consumer.go index f0a1d9e..0589a41 100644 --- a/clientlibrary/worker/polling-shard-consumer.go +++ b/clientlibrary/worker/polling-shard-consumer.go @@ -39,9 +39,9 @@ import ( "github.com/aws/aws-sdk-go-v2/service/kinesis" "github.com/aws/aws-sdk-go-v2/service/kinesis/types" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - kcl "github.com/vmware/vmware-go-kcl/clientlibrary/interfaces" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + kcl "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics" ) // PollingShardConsumer is responsible for polling data records from a (specified) shard. diff --git a/clientlibrary/worker/record-processor-checkpointer.go b/clientlibrary/worker/record-processor-checkpointer.go index c89dc4a..5544a86 100644 --- a/clientlibrary/worker/record-processor-checkpointer.go +++ b/clientlibrary/worker/record-processor-checkpointer.go @@ -23,9 +23,9 @@ package worker import ( "github.com/aws/aws-sdk-go-v2/aws" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - kcl "github.com/vmware/vmware-go-kcl/clientlibrary/interfaces" - par "github.com/vmware/vmware-go-kcl/clientlibrary/partition" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + kcl "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" + par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" ) type ( diff --git a/clientlibrary/worker/worker.go b/clientlibrary/worker/worker.go index 01db8f5..75ba41d 100644 --- a/clientlibrary/worker/worker.go +++ b/clientlibrary/worker/worker.go @@ -43,11 +43,11 @@ import ( "github.com/aws/aws-sdk-go-v2/credentials" "github.com/aws/aws-sdk-go-v2/service/kinesis" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - "github.com/vmware/vmware-go-kcl/clientlibrary/config" - kcl "github.com/vmware/vmware-go-kcl/clientlibrary/interfaces" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics" - par "github.com/vmware/vmware-go-kcl/clientlibrary/partition" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + kcl "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics" + 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 diff --git a/go.mod b/go.mod index d6133f7..dd7f2ef 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/vmware/vmware-go-kcl +module github.com/vmware/vmware-go-kcl-v2 go 1.17 diff --git a/internal/deaggregator/deaggregator.go b/internal/deaggregator/deaggregator.go index 91a5ad5..10e4dfb 100644 --- a/internal/deaggregator/deaggregator.go +++ b/internal/deaggregator/deaggregator.go @@ -10,7 +10,7 @@ import ( "github.com/aws/aws-sdk-go-v2/service/kinesis/types" "github.com/golang/protobuf/proto" - rec "github.com/vmware/vmware-go-kcl/internal/records" + rec "github.com/vmware/vmware-go-kcl-v2/internal/records" ) // KplMagicHeader Magic File Header for a KPL Aggregated Record diff --git a/internal/deaggregator/deaggregator_test.go b/internal/deaggregator/deaggregator_test.go index a933baa..3ba2793 100644 --- a/internal/deaggregator/deaggregator_test.go +++ b/internal/deaggregator/deaggregator_test.go @@ -13,8 +13,8 @@ import ( "github.com/golang/protobuf/proto" "github.com/stretchr/testify/assert" - deagg "github.com/vmware/vmware-go-kcl/internal/deaggregator" - rec "github.com/vmware/vmware-go-kcl/internal/records" + deagg "github.com/vmware/vmware-go-kcl-v2/internal/deaggregator" + rec "github.com/vmware/vmware-go-kcl-v2/internal/records" ) // Generate an aggregate record in the correct AWS-specified format diff --git a/logger/zap/zap.go b/logger/zap/zap.go index 237303e..cebb5b6 100644 --- a/logger/zap/zap.go +++ b/logger/zap/zap.go @@ -24,7 +24,7 @@ package zap import ( "os" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/logger" uzap "go.uber.org/zap" "go.uber.org/zap/zapcore" lumberjack "gopkg.in/natefinch/lumberjack.v2" diff --git a/logger/zap/zap_test.go b/logger/zap/zap_test.go index 820f31b..06f866f 100644 --- a/logger/zap/zap_test.go +++ b/logger/zap/zap_test.go @@ -4,8 +4,8 @@ import ( "testing" "github.com/stretchr/testify/assert" - "github.com/vmware/vmware-go-kcl/logger" - "github.com/vmware/vmware-go-kcl/logger/zap" + "github.com/vmware/vmware-go-kcl-v2/logger" + "github.com/vmware/vmware-go-kcl-v2/logger/zap" uzap "go.uber.org/zap" ) diff --git a/logger/zerolog/zerolog.go b/logger/zerolog/zerolog.go index 412540f..cace431 100644 --- a/logger/zerolog/zerolog.go +++ b/logger/zerolog/zerolog.go @@ -24,7 +24,7 @@ package zerolog import ( "github.com/rs/zerolog" - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/logger" "gopkg.in/natefinch/lumberjack.v2" "os" ) diff --git a/logger/zerolog/zerolog_test.go b/logger/zerolog/zerolog_test.go index 7d35aea..c231303 100644 --- a/logger/zerolog/zerolog_test.go +++ b/logger/zerolog/zerolog_test.go @@ -1,7 +1,7 @@ package zerolog import ( - "github.com/vmware/vmware-go-kcl/logger" + "github.com/vmware/vmware-go-kcl-v2/logger" "testing" ) diff --git a/test/lease_stealing_util_test.go b/test/lease_stealing_util_test.go index cbd01aa..1a85652 100644 --- a/test/lease_stealing_util_test.go +++ b/test/lease_stealing_util_test.go @@ -13,9 +13,9 @@ import ( "github.com/aws/aws-sdk-go-v2/service/kinesis" "github.com/stretchr/testify/assert" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - cfg "github.com/vmware/vmware-go-kcl/clientlibrary/config" - wk "github.com/vmware/vmware-go-kcl/clientlibrary/worker" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + cfg "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + wk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/worker" ) type LeaseStealingTest struct { diff --git a/test/logger_test.go b/test/logger_test.go index f5db877..b21dbf5 100644 --- a/test/logger_test.go +++ b/test/logger_test.go @@ -28,8 +28,8 @@ import ( "github.com/sirupsen/logrus" "go.uber.org/zap" - "github.com/vmware/vmware-go-kcl/logger" - zaplogger "github.com/vmware/vmware-go-kcl/logger/zap" + "github.com/vmware/vmware-go-kcl-v2/logger" + zaplogger "github.com/vmware/vmware-go-kcl-v2/logger/zap" ) func TestZapLoggerWithConfig(t *testing.T) { diff --git a/test/record_processor_test.go b/test/record_processor_test.go index ff4fef3..af6359b 100644 --- a/test/record_processor_test.go +++ b/test/record_processor_test.go @@ -26,7 +26,7 @@ import ( "github.com/aws/aws-sdk-go-v2/aws" "github.com/stretchr/testify/assert" - kc "github.com/vmware/vmware-go-kcl/clientlibrary/interfaces" + kc "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" ) // Record processor factory is used to create RecordProcessor diff --git a/test/record_publisher_test.go b/test/record_publisher_test.go index 5bd061a..e6c0419 100644 --- a/test/record_publisher_test.go +++ b/test/record_publisher_test.go @@ -35,8 +35,8 @@ import ( "github.com/aws/aws-sdk-go-v2/service/kinesis/types" "github.com/golang/protobuf/proto" - "github.com/vmware/vmware-go-kcl/clientlibrary/utils" - rec "github.com/vmware/vmware-go-kcl/internal/records" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/utils" + rec "github.com/vmware/vmware-go-kcl-v2/internal/records" ) const specstr = `{"name":"kube-qQyhk","networking":{"containerNetworkCidr":"10.2.0.0/16"},"orgName":"BVT-Org-cLQch","projectName":"project-tDSJd","serviceLevel":"DEVELOPER","size":{"count":1},"version":"1.8.1-4"}` diff --git a/test/worker_custom_test.go b/test/worker_custom_test.go index a513b56..5fbebf9 100644 --- a/test/worker_custom_test.go +++ b/test/worker_custom_test.go @@ -30,10 +30,10 @@ import ( log "github.com/sirupsen/logrus" "github.com/stretchr/testify/assert" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - cfg "github.com/vmware/vmware-go-kcl/clientlibrary/config" - par "github.com/vmware/vmware-go-kcl/clientlibrary/partition" - wk "github.com/vmware/vmware-go-kcl/clientlibrary/worker" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + cfg "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" + wk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/worker" ) func TestWorkerInjectCheckpointer(t *testing.T) { diff --git a/test/worker_lease_stealing_test.go b/test/worker_lease_stealing_test.go index 3742a8f..6cb83f9 100644 --- a/test/worker_lease_stealing_test.go +++ b/test/worker_lease_stealing_test.go @@ -3,10 +3,10 @@ package test import ( "testing" - chk "github.com/vmware/vmware-go-kcl/clientlibrary/checkpoint" - cfg "github.com/vmware/vmware-go-kcl/clientlibrary/config" - wk "github.com/vmware/vmware-go-kcl/clientlibrary/worker" - "github.com/vmware/vmware-go-kcl/logger" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + cfg "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + wk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/worker" + "github.com/vmware/vmware-go-kcl-v2/logger" ) func TestLeaseStealing(t *testing.T) { diff --git a/test/worker_test.go b/test/worker_test.go index 935ed45..5a87241 100644 --- a/test/worker_test.go +++ b/test/worker_test.go @@ -30,13 +30,13 @@ import ( "github.com/prometheus/common/expfmt" "github.com/stretchr/testify/assert" - cfg "github.com/vmware/vmware-go-kcl/clientlibrary/config" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics/cloudwatch" - "github.com/vmware/vmware-go-kcl/clientlibrary/metrics/prometheus" - wk "github.com/vmware/vmware-go-kcl/clientlibrary/worker" - "github.com/vmware/vmware-go-kcl/logger" - zaplogger "github.com/vmware/vmware-go-kcl/logger/zap" + cfg "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics/cloudwatch" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/metrics/prometheus" + wk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/worker" + "github.com/vmware/vmware-go-kcl-v2/logger" + zaplogger "github.com/vmware/vmware-go-kcl-v2/logger/zap" ) const (