Migrate to gosrc.io

backoff.go

@@ -20,7 +20,7 @@ TODO: Implement Backoff Ticker channel
 TODO: Implement throttler interface. Throttler could be used to implement various reconnect strategies.
 */
 
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"math"

backoff_test.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"testing"

client.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"errors"

client_manager.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import "log"
 

client_test.go

@@ -1,12 +1,12 @@
-package mqtt_test // import "fluux.io/mqtt"
+package mqtt_test // import "gosrc.io/mqtt"
 
 import (
 	"log"
 	"net"
 	"testing"
 	"time"
 
-	"fluux.io/mqtt"
+	"gosrc.io/mqtt"
 )
 
 const (

control_packets.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"encoding/binary"

control_packets_test.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"bytes"

doc.go

@@ -5,4 +5,4 @@ You can use the MQTT client directly at the low-level and handle connection even
 If you want to have sane default behaviour for handling reconnect, you can directly rely on the connection manager
 struct.
 */
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"

encoding.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"encoding/binary"

encoding_test.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"bytes"

examples/mqtt_pub/mqtt_pub.go

@@ -12,7 +12,7 @@ import (
 	"syscall"
 	"time"
 
-	"fluux.io/mqtt"
+	"gosrc.io/mqtt"
 )
 
 func main() {

examples/mqtt_sub/mqtt_sub.go

@@ -7,7 +7,7 @@ package main
 import (
 	"log"
 
-	"fluux.io/mqtt"
+	"gosrc.io/mqtt"
 )
 
 func main() {

examples/mqtt_temp_sub/mqtt_temp_pub.go

@@ -10,7 +10,7 @@ import (
 	"strings"
 	"time"
 
-	"fluux.io/mqtt"
+	"gosrc.io/mqtt"
 )
 
 func main() {

keepalive.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import "time"
 

receiver.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"io"

sender.go

@@ -1,4 +1,4 @@
-package mqtt // import "fluux.io/mqtt"
+package mqtt // import "gosrc.io/mqtt"
 
 import (
 	"io"