File tree 19 files changed +46
-46
lines changed
19 files changed +46
-46
lines changed Original file line number Diff line number Diff line change @@ -89,4 +89,4 @@ settings:
89
89
- test
90
90
docker:
91
91
image: 'vmware/go-kcl-toolchain:0.1.2'
92
- src-volume: /go/src/github.com/vmware /vmware-go-kcl
92
+ src-volume: /go/src/github.com/discovery-digital /vmware-go-kcl
Original file line number Diff line number Diff line change @@ -29,7 +29,7 @@ package checkpoint
29
29
30
30
import (
31
31
"errors"
32
- par "github.com/vmware /vmware-go-kcl/clientlibrary/partition"
32
+ par "github.com/discovery-digital /vmware-go-kcl/clientlibrary/partition"
33
33
)
34
34
35
35
const (
Original file line number Diff line number Diff line change @@ -38,9 +38,9 @@ import (
38
38
"github.com/aws/aws-sdk-go/service/dynamodb"
39
39
"github.com/aws/aws-sdk-go/service/dynamodb/dynamodbiface"
40
40
41
- "github.com/vmware /vmware-go-kcl/clientlibrary/config"
42
- par "github.com/vmware /vmware-go-kcl/clientlibrary/partition"
43
- "github.com/vmware /vmware-go-kcl/logger"
41
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/config"
42
+ par "github.com/discovery-digital /vmware-go-kcl/clientlibrary/partition"
43
+ "github.com/discovery-digital /vmware-go-kcl/logger"
44
44
)
45
45
46
46
const (
Original file line number Diff line number Diff line change @@ -39,8 +39,8 @@ import (
39
39
"github.com/aws/aws-sdk-go/service/dynamodb"
40
40
"github.com/aws/aws-sdk-go/service/dynamodb/dynamodbiface"
41
41
42
- cfg "github.com/vmware /vmware-go-kcl/clientlibrary/config"
43
- par "github.com/vmware /vmware-go-kcl/clientlibrary/partition"
42
+ cfg "github.com/discovery-digital /vmware-go-kcl/clientlibrary/config"
43
+ par "github.com/discovery-digital /vmware-go-kcl/clientlibrary/partition"
44
44
)
45
45
46
46
func TestDoesTableExist (t * testing.T ) {
Original file line number Diff line number Diff line change @@ -41,8 +41,8 @@ import (
41
41
42
42
"github.com/aws/aws-sdk-go/aws"
43
43
creds "github.com/aws/aws-sdk-go/aws/credentials"
44
- "github.com/vmware /vmware-go-kcl/clientlibrary/metrics"
45
- "github.com/vmware /vmware-go-kcl/logger"
44
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/metrics"
45
+ "github.com/discovery-digital /vmware-go-kcl/logger"
46
46
)
47
47
48
48
const (
Original file line number Diff line number Diff line change 19
19
package config
20
20
21
21
import (
22
- "github.com/vmware /vmware-go-kcl/logger"
22
+ "github.com/discovery-digital /vmware-go-kcl/logger"
23
23
"testing"
24
24
25
25
"github.com/stretchr/testify/assert"
Original file line number Diff line number Diff line change @@ -37,11 +37,11 @@ import (
37
37
"log"
38
38
"time"
39
39
40
- "github.com/vmware /vmware-go-kcl/clientlibrary/metrics"
40
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/metrics"
41
41
42
42
"github.com/aws/aws-sdk-go/aws/credentials"
43
- "github.com/vmware /vmware-go-kcl/clientlibrary/utils"
44
- "github.com/vmware /vmware-go-kcl/logger"
43
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/utils"
44
+ "github.com/discovery-digital /vmware-go-kcl/logger"
45
45
)
46
46
47
47
// NewKinesisClientLibConfig creates a default KinesisClientLibConfiguration based on the required fields.
Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ import (
37
37
cwatch "github.com/aws/aws-sdk-go/service/cloudwatch"
38
38
"github.com/aws/aws-sdk-go/service/cloudwatch/cloudwatchiface"
39
39
40
- "github.com/vmware /vmware-go-kcl/logger"
40
+ "github.com/discovery-digital /vmware-go-kcl/logger"
41
41
)
42
42
43
43
// Buffer metrics for at most this long before publishing to CloudWatch.
Original file line number Diff line number Diff line change @@ -33,7 +33,7 @@ import (
33
33
prom "github.com/prometheus/client_golang/prometheus"
34
34
"github.com/prometheus/client_golang/prometheus/promhttp"
35
35
36
- "github.com/vmware /vmware-go-kcl/logger"
36
+ "github.com/discovery-digital /vmware-go-kcl/logger"
37
37
)
38
38
39
39
// MonitoringService publishes kcl metrics to Prometheus.
Original file line number Diff line number Diff line change @@ -21,9 +21,9 @@ package worker
21
21
import (
22
22
"github.com/aws/aws-sdk-go/aws"
23
23
24
- chk "github.com/vmware /vmware-go-kcl/clientlibrary/checkpoint"
25
- kcl "github.com/vmware /vmware-go-kcl/clientlibrary/interfaces"
26
- par "github.com/vmware /vmware-go-kcl/clientlibrary/partition"
24
+ chk "github.com/discovery-digital /vmware-go-kcl/clientlibrary/checkpoint"
25
+ kcl "github.com/discovery-digital /vmware-go-kcl/clientlibrary/interfaces"
26
+ par "github.com/discovery-digital /vmware-go-kcl/clientlibrary/partition"
27
27
)
28
28
29
29
type (
Original file line number Diff line number Diff line change @@ -38,11 +38,11 @@ import (
38
38
"github.com/aws/aws-sdk-go/service/kinesis/kinesisiface"
39
39
deagg "github.com/awslabs/kinesis-aggregation/go/deaggregator"
40
40
41
- chk "github.com/vmware /vmware-go-kcl/clientlibrary/checkpoint"
42
- "github.com/vmware /vmware-go-kcl/clientlibrary/config"
43
- kcl "github.com/vmware /vmware-go-kcl/clientlibrary/interfaces"
44
- "github.com/vmware /vmware-go-kcl/clientlibrary/metrics"
45
- par "github.com/vmware /vmware-go-kcl/clientlibrary/partition"
41
+ chk "github.com/discovery-digital /vmware-go-kcl/clientlibrary/checkpoint"
42
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/config"
43
+ kcl "github.com/discovery-digital /vmware-go-kcl/clientlibrary/interfaces"
44
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/metrics"
45
+ par "github.com/discovery-digital /vmware-go-kcl/clientlibrary/partition"
46
46
)
47
47
48
48
const (
Original file line number Diff line number Diff line change @@ -37,11 +37,11 @@ import (
37
37
"github.com/aws/aws-sdk-go/service/kinesis"
38
38
"github.com/aws/aws-sdk-go/service/kinesis/kinesisiface"
39
39
40
- chk "github.com/vmware /vmware-go-kcl/clientlibrary/checkpoint"
41
- "github.com/vmware /vmware-go-kcl/clientlibrary/config"
42
- kcl "github.com/vmware /vmware-go-kcl/clientlibrary/interfaces"
43
- "github.com/vmware /vmware-go-kcl/clientlibrary/metrics"
44
- par "github.com/vmware /vmware-go-kcl/clientlibrary/partition"
40
+ chk "github.com/discovery-digital /vmware-go-kcl/clientlibrary/checkpoint"
41
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/config"
42
+ kcl "github.com/discovery-digital /vmware-go-kcl/clientlibrary/interfaces"
43
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/metrics"
44
+ par "github.com/discovery-digital /vmware-go-kcl/clientlibrary/partition"
45
45
)
46
46
47
47
/**
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ package zap
24
24
import (
25
25
"os"
26
26
27
- "github.com/vmware /vmware-go-kcl/logger"
27
+ "github.com/discovery-digital /vmware-go-kcl/logger"
28
28
uzap "go.uber.org/zap"
29
29
"go.uber.org/zap/zapcore"
30
30
lumberjack "gopkg.in/natefinch/lumberjack.v2"
Original file line number Diff line number Diff line change 4
4
"testing"
5
5
6
6
"github.com/stretchr/testify/assert"
7
- "github.com/vmware /vmware-go-kcl/logger"
8
- "github.com/vmware /vmware-go-kcl/logger/zap"
7
+ "github.com/discovery-digital /vmware-go-kcl/logger"
8
+ "github.com/discovery-digital /vmware-go-kcl/logger/zap"
9
9
uzap "go.uber.org/zap"
10
10
)
11
11
Original file line number Diff line number Diff line change @@ -27,8 +27,8 @@ import (
27
27
"go.uber.org/zap"
28
28
"testing"
29
29
30
- "github.com/vmware /vmware-go-kcl/logger"
31
- zaplogger "github.com/vmware /vmware-go-kcl/logger/zap"
30
+ "github.com/discovery-digital /vmware-go-kcl/logger"
31
+ zaplogger "github.com/discovery-digital /vmware-go-kcl/logger/zap"
32
32
)
33
33
34
34
func TestZapLoggerWithConfig (t * testing.T ) {
Original file line number Diff line number Diff line change @@ -21,7 +21,7 @@ package test
21
21
import (
22
22
"github.com/aws/aws-sdk-go/aws"
23
23
"github.com/stretchr/testify/assert"
24
- kc "github.com/vmware /vmware-go-kcl/clientlibrary/interfaces"
24
+ kc "github.com/discovery-digital /vmware-go-kcl/clientlibrary/interfaces"
25
25
"testing"
26
26
)
27
27
Original file line number Diff line number Diff line change @@ -28,7 +28,7 @@ import (
28
28
"github.com/aws/aws-sdk-go/service/kinesis/kinesisiface"
29
29
rec "github.com/awslabs/kinesis-aggregation/go/records"
30
30
"github.com/golang/protobuf/proto"
31
- "github.com/vmware /vmware-go-kcl/clientlibrary/utils"
31
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/utils"
32
32
33
33
"testing"
34
34
)
Original file line number Diff line number Diff line change @@ -31,10 +31,10 @@ import (
31
31
log "github.com/sirupsen/logrus"
32
32
33
33
"github.com/stretchr/testify/assert"
34
- chk "github.com/vmware /vmware-go-kcl/clientlibrary/checkpoint"
35
- cfg "github.com/vmware /vmware-go-kcl/clientlibrary/config"
36
- par "github.com/vmware /vmware-go-kcl/clientlibrary/partition"
37
- wk "github.com/vmware /vmware-go-kcl/clientlibrary/worker"
34
+ chk "github.com/discovery-digital /vmware-go-kcl/clientlibrary/checkpoint"
35
+ cfg "github.com/discovery-digital /vmware-go-kcl/clientlibrary/config"
36
+ par "github.com/discovery-digital /vmware-go-kcl/clientlibrary/partition"
37
+ wk "github.com/discovery-digital /vmware-go-kcl/clientlibrary/worker"
38
38
)
39
39
40
40
func TestWorkerInjectCheckpointer (t * testing.T ) {
Original file line number Diff line number Diff line change @@ -31,13 +31,13 @@ import (
31
31
"github.com/aws/aws-sdk-go/aws/session"
32
32
"github.com/prometheus/common/expfmt"
33
33
"github.com/stretchr/testify/assert"
34
- cfg "github.com/vmware /vmware-go-kcl/clientlibrary/config"
35
- "github.com/vmware /vmware-go-kcl/clientlibrary/metrics"
36
- "github.com/vmware /vmware-go-kcl/clientlibrary/metrics/cloudwatch"
37
- "github.com/vmware /vmware-go-kcl/clientlibrary/metrics/prometheus"
38
- wk "github.com/vmware /vmware-go-kcl/clientlibrary/worker"
39
- "github.com/vmware /vmware-go-kcl/logger"
40
- zaplogger "github.com/vmware /vmware-go-kcl/logger/zap"
34
+ cfg "github.com/discovery-digital /vmware-go-kcl/clientlibrary/config"
35
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/metrics"
36
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/metrics/cloudwatch"
37
+ "github.com/discovery-digital /vmware-go-kcl/clientlibrary/metrics/prometheus"
38
+ wk "github.com/discovery-digital /vmware-go-kcl/clientlibrary/worker"
39
+ "github.com/discovery-digital /vmware-go-kcl/logger"
40
+ zaplogger "github.com/discovery-digital /vmware-go-kcl/logger/zap"
41
41
)
42
42
43
43
const (
You can’t perform that action at this time.
0 commit comments