add test log

pankildaru · pankildaru · commit d224a19d2597 · 2022-11-10T07:59:39.000-08:00
diff --git a/common/options/listeneropts/options.go b/common/options/listeneropts/options.go
@@ -3,14 +3,14 @@ package listeneropts
 import (
 	"errors"
 	"fmt"
-	"github.com/Azure/go-shuttle/common"
+	"github.com/pdaru/go-shuttle/common"
 	"reflect"
 	"time"
 
 	"github.com/Azure/azure-service-bus-go"
 	"github.com/Azure/go-autorest/autorest/adal"
-	"github.com/Azure/go-shuttle/internal/aad"
-	sbinternal "github.com/Azure/go-shuttle/internal/servicebus"
+	"github.com/pdaru/go-shuttle/internal/aad"
+	sbinternal "github.com/pdaru/go-shuttle/internal/servicebus"
 )
 
 // Option provides structure for configuring when starting to listen to a specified topic
diff --git a/common/options/publisheropts/options.go b/common/options/publisheropts/options.go
@@ -7,10 +7,10 @@ import (
 	servicebus "github.com/Azure/azure-service-bus-go"
 	"github.com/Azure/go-autorest/autorest/adal"
 
-	"github.com/Azure/go-shuttle/common"
-	"github.com/Azure/go-shuttle/internal/aad"
-	sbinternal "github.com/Azure/go-shuttle/internal/servicebus"
-	"github.com/Azure/go-shuttle/marshal"
+	"github.com/pdaru/go-shuttle/common"
+	"github.com/pdaru/go-shuttle/internal/aad"
+	sbinternal "github.com/pdaru/go-shuttle/internal/servicebus"
+	"github.com/pdaru/go-shuttle/marshal"
 )
 
 // ManagementOption provides structure for configuring a new Publisher
diff --git a/common/types.go b/common/types.go
@@ -5,7 +5,7 @@ import (
 
 	servicebus "github.com/Azure/azure-service-bus-go"
 
-	"github.com/Azure/go-shuttle/marshal"
+	"github.com/pdaru/go-shuttle/marshal"
 )
 
 var _ Listener = &ListenerSettings{}
diff --git a/go.mod b/go.mod
@@ -1,4 +1,4 @@
-module github.com/Azure/go-shuttle
+module github.com/pdaru/go-shuttle
 
 go 1.14
 
diff --git a/handlers/concurrent.go b/handlers/concurrent.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/prometheus/listener"
+	"github.com/pdaru/go-shuttle/prometheus/listener"
 )
 
 var _ servicebus.Handler = (*concurrent)(nil)
