move to azure-amqp-common-v2
This commit is contained in:
Родитель
dda90fa328
Коммит
2d7ef1757e
2
batch.go
2
batch.go
|
@ -1,7 +1,7 @@
|
|||
package servicebus
|
||||
|
||||
import (
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"pack.ag/amqp"
|
||||
)
|
||||
|
||||
|
|
|
@ -4,7 +4,7 @@ import (
|
|||
"context"
|
||||
"fmt"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
)
|
||||
|
||||
type (
|
||||
|
|
|
@ -5,7 +5,7 @@ import (
|
|||
"fmt"
|
||||
"testing"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/stretchr/testify/assert"
|
||||
)
|
||||
|
||||
|
|
|
@ -2,6 +2,11 @@
|
|||
|
||||
## `head`
|
||||
|
||||
## `v0.8.0`
|
||||
- tab for tracing and logging which supports both opencensus and opentracing. To use opencensus, just add a
|
||||
`_ "github.com/devigned/tab/opencensus"`. To use opentracing, just add a `_ "github.com/devigned/tab/opentracing"`
|
||||
- target azure-amqp-common-go/v2
|
||||
|
||||
## `v0.7.0`
|
||||
- [add batch disposition errors](https://github.com/Azure/azure-service-bus-go/pull/129)
|
||||
|
||||
|
|
|
@ -6,7 +6,7 @@ import (
|
|||
"os"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
|
||||
"github.com/Azure/azure-service-bus-go"
|
||||
)
|
||||
|
|
|
@ -2,7 +2,7 @@ package servicebus
|
|||
|
||||
import (
|
||||
"fmt"
|
||||
"github.com/Azure/azure-amqp-common-go/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/rpc"
|
||||
"reflect"
|
||||
)
|
||||
|
||||
|
|
3
go.mod
3
go.mod
|
@ -3,11 +3,10 @@ module github.com/Azure/azure-service-bus-go
|
|||
go 1.12
|
||||
|
||||
require (
|
||||
github.com/Azure/azure-amqp-common-go v1.1.5-0.20190529212351-f3083d80d0bb
|
||||
github.com/Azure/azure-amqp-common-go/v2 v2.0.0
|
||||
github.com/Azure/azure-sdk-for-go v30.0.0+incompatible
|
||||
github.com/Azure/go-autorest v12.0.0+incompatible
|
||||
github.com/devigned/tab v0.1.1
|
||||
github.com/devigned/tab/opencensus v0.1.1
|
||||
github.com/fortytw2/leaktest v1.3.0 // indirect
|
||||
github.com/google/go-cmp v0.3.0 // indirect
|
||||
github.com/joho/godotenv v1.3.0
|
||||
|
|
7
go.sum
7
go.sum
|
@ -2,8 +2,8 @@ cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMT
|
|||
cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
|
||||
contrib.go.opencensus.io/exporter/ocagent v0.5.0 h1:TKXjQSRS0/cCDrP7KvkgU6SmILtF/yV2TOs/02K/WZQ=
|
||||
contrib.go.opencensus.io/exporter/ocagent v0.5.0/go.mod h1:ImxhfLRpxoYiSq891pBrLVhN+qmP8BTVvdH2YLs7Gl0=
|
||||
github.com/Azure/azure-amqp-common-go v1.1.5-0.20190529212351-f3083d80d0bb h1:SAtzHHCTssx/OAUacNGNc6W9asuCQGwr57gTtHWA3hI=
|
||||
github.com/Azure/azure-amqp-common-go v1.1.5-0.20190529212351-f3083d80d0bb/go.mod h1:1ZplNYSTFCYf0E6VZjZBTUEbj10mr75PaWv3Ve5sLBg=
|
||||
github.com/Azure/azure-amqp-common-go/v2 v2.0.0 h1:98xtMbghfioKloSBZgkIwH/SINcDYtxXBbUZoqCePiI=
|
||||
github.com/Azure/azure-amqp-common-go/v2 v2.0.0/go.mod h1:YDoDY50iQ2OabOP0WUQoNR7vpDjRlB13vIZVrvUoJLo=
|
||||
github.com/Azure/azure-sdk-for-go v29.0.0+incompatible h1:CYPU39ULbGjQBo3gXIqiWouK0C4F+Pt2Zx5CqGvqknE=
|
||||
github.com/Azure/azure-sdk-for-go v29.0.0+incompatible/go.mod h1:9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
|
||||
github.com/Azure/azure-sdk-for-go v30.0.0+incompatible h1:6o1Yzl7wTBYg+xw0pY4qnalaPmEQolubEEdepo1/kmI=
|
||||
|
@ -17,11 +17,8 @@ github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDk
|
|||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/devigned/tab v0.0.1/go.mod h1:oVYrfgGyond090gxCvvbjZji79+peOiSV6vhZhKJM0Y=
|
||||
github.com/devigned/tab v0.1.1 h1:3mD6Kb1mUOYeLpJvTVSDwSg5ZsfSxfvxGRTxRsJsITA=
|
||||
github.com/devigned/tab v0.1.1/go.mod h1:XG9mPq0dFghrYvoBF3xdRrJzSTX1b7IQrvaL9mzjeJY=
|
||||
github.com/devigned/tab/opencensus v0.1.1 h1:KX8QdRsPPEb6Wg+hWxk+gVSMvCvpXBpN3Hp3fOU1Efo=
|
||||
github.com/devigned/tab/opencensus v0.1.1/go.mod h1:U6xXMXnNwXJpdaK0mnT3zdng4WTi+vCfqn7YHofEv2A=
|
||||
github.com/dgrijalva/jwt-go v3.2.0+incompatible h1:7qlOGliEKZXTDg6OTjfoBKDXWrumCAMpl/TFQ4/5kLM=
|
||||
github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
|
||||
github.com/fortytw2/leaktest v1.2.0 h1:cj6GCiwJDH7l3tMHLjZDo0QqPtrXJiWSI9JgpeQKw+Q=
|
||||
|
|
|
@ -29,7 +29,7 @@ import (
|
|||
"os"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/conn"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/conn"
|
||||
rm "github.com/Azure/azure-sdk-for-go/services/resources/mgmt/2017-05-10/resources"
|
||||
sbmgmt "github.com/Azure/azure-sdk-for-go/services/servicebus/mgmt/2017-04-01/servicebus"
|
||||
"github.com/Azure/go-autorest/autorest"
|
||||
|
|
|
@ -6,7 +6,7 @@ import (
|
|||
"sort"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/rpc"
|
||||
"github.com/devigned/tab"
|
||||
"pack.ag/amqp"
|
||||
)
|
||||
|
|
|
@ -6,7 +6,7 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/rpc"
|
||||
"github.com/devigned/tab"
|
||||
"pack.ag/amqp"
|
||||
)
|
||||
|
|
|
@ -30,8 +30,8 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/devigned/tab"
|
||||
"github.com/mitchellh/mapstructure"
|
||||
"pack.ag/amqp"
|
||||
|
|
|
@ -7,7 +7,7 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/rpc"
|
||||
"pack.ag/amqp"
|
||||
)
|
||||
|
||||
|
|
|
@ -5,7 +5,7 @@ import (
|
|||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/stretchr/testify/assert"
|
||||
"github.com/stretchr/testify/require"
|
||||
)
|
||||
|
|
|
@ -3,7 +3,7 @@ package servicebus
|
|||
import (
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/Azure/go-autorest/autorest/to"
|
||||
"github.com/mitchellh/mapstructure"
|
||||
"pack.ag/amqp"
|
||||
|
|
2
mgmt.go
2
mgmt.go
|
@ -34,7 +34,7 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/auth"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/auth"
|
||||
"github.com/devigned/tab"
|
||||
)
|
||||
|
||||
|
|
14
namespace.go
14
namespace.go
|
@ -29,14 +29,10 @@ import (
|
|||
"runtime"
|
||||
"strings"
|
||||
|
||||
// use OpenCensus tracing by default; to use opentracing add the following import to your application
|
||||
// `_ "github.com/devigned/tab/opentracing"`
|
||||
_ "github.com/devigned/tab/opencensus"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/auth"
|
||||
"github.com/Azure/azure-amqp-common-go/cbs"
|
||||
"github.com/Azure/azure-amqp-common-go/conn"
|
||||
"github.com/Azure/azure-amqp-common-go/sas"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/auth"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/cbs"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/conn"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/sas"
|
||||
"github.com/Azure/go-autorest/autorest/azure"
|
||||
"golang.org/x/net/websocket"
|
||||
"pack.ag/amqp"
|
||||
|
@ -52,7 +48,7 @@ const (
|
|||
//`
|
||||
|
||||
// Version is the semantic version number
|
||||
Version = "0.7.0"
|
||||
Version = "0.8.0"
|
||||
|
||||
rootUserAgent = "/golang-service-bus"
|
||||
)
|
||||
|
|
4
queue.go
4
queue.go
|
@ -32,8 +32,8 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/rpc"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/Azure/go-autorest/autorest/date"
|
||||
"github.com/devigned/tab"
|
||||
"pack.ag/amqp"
|
||||
|
|
|
@ -8,7 +8,7 @@ import (
|
|||
"os"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/Azure/azure-service-bus-go"
|
||||
"github.com/joho/godotenv"
|
||||
)
|
||||
|
|
|
@ -26,7 +26,7 @@ import (
|
|||
"context"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go"
|
||||
"github.com/Azure/azure-amqp-common-go/v2"
|
||||
"github.com/devigned/tab"
|
||||
"pack.ag/amqp"
|
||||
)
|
||||
|
|
|
@ -27,7 +27,7 @@ import (
|
|||
"math/rand"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/devigned/tab"
|
||||
"pack.ag/amqp"
|
||||
)
|
||||
|
|
|
@ -27,7 +27,7 @@ import (
|
|||
"sync"
|
||||
"sync/atomic"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/devigned/tab"
|
||||
"pack.ag/amqp"
|
||||
)
|
||||
|
|
|
@ -31,7 +31,7 @@ import (
|
|||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/Azure/azure-sdk-for-go/services/servicebus/mgmt/2015-08-01/servicebus"
|
||||
"github.com/stretchr/testify/assert"
|
||||
"github.com/stretchr/testify/require"
|
||||
|
|
2
topic.go
2
topic.go
|
@ -28,7 +28,7 @@ import (
|
|||
"strings"
|
||||
"sync"
|
||||
|
||||
"github.com/Azure/azure-amqp-common-go/uuid"
|
||||
"github.com/Azure/azure-amqp-common-go/v2/uuid"
|
||||
"github.com/Azure/go-autorest/autorest/date"
|
||||
"github.com/devigned/tab"
|
||||
)
|
||||
|
|
Загрузка…
Ссылка в новой задаче