Update imports for NATS (#881)
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
Waldemar Quevedo authored 3 years ago
Peter Bourgon committed 3 years ago
12 | 12 |
natstransport "github.com/go-kit/kit/transport/nats"
|
13 | 13 |
httptransport "github.com/go-kit/kit/transport/http"
|
14 | 14 |
|
15 | |
"github.com/nats-io/go-nats"
|
|
15 |
"github.com/nats-io/nats.go"
|
16 | 16 |
)
|
17 | 17 |
|
18 | 18 |
// StringService provides operations on strings.
|
2 | 2 |
import (
|
3 | 3 |
"context"
|
4 | 4 |
|
5 | |
"github.com/nats-io/go-nats"
|
|
5 |
"github.com/nats-io/nats.go"
|
6 | 6 |
)
|
7 | 7 |
|
8 | 8 |
// DecodeRequestFunc extracts a user-domain request object from a publisher
|
3 | 3 |
"context"
|
4 | 4 |
"encoding/json"
|
5 | 5 |
"github.com/go-kit/kit/endpoint"
|
6 | |
"github.com/nats-io/go-nats"
|
|
6 |
"github.com/nats-io/nats.go"
|
7 | 7 |
"time"
|
8 | 8 |
)
|
9 | 9 |
|
6 | 6 |
"time"
|
7 | 7 |
|
8 | 8 |
natstransport "github.com/go-kit/kit/transport/nats"
|
9 | |
"github.com/nats-io/go-nats"
|
|
9 |
"github.com/nats-io/nats.go"
|
10 | 10 |
)
|
11 | 11 |
|
12 | 12 |
func TestPublisher(t *testing.T) {
|
2 | 2 |
import (
|
3 | 3 |
"context"
|
4 | 4 |
|
5 | |
"github.com/nats-io/go-nats"
|
|
5 |
"github.com/nats-io/nats.go"
|
6 | 6 |
)
|
7 | 7 |
|
8 | 8 |
// RequestFunc may take information from a publisher request and put it into a
|
7 | 7 |
"github.com/go-kit/kit/log"
|
8 | 8 |
"github.com/go-kit/kit/transport"
|
9 | 9 |
|
10 | |
"github.com/nats-io/go-nats"
|
|
10 |
"github.com/nats-io/nats.go"
|
11 | 11 |
)
|
12 | 12 |
|
13 | 13 |
// Subscriber wraps an endpoint and provides nats.MsgHandler.
|
8 | 8 |
"testing"
|
9 | 9 |
"time"
|
10 | 10 |
|
11 | |
"github.com/nats-io/gnatsd/server"
|
12 | |
"github.com/nats-io/go-nats"
|
|
11 |
"github.com/nats-io/nats-server/server"
|
|
12 |
"github.com/nats-io/nats.go"
|
13 | 13 |
|
14 | 14 |
"github.com/go-kit/kit/endpoint"
|
15 | 15 |
natstransport "github.com/go-kit/kit/transport/nats"
|