rename meqio to mafanr

Readme.md

@@ -1,7 +1,7 @@
 
 MeQ [mi:kju]
 ------------
-A modern messaging platform for Message Push、IM、Group Chatting、IoT etc, based on [MQTT protocol](https://github.com/meqio/meq/tree/master/proto/mqtt). MeQ is written in pure go and standard library,nearly no messy dependencies. so you can easily deploy a standalone binary in linux、unix、macos、windows.
+A modern messaging platform for Message Push、IM、Group Chatting、IoT etc, based on [MQTT protocol](https://github.com/mafanr/meq/tree/master/proto/mqtt). MeQ is written in pure go and standard library,nearly no messy dependencies. so you can easily deploy a standalone binary in linux、unix、macos、windows.
 
 Our goal is to be the best messaging platform in the world.
 
@@ -29,8 +29,8 @@ Other Os: https://www.foundationdb.org/download/ (Please choose version 5.1.7)
 
 ### Start MeQ
 ```bash
-> go get github.com/meqio/meq
-> cd $GOPATH/src/github.com/meqio/meq/broker
+> go get github.com/mafanr/meq
+> cd $GOPATH/src/github.com/mafanr/meq/broker
 > go run main.go
 ```
 ### Start example

ReadmeCn.md

@@ -1,7 +1,7 @@
 
 MeQ [咪Q]
 ------------
-MeQ是一个现代化的消息平台，支持消息推送、即时通讯、群组聊天、物联网IoT等场景，基于[MQTT协议](https://github.com/meqio/meq/tree/master/proto/mqtt)，完全使用Go语言开发，无任何依赖、无Cgo。目前支持所有主流的平台：Linux、Unix、MacOS、Windows、ARM等。
+MeQ是一个现代化的消息平台，支持消息推送、即时通讯、群组聊天、物联网IoT等场景，基于[MQTT协议](https://github.com/mafanr/meq/tree/master/proto/mqtt)，完全使用Go语言开发，无任何依赖、无Cgo。目前支持所有主流的平台：Linux、Unix、MacOS、Windows、ARM等。
 
 MeQ的目标是成为世界上最好的消息平台，就像手机中的Iphone一样，从性能到产品体验都做到最一流。
 
@@ -27,8 +27,8 @@ Centos6: https://www.foundationdb.org/downloads/5.1.7/rhel6/installers/foundatio
 
 ### 启动MeQ
 ```bash
-> go get github.com/meqio/meq
-> cd $GOPATH/src/github.com/meqio/meq/broker
+> go get github.com/mafanr/meq
+> cd $GOPATH/src/github.com/mafanr/meq/broker
 > go run main.go
 ```
 

broker/cmd/root.go

@@ -20,7 +20,7 @@ import (
 	"os/signal"
 	"syscall"
 
-	"github.com/meqio/meq/broker/service"
+	"github.com/mafanr/meq/broker/service"
 	"github.com/spf13/cobra"
 )
 

broker/main.go

@@ -14,7 +14,7 @@
 
 package main
 
-import "github.com/meqio/meq/broker/cmd"
+import "github.com/mafanr/meq/broker/cmd"
 
 func main() {
 	cmd.Execute()

broker/service/broker.go

@@ -26,7 +26,7 @@ import (
 	_ "net/http/pprof"
 
 	"github.com/bwmarrin/snowflake"
-	"github.com/meqio/meq/proto/websocket"
+	"github.com/mafanr/meq/proto/websocket"
 	"github.com/sunface/talent"
 	"go.uber.org/zap"
 )

broker/service/client.go

@@ -24,8 +24,8 @@ import (
 
 	"github.com/sunface/talent"
 
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 	"go.uber.org/zap"
 )
 

broker/service/fdb_store.go

@@ -23,7 +23,7 @@ import (
 	"github.com/apple/foundationdb/bindings/go/src/fdb/directory"
 	"github.com/apple/foundationdb/bindings/go/src/fdb/subspace"
 	"github.com/apple/foundationdb/bindings/go/src/fdb/tuple"
-	"github.com/meqio/meq/proto"
+	"github.com/mafanr/meq/proto"
 	"go.uber.org/zap"
 )
 

broker/service/fdb_store_test.go

@@ -19,7 +19,7 @@ import (
 
 	"github.com/apple/foundationdb/bindings/go/src/fdb"
 	"github.com/apple/foundationdb/bindings/go/src/fdb/tuple"
-	"github.com/meqio/meq/proto"
+	"github.com/mafanr/meq/proto"
 	"github.com/stretchr/testify/assert"
 )
 

broker/service/mem_store.go

@@ -21,7 +21,7 @@ import (
 	"github.com/sunface/talent"
 	"github.com/weaveworks/mesh"
 
-	"github.com/meqio/meq/proto"
+	"github.com/mafanr/meq/proto"
 )
 
 type MemStore struct {

broker/service/push.go

@@ -18,8 +18,8 @@ import (
 
 	"go.uber.org/zap"
 
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 )
 
 func publishOnline(from uint64, bk *Broker, msgs []*proto.PubMsg, broadcast bool) {

broker/service/router.go

@@ -17,7 +17,7 @@ import (
 	"encoding/binary"
 	"sync"
 
-	"github.com/meqio/meq/proto"
+	"github.com/mafanr/meq/proto"
 	"github.com/weaveworks/mesh"
 	"go.uber.org/zap"
 )

broker/service/storage.go

@@ -14,7 +14,7 @@
 package service
 
 import (
-	"github.com/meqio/meq/proto"
+	"github.com/mafanr/meq/proto"
 )
 
 type Storage interface {

broker/service/sub_trie.go

@@ -20,7 +20,7 @@ import (
 	"math/rand"
 	"sync"
 
-	"github.com/meqio/meq/proto"
+	"github.com/mafanr/meq/proto"
 	"github.com/weaveworks/mesh"
 )
 

broker/service/test_utils.go

@@ -17,7 +17,7 @@ import (
 	"bytes"
 	"fmt"
 
-	"github.com/meqio/meq/proto"
+	"github.com/mafanr/meq/proto"
 	"github.com/weaveworks/mesh"
 )
 

meq-io-website/src/components/Nav.vue

@@ -4,7 +4,7 @@
             <Col span="20" offset="2" >
                 <img class="align-middle" src="../assets/logo.png" style="height:50px;width:50px;"/>
                 <h2  class="header-font font-weight-600 large-font-size in-line align-middle margin-left-5">MeQ</h2>
-                <div class="align-middle medium-font-size float-right margin-top-10"> <a class="a-hover font-color-normal" @click="gotoDocs">Docs</a> <a class="a-hover margin-left-20 font-color-normal" @click="gotoDocs">AdminSite</a> <a class="a-hover margin-left-20 font-color-normal" href="https://github.com/meqio/meq">Github</a></div>
+                <div class="align-middle medium-font-size float-right margin-top-10"> <a class="a-hover font-color-normal" @click="gotoDocs">Docs</a> <a class="a-hover margin-left-20 font-color-normal" @click="gotoDocs">AdminSite</a> <a class="a-hover margin-left-20 font-color-normal" href="https://github.com/mafanr/meq">Github</a></div>
             </Col>
         </Row>
     </div>

sdks/go-meq/ack.go

@@ -17,8 +17,8 @@ import (
 	"errors"
 	"fmt"
 
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 )
 
 func (c *Connection) ReduceCount(topic []byte, count int) error {

sdks/go-meq/callback.go

@@ -13,7 +13,7 @@
 // limitations under the License.
 package meq
 
-import "github.com/meqio/meq/proto"
+import "github.com/mafanr/meq/proto"
 
 type PubMsgHandler func(*proto.PubMsg)
 type UnreadHandler func([]byte, int)

sdks/go-meq/chat.go

@@ -14,8 +14,8 @@
 package meq
 
 import (
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 )
 
 func (c *Connection) JoinChat(topic []byte) {

sdks/go-meq/connection.go

@@ -20,8 +20,8 @@ import (
 	"net"
 	"time"
 
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 	"go.uber.org/zap"
 )
 

sdks/go-meq/publish.go

@@ -14,8 +14,8 @@
 package meq
 
 import (
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 )
 
 func (c *Connection) Publish(msgs []*proto.PubMsg) error {

sdks/go-meq/pull_message.go

@@ -17,8 +17,8 @@ import (
 	"errors"
 	"fmt"
 
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 )
 
 func (c *Connection) PullMsgs(topic []byte, count int, offset []byte) error {

sdks/go-meq/subscribe.go

@@ -17,8 +17,8 @@ import (
 	"errors"
 	"time"
 
-	"github.com/meqio/meq/proto"
-	"github.com/meqio/meq/proto/mqtt"
+	"github.com/mafanr/meq/proto"
+	"github.com/mafanr/meq/proto/mqtt"
 )
 
 func (c *Connection) Subscribe(topic []byte) error {

sdks/go-meq/test/main.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"time"
 
-	meq "github.com/meqio/meq/sdks/go-meq"
+	meq "github.com/mafanr/meq/sdks/go-meq"
 )
 
 var topic = "/1234567890/22/chat/001"

sdks/go-meq/test/pub.go

@@ -5,8 +5,8 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"github.com/meqio/meq/proto"
-	meq "github.com/meqio/meq/sdks/go-meq"
+	"github.com/mafanr/meq/proto"
+	meq "github.com/mafanr/meq/sdks/go-meq"
 )
 
 func pub(conns []*meq.Connection) {

sdks/go-meq/test/sub.go

@@ -4,8 +4,8 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/meqio/meq/proto"
-	meq "github.com/meqio/meq/sdks/go-meq"
+	"github.com/mafanr/meq/proto"
+	meq "github.com/mafanr/meq/sdks/go-meq"
 )
 
 func sub(conn *meq.Connection) {