diff --git a/handlers/lockrenewer.go b/handlers/lockrenewer.go
@@ -7,9 +7,9 @@ import (
 	"time"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/prometheus/listener"
-	"github.com/Azure/go-shuttle/tracing"
 	"github.com/devigned/tab"
+	"github.com/pdaru/go-shuttle/prometheus/listener"
+	"github.com/pdaru/go-shuttle/tracing"
 )
 
 type EntityInfoProvider interface {
diff --git a/handlers/lockrenewer_test.go b/handlers/lockrenewer_test.go
@@ -6,8 +6,8 @@ import (
 	"time"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/handlers"
-	"github.com/Azure/go-shuttle/prometheus/listener"
+	"github.com/pdaru/go-shuttle/handlers"
+	"github.com/pdaru/go-shuttle/prometheus/listener"
 	prom "github.com/prometheus/client_golang/prometheus"
 	"github.com/stretchr/testify/assert"
 )
diff --git a/handlers/messagecontext_test.go b/handlers/messagecontext_test.go
@@ -6,7 +6,7 @@ import (
 	"time"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/handlers"
+	"github.com/pdaru/go-shuttle/handlers"
 	"github.com/stretchr/testify/assert"
 )
 
diff --git a/handlers/shuttleadapter.go b/handlers/shuttleadapter.go
@@ -4,8 +4,8 @@ import (
 	"context"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/message"
 	"github.com/devigned/tab"
+	"github.com/pdaru/go-shuttle/message"
 )
 
 var _ servicebus.Handler = (*shuttleAdapter)(nil)
diff --git a/integration/concurrentcreate_topic_test.go b/integration/concurrentcreate_topic_test.go
@@ -1,3 +1,4 @@
+//go:build integration
 // +build integration
 
 package integration
@@ -8,11 +9,11 @@ import (
 	"sync"
 	"time"
 
-	"github.com/Azure/go-shuttle/topic"
-	"github.com/Azure/go-shuttle/topic/listener"
+	"github.com/pdaru/go-shuttle/topic"
+	"github.com/pdaru/go-shuttle/topic/listener"
 	"github.com/stretchr/testify/require"
 
-	"github.com/Azure/go-shuttle/message"
+	"github.com/pdaru/go-shuttle/message"
 )
 
 func (suite *serviceBusTopicSuite) TestCreatePublisherConcurrently() {
diff --git a/integration/issue_topic_test.go b/integration/issue_topic_test.go
@@ -1,3 +1,4 @@
+//go:build integration
 // +build integration
 
 package integration
@@ -9,12 +10,12 @@ import (
 	"testing"
 	"time"
 
-	"github.com/Azure/go-shuttle/topic"
-	"github.com/Azure/go-shuttle/topic/listener"
+	"github.com/pdaru/go-shuttle/topic"
+	"github.com/pdaru/go-shuttle/topic/listener"
 	"github.com/stretchr/testify/require"
 
-	"github.com/Azure/go-shuttle/message"
 	"github.com/devigned/tab"
+	"github.com/pdaru/go-shuttle/message"
 	"github.com/stretchr/testify/assert"
 )
 
diff --git a/integration/listener_queue_test.go b/integration/listener_queue_test.go
@@ -1,3 +1,4 @@
+//go:build integration
 // +build integration
 
 package integration
@@ -6,7 +7,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/Azure/go-shuttle/queue"
+	"github.com/pdaru/go-shuttle/queue"
 )
 
 // TestCreateNewListenerFromConnectionString tests the creation of a listener with a connection string
diff --git a/integration/listener_topic_test.go b/integration/listener_topic_test.go
@@ -1,16 +1,17 @@
+//go:build integration
 // +build integration
 
 package integration
 
 import (
 	"context"
-	"github.com/Azure/go-shuttle/topic"
-	"github.com/Azure/go-shuttle/topic/listener"
+	"github.com/pdaru/go-shuttle/topic"
+	"github.com/pdaru/go-shuttle/topic/listener"
 	"strings"
 	"time"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/message"
+	"github.com/pdaru/go-shuttle/message"
 )
 
 // TestCreateNewListenerFromConnectionString tests the creation of a listener with a connection string
diff --git a/integration/protomsg/Makefile b/integration/protomsg/Makefile
@@ -1,3 +1,3 @@
 
 all:
-	@protoc ./message.proto --go_opt=Mmessage.proto=github.com/Azure/go-shuttle/integration --go_opt=paths=source_relative --go_out .
+	@protoc ./message.proto --go_opt=Mmessage.proto=github.com/pdaru/go-shuttle/integration --go_opt=paths=source_relative --go_out .
diff --git a/integration/protomsg/message.proto b/integration/protomsg/message.proto
@@ -1,5 +1,5 @@
 syntax = "proto3";
-option go_package = "github.com/Azure/go-shuttle/integration/protomsg";
+option go_package = "github.com/pdaru/go-shuttle/integration/protomsg";
 
 package protomsg;
 
diff --git a/integration/publisher_queue_test.go b/integration/publisher_queue_test.go
@@ -9,8 +9,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/Azure/go-shuttle/queue"
-	"github.com/Azure/go-shuttle/queue/publisher"
+	"github.com/pdaru/go-shuttle/queue"
+	"github.com/pdaru/go-shuttle/queue/publisher"
 	"github.com/stretchr/testify/require"
 )
 
diff --git a/integration/publisher_topic_test.go b/integration/publisher_topic_test.go
@@ -1,3 +1,4 @@
+//go:build integration
 // +build integration
 
 package integration
@@ -8,8 +9,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/Azure/go-shuttle/topic"
-	"github.com/Azure/go-shuttle/topic/publisher"
+	"github.com/pdaru/go-shuttle/topic"
+	"github.com/pdaru/go-shuttle/topic/publisher"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
diff --git a/integration/pubsub_queue_test.go b/integration/pubsub_queue_test.go
@@ -13,14 +13,14 @@ import (
 	"github.com/devigned/tab"
 	"github.com/stretchr/testify/assert"
 
-	"github.com/Azure/go-shuttle/common/options/publisheropts"
-	"github.com/Azure/go-shuttle/integration/protomsg"
-	"github.com/Azure/go-shuttle/internal/reflection"
-	"github.com/Azure/go-shuttle/marshal"
-	"github.com/Azure/go-shuttle/message"
-	"github.com/Azure/go-shuttle/queue"
-	"github.com/Azure/go-shuttle/queue/listener"
-	"github.com/Azure/go-shuttle/queue/publisher"
+	"github.com/pdaru/go-shuttle/common/options/publisheropts"
+	"github.com/pdaru/go-shuttle/integration/protomsg"
+	"github.com/pdaru/go-shuttle/internal/reflection"
+	"github.com/pdaru/go-shuttle/marshal"
+	"github.com/pdaru/go-shuttle/message"
+	"github.com/pdaru/go-shuttle/queue"
+	"github.com/pdaru/go-shuttle/queue/listener"
+	"github.com/pdaru/go-shuttle/queue/publisher"
 )
 
 // TestPublishAndListenWithConnectionStringUsingDefault tests both the publisher and listener with default configurations
