Skip to content

Commit

Permalink
add test log
Browse files Browse the repository at this point in the history
  • Loading branch information
pankildaru committed Nov 10, 2022
1 parent 86661de commit d224a19
Show file tree
Hide file tree
Showing 46 changed files with 108 additions and 102 deletions.
6 changes: 3 additions & 3 deletions common/options/listeneropts/options.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
8 changes: 4 additions & 4 deletions common/options/publisheropts/options.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion common/types.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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{}
Expand Down
2 changes: 1 addition & 1 deletion go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/Azure/go-shuttle
module github.com/pdaru/go-shuttle

go 1.14

Expand Down
2 changes: 1 addition & 1 deletion handlers/concurrent.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
4 changes: 2 additions & 2 deletions handlers/lockrenewer.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
4 changes: 2 additions & 2 deletions handlers/lockrenewer_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion handlers/messagecontext_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion handlers/shuttleadapter.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
7 changes: 4 additions & 3 deletions integration/concurrentcreate_topic_test.go
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build integration
// +build integration

package integration
Expand All @@ -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() {
Expand Down
7 changes: 4 additions & 3 deletions integration/issue_topic_test.go
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build integration
// +build integration

package integration
Expand All @@ -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"
)

Expand Down
3 changes: 2 additions & 1 deletion integration/listener_queue_test.go
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build integration
// +build integration

package integration
Expand All @@ -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
Expand Down
7 changes: 4 additions & 3 deletions integration/listener_topic_test.go
View file
Original file line number Diff line number Diff line change
@@ -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
Expand Down
2 changes: 1 addition & 1 deletion integration/protomsg/Makefile
View file
Original file line number Diff line number Diff line change
@@ -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 .
2 changes: 1 addition & 1 deletion integration/protomsg/message.proto
View file
Original file line number Diff line number Diff line change
@@ -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;

Expand Down
4 changes: 2 additions & 2 deletions integration/publisher_queue_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
5 changes: 3 additions & 2 deletions integration/publisher_topic_test.go
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build integration
// +build integration

package integration
Expand All @@ -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"
)
Expand Down
16 changes: 8 additions & 8 deletions integration/pubsub_queue_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
10 changes: 5 additions & 5 deletions integration/pubsub_topic_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
6 changes: 3 additions & 3 deletions integration/suite_queue_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
7 changes: 4 additions & 3 deletions integration/suite_topic_test.go
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build integration
// +build integration

package integration
Expand All @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion internal/servicebus/namespace.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 (
Expand Down
4 changes: 2 additions & 2 deletions listener/alias.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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)
}
}
2 changes: 1 addition & 1 deletion marshal/types_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package marshal_test
import (
"testing"

"github.com/Azure/go-shuttle/marshal"
"github.com/pdaru/go-shuttle/marshal"
)

type customMarshaller struct {
Expand Down
2 changes: 1 addition & 1 deletion message/abandon.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion message/complete.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion message/deadletter.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion message/error.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion message/handler.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion message/handler_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
2 changes: 1 addition & 1 deletion message/message.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion message/retrylater.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
Loading

0 comments on commit d224a19

Please sign in to comment.