Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

#

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

rename go-nats-streaming to stan.go #75

Merged
merged 1 commit into from
May 19, 2019
Merged

rename go-nats-streaming to stan.go #75

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion docs/content/docs/getting-started/nats-streaming/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,9 @@ require (
github.com/kr/pretty v0.1.0 // indirect
github.com/lib/pq v1.0.0 // indirect
github.com/nats-io/gnatsd v1.3.0 // indirect
github.com/nats-io/go-nats-streaming v0.4.4
github.com/nats-io/nats-server v1.4.1 // indirect
github.com/nats-io/nats-streaming-server v0.11.2 // indirect
github.com/nats-io/stan.go v0.4.4
roblaszczak marked this conversation as resolved.
Show resolved Hide resolved
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c // indirect
golang.org/x/crypto v0.0.0-20190506204251-e1dfcc566284 // indirect
golang.org/x/net v0.0.0-20190503192946-f4e77d36d62c // indirect
Expand Down
2 changes: 2 additions & 0 deletions docs/content/docs/getting-started/nats-streaming/go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,8 @@ github.com/nats-io/nkeys v0.0.2 h1:+qM7QpgXnvDDixitZtQUBDY9w/s9mu1ghS+JIbsrx6M=
github.com/nats-io/nkeys v0.0.2/go.mod h1:dab7URMsZm6Z/jp9Z5UGa87Uutgc2mVpXLC4B7TDb/4=
github.com/nats-io/nuid v1.0.1 h1:5iA8DT8V7q8WK2EScv2padNa/rTESc1KdnPw4TC2paw=
github.com/nats-io/nuid v1.0.1/go.mod h1:19wcPz3Ph3q0Jbyiqsd0kePYG7A95tJPxeL+1OSON2c=
github.com/nats-io/stan.go v0.4.4 h1:A11Fv2Gqap21tz76BL+N26EyNdZNNmmyr5s0ZpApwOU=
github.com/nats-io/stan.go v0.4.4/go.mod h1:Ji7mK6gRZJSH1nc3ZJH6vi7zn/QnZhpR9Arm4iuzsUQ=
github.com/oklog/ulid v1.3.1 h1:EGfNDEx6MqHz8B3uNV6QAib1UR2Lm97sHi3ocA6ESJ4=
github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U=
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c h1:Lgl0gzECD8GnQ5QCWA8o6BtfL6mDH5rQgM4/fX3avOs=
Expand Down
2 changes: 1 addition & 1 deletion docs/content/docs/getting-started/nats-streaming/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"log"
"time"

"github.com/nats-io/go-nats-streaming"
stan "github.com/nats-io/stan.go"

"github.com/ThreeDotsLabs/watermill"
"github.com/ThreeDotsLabs/watermill/message/infrastructure/nats"
Expand Down
22 changes: 20 additions & 2 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,23 +1,41 @@
module github.com/ThreeDotsLabs/watermill

require (
cloud.google.com/go v0.34.0
roblaszczak marked this conversation as resolved.
Show resolved Hide resolved
github.com/Shopify/sarama v1.22.1
github.com/armon/go-metrics v0.0.0-20190430140413-ec5e00d3c878 // indirect
github.com/cenkalti/backoff v2.1.1+incompatible
github.com/go-chi/chi v4.0.2+incompatible
github.com/go-sql-driver/mysql v1.4.1 // indirect
github.com/gogo/protobuf v1.2.1
github.com/golang/protobuf v1.3.1 // indirect
github.com/golang/protobuf v1.3.1
github.com/google/uuid v1.1.1
github.com/googleapis/gax-go v2.0.2+incompatible // indirect
github.com/hashicorp/go-msgpack v0.5.5 // indirect
github.com/hashicorp/go-multierror v1.0.0
github.com/hashicorp/raft v1.0.1 // indirect
github.com/lib/pq v1.1.1 // indirect
github.com/nats-io/gnatsd v1.4.1 // indirect
github.com/nats-io/go-nats v1.7.2 // indirect
github.com/nats-io/go-nats-streaming v0.4.4
github.com/nats-io/go-nats-streaming v0.4.5 // indirect
github.com/nats-io/nats-server v1.4.1 // indirect
github.com/nats-io/nats-streaming-server v0.14.1 // indirect
github.com/nats-io/nats.go v1.7.2 // indirect
github.com/nats-io/nkeys v0.0.2 // indirect
github.com/nats-io/nuid v1.0.1 // indirect
github.com/nats-io/stan.go v0.4.5
github.com/oklog/ulid v1.3.1
github.com/pkg/errors v0.8.1
github.com/prometheus/client_golang v0.9.2
github.com/renstrom/shortuuid v3.0.0+incompatible
github.com/streadway/amqp v0.0.0-20190404075320-75d898a42a94
github.com/stretchr/testify v1.3.0
go.etcd.io/bbolt v1.3.2 // indirect
golang.org/x/crypto v0.0.0-20190513172903-22d7a77e9e5f // indirect
golang.org/x/net v0.0.0-20190514140710-3ec191127204 // indirect
golang.org/x/sync v0.0.0-20190423024810-112230192c58 // indirect
golang.org/x/sys v0.0.0-20190516110030-61b9204099cb // indirect
golang.org/x/text v0.3.2 // indirect
google.golang.org/api v0.5.0
google.golang.org/grpc v1.20.1
)
74 changes: 56 additions & 18 deletions go.sum
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion message/infrastructure/nats/connection.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package nats

import "github.com/nats-io/go-nats-streaming"
import stan "github.com/nats-io/stan.go"

type StanConnConfig struct {
// ClusterID is the NATS Streaming cluster ID.
Expand Down
2 changes: 1 addition & 1 deletion message/infrastructure/nats/marshaler.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,10 @@ import (
"bytes"
"encoding/gob"

stan "github.com/nats-io/stan.go"
"github.com/pkg/errors"

"github.com/ThreeDotsLabs/watermill/message"
"github.com/nats-io/go-nats-streaming"
)

type Marshaler interface {
Expand Down
5 changes: 3 additions & 2 deletions message/infrastructure/nats/marshaler_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,12 @@ import (
"sync"
"testing"

stan "github.com/nats-io/stan.go"

"github.com/stretchr/testify/assert"

"github.com/ThreeDotsLabs/watermill/message/infrastructure/nats"
"github.com/nats-io/go-nats-streaming"
"github.com/nats-io/go-nats-streaming/pb"
"github.com/nats-io/stan.go/pb"
"github.com/stretchr/testify/require"

"github.com/ThreeDotsLabs/watermill/message"
Expand Down
2 changes: 1 addition & 1 deletion message/infrastructure/nats/publisher.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package nats
import (
"github.com/ThreeDotsLabs/watermill"
"github.com/ThreeDotsLabs/watermill/message"
"github.com/nats-io/go-nats-streaming"
stan "github.com/nats-io/stan.go"
"github.com/pkg/errors"
)

Expand Down
2 changes: 1 addition & 1 deletion message/infrastructure/nats/pubsub_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (
"github.com/ThreeDotsLabs/watermill/message"
"github.com/ThreeDotsLabs/watermill/message/infrastructure"
"github.com/ThreeDotsLabs/watermill/message/infrastructure/nats"
stan "github.com/nats-io/go-nats-streaming"
stan "github.com/nats-io/stan.go"
"github.com/stretchr/testify/require"
)

Expand Down
2 changes: 1 addition & 1 deletion message/infrastructure/nats/subscriber.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,11 @@ import (
"time"

internalSync "github.com/ThreeDotsLabs/watermill/internal/sync"
stan "github.com/nats-io/stan.go"

"github.com/ThreeDotsLabs/watermill"

"github.com/ThreeDotsLabs/watermill/message"
"github.com/nats-io/go-nats-streaming"
"github.com/pkg/errors"
)

Expand Down