diff --git a/integration/pubsub_topic_test.go b/integration/pubsub_topic_test.go
@@ -15,11 +15,11 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"github.com/Azure/go-shuttle/internal/reflection"
-	"github.com/Azure/go-shuttle/message"
-	"github.com/Azure/go-shuttle/topic"
-	"github.com/Azure/go-shuttle/topic/listener"
-	"github.com/Azure/go-shuttle/topic/publisher"
+	"github.com/pdaru/go-shuttle/internal/reflection"
+	"github.com/pdaru/go-shuttle/message"
+	"github.com/pdaru/go-shuttle/topic"
+	"github.com/pdaru/go-shuttle/topic/listener"
+	"github.com/pdaru/go-shuttle/topic/publisher"
 )
 
 // TestPublishAndListenWithConnectionStringUsingDefault tests both the publisher and listener with default configurations
diff --git a/integration/suite_queue_test.go b/integration/suite_queue_test.go
@@ -11,9 +11,9 @@ import (
 	"github.com/Azure/go-autorest/autorest/adal"
 	"github.com/stretchr/testify/suite"
 
-	"github.com/Azure/go-shuttle/internal/test"
-	"github.com/Azure/go-shuttle/queue/listener"
-	"github.com/Azure/go-shuttle/queue/publisher"
+	"github.com/pdaru/go-shuttle/internal/test"
+	"github.com/pdaru/go-shuttle/queue/listener"
+	"github.com/pdaru/go-shuttle/queue/publisher"
 )
 
 type serviceBusQueueSuite struct {
diff --git a/integration/suite_topic_test.go b/integration/suite_topic_test.go
@@ -1,3 +1,4 @@
+//go:build integration
 // +build integration
 
 package integration
@@ -9,11 +10,11 @@ import (
 	"testing"
 	"time"
 
-	"github.com/Azure/go-shuttle/topic/listener"
-	"github.com/Azure/go-shuttle/topic/publisher"
+	"github.com/pdaru/go-shuttle/topic/listener"
+	"github.com/pdaru/go-shuttle/topic/publisher"
 
 	"github.com/Azure/go-autorest/autorest/adal"
-	"github.com/Azure/go-shuttle/internal/test"
+	"github.com/pdaru/go-shuttle/internal/test"
 	"github.com/stretchr/testify/suite"
 )
 
diff --git a/internal/servicebus/namespace.go b/internal/servicebus/namespace.go
@@ -7,7 +7,7 @@ import (
 	"github.com/Azure/azure-amqp-common-go/v3/auth"
 	servicebussdk "github.com/Azure/azure-service-bus-go"
 
-	"github.com/Azure/go-shuttle/internal/aad"
+	"github.com/pdaru/go-shuttle/internal/aad"
 )
 
 const (
diff --git a/listener/alias.go b/listener/alias.go
@@ -5,7 +5,7 @@ import (
 
 	servicebus "github.com/Azure/azure-service-bus-go"
 	"github.com/Azure/go-autorest/autorest/adal"
-	topic "github.com/Azure/go-shuttle/topic/listener"
+	topic "github.com/pdaru/go-shuttle/topic/listener"
 )
 
 // Deprecated: use topic package
@@ -90,4 +90,4 @@ func WithFilterDescriber(filterName string, filter servicebus.FilterDescriber) M
 // Deprecated: use topic package
 func WithTypeFilter(event interface{}) ManagementOption {
 	return topic.WithTypeFilter(event)
-}
+}
diff --git a/marshal/types_test.go b/marshal/types_test.go
@@ -3,7 +3,7 @@ package marshal_test
 import (
 	"testing"
 
-	"github.com/Azure/go-shuttle/marshal"
+	"github.com/pdaru/go-shuttle/marshal"
 )
 
 type customMarshaller struct {
diff --git a/message/abandon.go b/message/abandon.go
@@ -4,7 +4,7 @@ import (
 	"context"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/tracing"
+	"github.com/pdaru/go-shuttle/tracing"
 )
 
 // Abandon stops processing the message and releases the lock on it.
diff --git a/message/complete.go b/message/complete.go
@@ -4,7 +4,7 @@ import (
 	"context"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/tracing"
+	"github.com/pdaru/go-shuttle/tracing"
 )
 
 // Complete will notify Azure Service Bus that the message was successfully handled and should be deleted from the queue
diff --git a/message/deadletter.go b/message/deadletter.go
@@ -4,7 +4,7 @@ import (
 	"context"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/tracing"
+	"github.com/pdaru/go-shuttle/tracing"
 )
 
 // DeadLetter will notify Azure Service Bus that the message will be sent to the deadletter queue
diff --git a/message/error.go b/message/error.go
@@ -6,7 +6,7 @@ import (
 
 	servicebus "github.com/Azure/azure-service-bus-go"
 	"github.com/Azure/go-amqp"
-	"github.com/Azure/go-shuttle/tracing"
+	"github.com/pdaru/go-shuttle/tracing"
 )
 
 // Error is a wrapper around Abandon() that allows to trace the error before abandoning the message
diff --git a/message/handler.go b/message/handler.go
@@ -4,7 +4,7 @@ import (
 	"context"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/tracing"
+	"github.com/pdaru/go-shuttle/tracing"
 )
 
 // HandleFunc is a func to handle the message received from a subscription
diff --git a/message/handler_test.go b/message/handler_test.go
@@ -11,7 +11,7 @@ import (
 	. "github.com/onsi/gomega"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/message"
+	"github.com/pdaru/go-shuttle/message"
 )
 
 var completeHandler = message.HandleFunc(func(ctx context.Context, m *message.Message) message.Handler {
diff --git a/message/message.go b/message/message.go
@@ -6,7 +6,7 @@ import (
 
 	servicebus "github.com/Azure/azure-service-bus-go"
 
-	"github.com/Azure/go-shuttle/marshal"
+	"github.com/pdaru/go-shuttle/marshal"
 )
 
 // Message is the wrapping type of service bus message with a type
diff --git a/message/retrylater.go b/message/retrylater.go
@@ -5,7 +5,7 @@ import (
 	"time"
 
 	servicebus "github.com/Azure/azure-service-bus-go"
-	"github.com/Azure/go-shuttle/tracing"
+	"github.com/pdaru/go-shuttle/tracing"
 	"github.com/pkg/errors"
 )
 
diff --git a/prometheus/register.go b/prometheus/register.go
diff --git a/publisher/alias.go b/publisher/alias.go
diff --git a/publisher/queue/alias.go b/publisher/queue/alias.go
diff --git a/publisher/topic/alias.go b/publisher/topic/alias.go
diff --git a/queue/listener/listener.go b/queue/listener/listener.go
diff --git a/queue/listener/options.go b/queue/listener/options.go
diff --git a/queue/publisher/options.go b/queue/publisher/options.go
diff --git a/queue/publisher/publisher.go b/queue/publisher/publisher.go
diff --git a/queue/queue.go b/queue/queue.go
diff --git a/topic/listener/listener.go b/topic/listener/listener.go
diff --git a/topic/listener/options.go b/topic/listener/options.go
diff --git a/topic/publisher/options.go b/topic/publisher/options.go
diff --git a/topic/publisher/publisher.go b/topic/publisher/publisher.go
diff --git a/topic/topic.go b/topic/topic.go

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@ import (`
`5`	`5`
`6`	`6`	`servicebus "github.com/Azure/azure-service-bus-go"`
`7`	`7`
`8`		`- "github.com/Azure/go-shuttle/marshal"`
	`8`	`+ "github.com/pdaru/go-shuttle/marshal"`
`9`	`9`	`)`
`10`	`10`
`11`	`11`	`var _ Listener = &ListenerSettings{}`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-module github.com/Azure/go-shuttle`
	`1`	`+module github.com/pdaru/go-shuttle`
`2`	`2`
`3`	`3`	`go 1.14`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@ import (`
`5`	`5`	`"fmt"`
`6`	`6`
`7`	`7`	`servicebus "github.com/Azure/azure-service-bus-go"`
`8`		`- "github.com/Azure/go-shuttle/prometheus/listener"`
	`8`	`+ "github.com/pdaru/go-shuttle/prometheus/listener"`
`9`	`9`	`)`
`10`	`10`
`11`	`11`	`var _ servicebus.Handler = (*concurrent)(nil)`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,7 @@ import (`
`6`	`6`	`"time"`
`7`	`7`
`8`	`8`	`servicebus "github.com/Azure/azure-service-bus-go"`
`9`		`- "github.com/Azure/go-shuttle/handlers"`
	`9`	`+ "github.com/pdaru/go-shuttle/handlers"`
`10`	`10`	`"github.com/stretchr/testify/assert"`
`11`	`11`	`)`
`12`	`12`
Original file line number	Diff line number	Diff line change
`@@ -4,8 +4,8 @@ import (`
`4`	`4`	`"context"`
`5`	`5`
`6`	`6`	`servicebus "github.com/Azure/azure-service-bus-go"`
`7`		`- "github.com/Azure/go-shuttle/message"`
`8`	`7`	`"github.com/devigned/tab"`
	`8`	`+ "github.com/pdaru/go-shuttle/message"`
`9`	`9`	`)`
`10`	`10`
`11`	`11`	`var _ servicebus.Handler = (*shuttleAdapter)(nil)`