move to h12.io

Change-Id: I30d930654ab39563b40d6d1f442a04bdac80d94a
h12w · May 5, 2018 · 07ad8dd · 07ad8dd
1 parent ecf4188
commit 07ad8dd
Show file tree

Hide file tree

Showing 21 changed files with 45 additions and 45 deletions.
diff --git a/README.md b/README.md
@@ -1,18 +1,18 @@
 kpax: a modular & idiomatic Kafka client in Go
 ==============================================
 
-[![GoDoc](https://godoc.org/h12.me/kpax?status.svg)](https://godoc.org/h12.me/kpax)
+[![GoDoc](https://godoc.org/h12.io/kpax?status.svg)](https://godoc.org/h12.io/kpax)
 
 Install
 -------
 
 ```
-go get -u h12.me/kpax.v1
+go get -u h12.io/kpax.v1
 ```
 
 ### Compatibility
 
-h12.me/kpax.v1 is compatible with Kafka Server 0.8.2.
+h12.io/kpax.v1 is compatible with Kafka Server 0.8.2.
 
 Design
 ------

diff --git a/broker/async.go b/broker/async.go
@@ -7,7 +7,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"h12.me/kpax/model"
+	"h12.io/kpax/model"
 )
 
 type AsyncBroker struct {

diff --git a/broker/pool.go b/broker/pool.go
@@ -8,7 +8,7 @@ import (
 	"time"
 
 	"gopkg.in/fatih/pool.v2"
-	"h12.me/kpax/model"
+	"h12.io/kpax/model"
 )
 
 const defaultTimeout = 30 * time.Second

diff --git a/cluster/cluster.go b/cluster/cluster.go
@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"sync"
 
-	"h12.me/kpax/model"
-	"h12.me/kpax/proto"
+	"h12.io/kpax/model"
+	"h12.io/kpax/proto"
 )
 
 var (

diff --git a/cluster/pool.go b/cluster/pool.go
@@ -3,8 +3,8 @@ package cluster
 import (
 	"sync"
 
-	"h12.me/kpax/model"
-	"h12.me/kpax/log"
+	"h12.io/kpax/model"
+	"h12.io/kpax/log"
 )
 
 type brokerPool struct {

diff --git a/cmd/kpax/command.go b/cmd/kpax/command.go
@@ -10,10 +10,10 @@ import (
 	"sync/atomic"
 	"time"
 
-	"h12.me/kpax/consumer"
-	"h12.me/kpax/model"
-	"h12.me/kpax/producer"
-	"h12.me/kpax/proto"
+	"h12.io/kpax/consumer"
+	"h12.io/kpax/model"
+	"h12.io/kpax/producer"
+	"h12.io/kpax/proto"
 )
 
 const (

diff --git a/cmd/kpax/format.go b/cmd/kpax/format.go
@@ -7,10 +7,10 @@ import (
 	"time"
 
 	"gopkg.in/vmihailenco/msgpack.v2"
-	"h12.me/kpax/consumer"
-	"h12.me/kpax/model"
-	"h12.me/kpax/proto"
-	"h12.me/uuid/hexid"
+	"h12.io/kpax/consumer"
+	"h12.io/kpax/model"
+	"h12.io/kpax/proto"
+	"h12.io/uuid/hexid"
 )
 
 type Format string

diff --git a/cmd/kpax/main.go b/cmd/kpax/main.go
@@ -3,13 +3,13 @@ package main
 import (
 	"log"
 
-	"h12.me/config"
-	"h12.me/kpax/broker"
-	"h12.me/kpax/cluster"
+	"h12.io/config"
+	"h12.io/kpax/broker"
+	"h12.io/kpax/cluster"
 )
 
 const (
-	clientID = "h12.me/kpax/kafpro"
+	clientID = "h12.io/kpax/kafpro"
 )
 
 func main() {

diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -4,8 +4,8 @@ import (
 	"errors"
 	"time"
 
-	"h12.me/kpax/model"
-	"h12.me/kpax/proto"
+	"h12.io/kpax/model"
+	"h12.io/kpax/proto"
 )
 
 var (

diff --git a/kpaxutil/sender.go b/kpaxutil/sender.go
@@ -3,9 +3,9 @@ package kpaxutil
 import (
 	"encoding"
 
-	"h12.me/kpax/broker"
-	"h12.me/kpax/cluster"
-	"h12.me/kpax/producer"
+	"h12.io/kpax/broker"
+	"h12.io/kpax/cluster"
+	"h12.io/kpax/producer"
 )
 
 type Sender interface {

diff --git a/producer/producer.go b/producer/producer.go
@@ -5,9 +5,9 @@ import (
 	"fmt"
 	"time"
 
-	"h12.me/kpax/log"
-	"h12.me/kpax/model"
-	"h12.me/kpax/proto"
+	"h12.io/kpax/log"
+	"h12.io/kpax/model"
+	"h12.io/kpax/proto"
 )
 
 var (

diff --git a/proto/api.go b/proto/api.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"time"
 
-	"h12.me/kpax/model"
+	"h12.io/kpax/model"
 )
 
 type client struct {
@@ -24,7 +24,7 @@ func (c client) Do(req RequestMessage, resp ResponseMessage) error {
 	)
 }
 
-const clientID = "h12.me/kpax"
+const clientID = "h12.io/kpax"
 
 type Metadata string
 

diff --git a/proto/api_test.go b/proto/api_test.go
@@ -6,10 +6,10 @@ import (
 	"testing"
 	"time"
 
-	"h12.me/kpax/broker"
-	"h12.me/kpax/model"
-	"h12.me/realtest/kafka"
-	"h12.me/wipro"
+	"h12.io/kpax/broker"
+	"h12.io/kpax/model"
+	"h12.io/realtest/kafka"
+	"h12.io/wipro"
 )
 
 func TestTopicMetadata(t *testing.T) {

diff --git a/proto/codec.go b/proto/codec.go
@@ -5,7 +5,7 @@ import (
 	"encoding/binary"
 
 	"github.com/golang/snappy"
-	"h12.me/wipro"
+	"h12.io/wipro"
 )
 
 func (m *Message) Compressed() bool {

diff --git a/proto/marshal_auto.go b/proto/marshal_auto.go
@@ -1,7 +1,7 @@
 package proto
 
 import (
-	"h12.me/wipro"
+	"h12.io/wipro"
 	"hash/crc32"
 )
 

diff --git a/proto/marshal_test.go b/proto/marshal_test.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"testing"
 
-	"h12.me/wipro"
+	"h12.io/wipro"
 )
 
 func TestUnmarshal(t *testing.T) {

diff --git a/proto/offset.go b/proto/offset.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"time"
 
-	"h12.me/kpax/model"
+	"h12.io/kpax/model"
 )
 
 type GetTimeFunc func([]byte) (time.Time, error)

diff --git a/proto/type.go b/proto/type.go
@@ -4,7 +4,7 @@ import (
 	"io"
 	"strconv"
 
-	"h12.me/wipro"
+	"h12.io/wipro"
 )
 
 type RequestMessage interface {

diff --git a/proto/type_auto.go b/proto/type_auto.go
@@ -1,6 +1,6 @@
 package proto
 
-import "h12.me/wipro"
+import "h12.io/wipro"
 
 type RequestOrResponse struct {
 	Size int32

diff --git a/spec/gen/html.go b/spec/gen/html.go
@@ -6,9 +6,9 @@ import (
 	"io"
 	"strings"
 
-	"h12.me/gs"
-	"h12.me/html-query"
-	"h12.me/html-query/expr"
+	"h12.io/gs"
+	"h12.io/html-query"
+	"h12.io/html-query/expr"
 )
 
 var (

diff --git a/spec/gen/main.go b/spec/gen/main.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"os"
 
-	"h12.me/wipro/gen"
+	"h12.io/wipro/gen"
 )
 
 const packageName = "proto"
-Original file line number
+Diff line change
@@ Expand Up / @@ -4,7 +4,7 @@ import ( @@
     	"fmt"
     	"time"
-    	"h12.me/kpax/model"
+    	"h12.io/kpax/model"
     )
     type GetTimeFunc func([]byte) (time.Time, error)
@@ Expand Down @@