diff --git a/README.md b/README.md index b61c0ac..c4aa9e6 100644 --- a/README.md +++ b/README.md @@ -1,9 +1,9 @@ # VMWare Go KCL v2 ![technology Go](https://img.shields.io/badge/technology-go-blue.svg) -[![Go Report Card](https://goreportcard.com/badge/github.com/magiusdarrigo/vmware-go-kcl-v2)](https://goreportcard.com/report/github.com/magiusdarrigo/vmware-go-kcl-v2) +[![Go Report Card](https://goreportcard.com/badge/github.com/vmware/vmware-go-kcl-v2)](https://goreportcard.com/report/github.com/vmware/vmware-go-kcl-v2) [![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT) -[![vmware-go-kcl-v2](https://github.com/magiusdarrigo/vmware-go-kcl-v2/actions/workflows/vmware-go-kcl-v2-ci.yml/badge.svg)](https://github.com/magiusdarrigo/vmware-go-kcl-v2/actions/workflows/vmware-go-kcl-v2-ci.yml) +[![vmware-go-kcl-v2](https://github.com/vmware/vmware-go-kcl-v2/actions/workflows/vmware-go-kcl-v2-ci.yml/badge.svg)](https://github.com/vmware/vmware-go-kcl-v2/actions/workflows/vmware-go-kcl-v2-ci.yml) ## Overview @@ -11,12 +11,12 @@ VMware-Go-KCL-V2 is a native open-source Go library for Amazon Kinesis Data Stre 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-v2](https://github.com/magiusdarrigo/vmware-go-kcl-v2) is a VMWare originated open-source project for AWS Kinesis +[vmware-go-kcl-v2](https://github.com/vmware/vmware-go-kcl-v2) 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-v2](https://github.com/magiusdarrigo/vmware-go-kcl-v2) has got +[vmware-go-kcl-v2](https://github.com/vmware/vmware-go-kcl-v2) 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/magiusdarrigo/vmware-go-kcl-v2/graphs/contributors) from the industry. +and [contributions](https://github.com/vmware/vmware-go-kcl-v2/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). diff --git a/clientlibrary/checkpoint/checkpointer.go b/clientlibrary/checkpoint/checkpointer.go index 1a31e84..c24f469 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: // @@ -33,7 +33,7 @@ import ( "errors" "fmt" - par "github.com/magiusdarrigo/vmware-go-kcl-v2/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 ccf77c9..f64e630 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: // @@ -41,9 +41,9 @@ import ( "github.com/aws/aws-sdk-go-v2/service/dynamodb" "github.com/aws/aws-sdk-go-v2/service/dynamodb/types" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - par "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/partition" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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 4c4f09b..4aecafb 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/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - par "github.com/magiusdarrigo/vmware-go-kcl-v2/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 5727845..5b45678 100644 --- a/clientlibrary/config/config.go +++ b/clientlibrary/config/config.go @@ -44,8 +44,8 @@ import ( "github.com/aws/aws-sdk-go-v2/aws" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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 313b6eb..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/magiusdarrigo/vmware-go-kcl-v2/logger" + "github.com/vmware/vmware-go-kcl-v2/logger" ) func TestConfig(t *testing.T) { diff --git a/clientlibrary/config/kcl-config.go b/clientlibrary/config/kcl-config.go index a7408b6..135f3fa 100644 --- a/clientlibrary/config/kcl-config.go +++ b/clientlibrary/config/kcl-config.go @@ -42,9 +42,9 @@ import ( "github.com/aws/aws-sdk-go-v2/aws" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/utils" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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/metrics/cloudwatch/cloudwatch.go b/clientlibrary/metrics/cloudwatch/cloudwatch.go index c7209fd..1383bbb 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: // @@ -38,7 +38,7 @@ import ( cwatch "github.com/aws/aws-sdk-go-v2/service/cloudwatch" "github.com/aws/aws-sdk-go-v2/service/cloudwatch/types" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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 9ddd2c2..07a6e7e 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: // @@ -35,7 +35,7 @@ import ( prom "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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 e9f8345..6f75290 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: // @@ -33,7 +33,7 @@ import ( "sync" "time" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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 5e6c816..32b91b1 100644 --- a/clientlibrary/worker/common-shard-consumer.go +++ b/clientlibrary/worker/common-shard-consumer.go @@ -29,11 +29,11 @@ import ( "github.com/aws/aws-sdk-go-v2/service/kinesis/types" deagg "github.com/awslabs/kinesis-aggregation/go/v2/deaggregator" - chk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - kcl "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/interfaces" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics" - par "github.com/magiusdarrigo/vmware-go-kcl-v2/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" ) type shardConsumer interface { diff --git a/clientlibrary/worker/fan-out-shard-consumer.go b/clientlibrary/worker/fan-out-shard-consumer.go index 1d1596f..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/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" - kcl "github.com/magiusdarrigo/vmware-go-kcl-v2/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 32703f7..0589a41 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: // @@ -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/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" - kcl "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/interfaces" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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 5757e9c..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/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" - kcl "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/interfaces" - par "github.com/magiusdarrigo/vmware-go-kcl-v2/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 63f8fef..7807edd 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: // @@ -42,16 +42,16 @@ import ( awsConfig "github.com/aws/aws-sdk-go-v2/config" "github.com/aws/aws-sdk-go-v2/service/kinesis" - chk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - kcl "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/interfaces" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics" - par "github.com/magiusdarrigo/vmware-go-kcl-v2/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 -// 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/go.mod b/go.mod index 500f60c..9a56ba8 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/magiusdarrigo/vmware-go-kcl-v2 +module github.com/vmware/vmware-go-kcl-v2 go 1.17 diff --git a/logger/zap/zap.go b/logger/zap/zap.go index d54b2b6..cebb5b6 100644 --- a/logger/zap/zap.go +++ b/logger/zap/zap.go @@ -24,7 +24,7 @@ package zap import ( "os" - "github.com/magiusdarrigo/vmware-go-kcl-v2/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" @@ -44,6 +44,7 @@ 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, diff --git a/logger/zap/zap_test.go b/logger/zap/zap_test.go index 865d2bf..06f866f 100644 --- a/logger/zap/zap_test.go +++ b/logger/zap/zap_test.go @@ -3,9 +3,9 @@ package zap_test import ( "testing" - "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" - "github.com/magiusdarrigo/vmware-go-kcl-v2/logger/zap" "github.com/stretchr/testify/assert" + "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 4a3e2eb..cace431 100644 --- a/logger/zerolog/zerolog.go +++ b/logger/zerolog/zerolog.go @@ -23,8 +23,8 @@ package zerolog import ( - "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" "github.com/rs/zerolog" + "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 cd85f71..c231303 100644 --- a/logger/zerolog/zerolog_test.go +++ b/logger/zerolog/zerolog_test.go @@ -1,7 +1,7 @@ package zerolog import ( - "github.com/magiusdarrigo/vmware-go-kcl-v2/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 1c8f443..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/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" - cfg "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - wk "github.com/magiusdarrigo/vmware-go-kcl-v2/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 1c0794e..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/magiusdarrigo/vmware-go-kcl-v2/logger" - zaplogger "github.com/magiusdarrigo/vmware-go-kcl-v2/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 3eb274a..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/magiusdarrigo/vmware-go-kcl-v2/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 88f5289..cfd142b 100644 --- a/test/record_publisher_test.go +++ b/test/record_publisher_test.go @@ -35,7 +35,7 @@ import ( rec "github.com/awslabs/kinesis-aggregation/go/v2/records" "github.com/golang/protobuf/proto" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/utils" + "github.com/vmware/vmware-go-kcl-v2/clientlibrary/utils" ) 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 2671a67..ffa6bba 100644 --- a/test/worker_custom_test.go +++ b/test/worker_custom_test.go @@ -20,7 +20,7 @@ package test import ( "context" - chk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" "os" "sync" "testing" @@ -31,9 +31,9 @@ import ( log "github.com/sirupsen/logrus" "github.com/stretchr/testify/assert" - cfg "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - par "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/partition" - wk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/worker" + 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 f1b1c0a..6d03aeb 100644 --- a/test/worker_lease_stealing_test.go +++ b/test/worker_lease_stealing_test.go @@ -1,12 +1,12 @@ package test import ( - chk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" + chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" "testing" - cfg "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - wk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/worker" - "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" + 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 a3ee519..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/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics/cloudwatch" - "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics/prometheus" - wk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/worker" - "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" - zaplogger "github.com/magiusdarrigo/vmware-go-kcl-v2/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 (