diff --git a/README.md b/README.md index c4aa9e6..b61c0ac 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/vmware/vmware-go-kcl-v2)](https://goreportcard.com/report/github.com/vmware/vmware-go-kcl-v2) +[![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) [![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT) -[![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) +[![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) ## 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/vmware/vmware-go-kcl-v2) is a VMWare originated open-source project for AWS Kinesis +[vmware-go-kcl-v2](https://github.com/magiusdarrigo/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/vmware/vmware-go-kcl-v2) has got +[vmware-go-kcl-v2](https://github.com/magiusdarrigo/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/vmware/vmware-go-kcl-v2/graphs/contributors) from the industry. +and [contributions](https://github.com/magiusdarrigo/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 c24f469..1a31e84 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/vmware/vmware-go-kcl-v2/clientlibrary/partition" + par "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/partition" ) const ( diff --git a/clientlibrary/checkpoint/dynamodb-checkpointer.go b/clientlibrary/checkpoint/dynamodb-checkpointer.go index f64e630..ccf77c9 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/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" + "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" ) const ( diff --git a/clientlibrary/checkpoint/dynamodb-checkpointer_test.go b/clientlibrary/checkpoint/dynamodb-checkpointer_test.go index 4aecafb..4c4f09b 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-v2/clientlibrary/config" - par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" + cfg "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/config" + par "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/partition" ) func TestDoesTableExist(t *testing.T) { diff --git a/clientlibrary/config/config.go b/clientlibrary/config/config.go index 5b45678..5727845 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/vmware/vmware-go-kcl-v2/clientlibrary/metrics" - "github.com/vmware/vmware-go-kcl-v2/logger" + "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/metrics" + "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" ) const ( diff --git a/clientlibrary/config/config_test.go b/clientlibrary/config/config_test.go index b53b6ac..313b6eb 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-v2/logger" + "github.com/magiusdarrigo/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 135f3fa..a7408b6 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/vmware/vmware-go-kcl-v2/clientlibrary/metrics" - "github.com/vmware/vmware-go-kcl-v2/clientlibrary/utils" - "github.com/vmware/vmware-go-kcl-v2/logger" + "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" ) // 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 1383bbb..c7209fd 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/vmware/vmware-go-kcl-v2/logger" + "github.com/magiusdarrigo/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 07a6e7e..9ddd2c2 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/vmware/vmware-go-kcl-v2/logger" + "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" ) // MonitoringService publishes kcl metrics to Prometheus. diff --git a/clientlibrary/partition/partition.go b/clientlibrary/partition/partition.go index 6f75290..e9f8345 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/vmware/vmware-go-kcl-v2/clientlibrary/config" + "github.com/magiusdarrigo/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 32b91b1..5e6c816 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/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" + 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" ) type shardConsumer interface { diff --git a/clientlibrary/worker/fan-out-shard-consumer.go b/clientlibrary/worker/fan-out-shard-consumer.go index ee0686f..1d1596f 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-v2/clientlibrary/checkpoint" - kcl "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" + chk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" + kcl "github.com/magiusdarrigo/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 0589a41..32703f7 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/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" + 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" ) // 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 5544a86..5757e9c 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-v2/clientlibrary/checkpoint" - kcl "github.com/vmware/vmware-go-kcl-v2/clientlibrary/interfaces" - par "github.com/vmware/vmware-go-kcl-v2/clientlibrary/partition" + 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" ) type ( diff --git a/clientlibrary/worker/worker.go b/clientlibrary/worker/worker.go index 7807edd..63f8fef 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/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" + 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" ) -//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 074a734..c597f40 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/vmware/vmware-go-kcl-v2 +module github.com/magiusdarrigo/vmware-go-kcl-v2 go 1.17 diff --git a/logger/zap/zap.go b/logger/zap/zap.go index cebb5b6..d54b2b6 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-v2/logger" + "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" uzap "go.uber.org/zap" "go.uber.org/zap/zapcore" lumberjack "gopkg.in/natefinch/lumberjack.v2" @@ -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, diff --git a/logger/zap/zap_test.go b/logger/zap/zap_test.go index 06f866f..865d2bf 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 cace431..4a3e2eb 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 c231303..cd85f71 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-v2/logger" + "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" "testing" ) diff --git a/test/lease_stealing_util_test.go b/test/lease_stealing_util_test.go index 1a85652..1c8f443 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-v2/clientlibrary/checkpoint" - cfg "github.com/vmware/vmware-go-kcl-v2/clientlibrary/config" - wk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/worker" + 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" ) type LeaseStealingTest struct { diff --git a/test/logger_test.go b/test/logger_test.go index b21dbf5..1c0794e 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-v2/logger" - zaplogger "github.com/vmware/vmware-go-kcl-v2/logger/zap" + "github.com/magiusdarrigo/vmware-go-kcl-v2/logger" + zaplogger "github.com/magiusdarrigo/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 af6359b..3eb274a 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-v2/clientlibrary/interfaces" + kc "github.com/magiusdarrigo/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 cfd142b..88f5289 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/vmware/vmware-go-kcl-v2/clientlibrary/utils" + "github.com/magiusdarrigo/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 ffa6bba..2671a67 100644 --- a/test/worker_custom_test.go +++ b/test/worker_custom_test.go @@ -20,7 +20,7 @@ package test import ( "context" - chk "github.com/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + chk "github.com/magiusdarrigo/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/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" + 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" ) func TestWorkerInjectCheckpointer(t *testing.T) { diff --git a/test/worker_lease_stealing_test.go b/test/worker_lease_stealing_test.go index 6d03aeb..f1b1c0a 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/vmware/vmware-go-kcl-v2/clientlibrary/checkpoint" + chk "github.com/magiusdarrigo/vmware-go-kcl-v2/clientlibrary/checkpoint" "testing" - 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" + 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" ) func TestLeaseStealing(t *testing.T) { diff --git a/test/worker_test.go b/test/worker_test.go index 5a87241..a3ee519 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-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" + 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" ) const (