Skip to content

Commit cc35d22

Browse files
asimasim
committed
move the client
1 parent 35da760 commit cc35d22

File tree

16 files changed

+22
-22
lines changed

16 files changed

+22
-22
lines changed

‎README.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -140,12 +140,12 @@ curl -k -i -N -H "Connection: Upgrade" \
140140
"https://localhost:8081/sub?topic=foo"
141141
```
142142

143-
## Go Client [![GoDoc](https://godoc.org/github.com/asim/emque/go/client?status.svg)](https://godoc.org/github.com/asim/emque/go/client)
143+
## Go Client [![GoDoc](https://godoc.org/github.com/asim/emque/client?status.svg)](https://godoc.org/github.com/asim/emque/client)
144144

145145
Emque provides a simple go client
146146

147147
```go
148-
import "github.com/asim/emque/go/client"
148+
import "github.com/asim/emque/client"
149149
```
150150

151151
### Publish
@@ -177,7 +177,7 @@ c := client.New()
177177
gRPC client
178178

179179
```go
180-
import "github.com/asim/emque/go/client/grpc"
180+
import "github.com/asim/emque/client/grpc"
181181

182182
c := grpc.New()
183183
```
@@ -197,7 +197,7 @@ c := client.New(
197197
Sharding is supported via client much like gomemcache. Publish/Subscribe operations are performed against a single server.
198198

199199
```go
200-
import "github.com/asim/emque/go/client/selector"
200+
import "github.com/asim/emque/client/selector"
201201

202202
c := client.New(
203203
client.WithServers("10.0.0.1:8081", "10.0.0.1:8082", "10.0.0.1:8083"),
@@ -209,7 +209,7 @@ c := client.New(
209209
A name resolver can be used to discover the ip addresses of Emque servers
210210

211211
```go
212-
import "github.com/asim/emque/go/client/resolver"
212+
import "github.com/asim/emque/client/resolver"
213213

214214
c := client.New(
215215
// use the DNS resolver

‎broker/broker.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import (
77
"sync"
88
"time"
99

10-
"github.com/asim/emque/go/client"
10+
"github.com/asim/emque/client"
1111
)
1212

1313
var (

‎broker/options.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package broker
22

33
import (
4-
"github.com/asim/emque/go/client"
4+
"github.com/asim/emque/client"
55
)
66

77
type Options struct {

‎go/README.md renamed to ‎client/README.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
# Go Client [![GoDoc](https://godoc.org/github.com/asim/emque/go/client?status.svg)](https://godoc.org/github.com/asim/emque/go/client)
1+
# Go Client [![GoDoc](https://godoc.org/github.com/asim/emque/client?status.svg)](https://godoc.org/github.com/asim/emque/client)
22

33
## Usage
44

@@ -11,7 +11,7 @@ import (
1111
"log"
1212
"time"
1313

14-
"github.com/asim/emque/go/client"
14+
"github.com/asim/emque/client"
1515
)
1616

1717
func main() {
@@ -33,7 +33,7 @@ package main
3333
import (
3434
"log"
3535

36-
"github.com/asim/emque/go/client"
36+
"github.com/asim/emque/client"
3737
)
3838

3939
func main() {
@@ -61,7 +61,7 @@ c := client.New()
6161
gRPC client
6262

6363
```go
64-
import "github.com/asim/emque/go/client/grpc"
64+
import "github.com/asim/emque/client/grpc"
6565

6666
c := grpc.New()
6767
```
@@ -81,7 +81,7 @@ c := client.New(
8181
Sharding is supported via client much like gomemcache. Publish/Subscribe operations are performed against a single server.
8282

8383
```go
84-
import "github.com/asim/emque/go/client/selector"
84+
import "github.com/asim/emque/client/selector"
8585

8686
c := client.New(
8787
client.WithServers("10.0.0.1:8081", "10.0.0.1:8082", "10.0.0.1:8083"),
@@ -94,7 +94,7 @@ c := client.New(
9494
A name resolver can be used to discover the ip addresses of MQ servers
9595

9696
```go
97-
import "github.com/asim/emque/go/client/resolver"
97+
import "github.com/asim/emque/client/resolver"
9898

9999
c := client.New(
100100
// use the DNS resolver

‎go/client/client.go renamed to ‎client/client.go

File renamed without changes.

‎go/client/grpc/grpc.go renamed to ‎client/grpc/grpc.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@ import (
66
"sync"
77
"time"
88

9-
"github.com/asim/emque/go/client"
10-
"github.com/asim/emque/go/client/selector"
9+
"github.com/asim/emque/client"
10+
"github.com/asim/emque/client/selector"
1111
pb "github.com/asim/emque/proto"
1212
"golang.org/x/net/context"
1313
"google.golang.org/grpc"

‎go/client/http.go renamed to ‎client/http.go

File renamed without changes.

‎go/client/http/http.go renamed to ‎client/http/http.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package http
22

33
import (
4-
"github.com/asim/emque/go/client"
4+
"github.com/asim/emque/client"
55
)
66

77
// New returns a http client

‎go/client/options.go renamed to ‎client/options.go

File renamed without changes.

‎go/client/resolver/resolver.go renamed to ‎client/resolver/resolver.go

File renamed without changes.

‎go/client/resolver/resolver_test.go renamed to ‎client/resolver/resolver_test.go

File renamed without changes.

‎go/client/selector/selector.go renamed to ‎client/selector/selector.go

File renamed without changes.

‎go/client/selector/selector_test.go renamed to ‎client/selector/selector_test.go

File renamed without changes.

‎go/examples/pub/pub.go renamed to ‎examples/pub/pub.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66
"strings"
77
"time"
88

9-
"github.com/asim/emque/go/client"
9+
"github.com/asim/emque/client"
1010
)
1111

1212
var (

‎go/examples/sub/sub.go renamed to ‎examples/sub/sub.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"log"
66
"strings"
77

8-
"github.com/asim/emque/go/client"
8+
"github.com/asim/emque/client"
99
)
1010

1111
var (

‎main.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,10 @@ import (
1111
"time"
1212

1313
"github.com/asim/emque/broker"
14-
mqclient "github.com/asim/emque/go/client"
15-
mqgrpc "github.com/asim/emque/go/client/grpc"
16-
mqresolver "github.com/asim/emque/go/client/resolver"
17-
mqselector "github.com/asim/emque/go/client/selector"
14+
mqclient "github.com/asim/emque/client"
15+
mqgrpc "github.com/asim/emque/client/grpc"
16+
mqresolver "github.com/asim/emque/client/resolver"
17+
mqselector "github.com/asim/emque/client/selector"
1818
"github.com/asim/emque/server"
1919
grpcsrv "github.com/asim/emque/server/grpc"
2020
httpsrv "github.com/asim/emque/server/http"

0 commit comments

Comments
 (0)