Become VolantMQ

Signed-off-by: Artur Troian <[email protected]>

.gitignore

@@ -38,6 +38,6 @@ _testmain.go
 *.sublime-workspace
 
 persistence/examples/bolt/test.db
-examples/surgemq/persist.db
+examples/tcp/persist.db
 coverage.txt
 vendor

AUTHORS

@@ -1,4 +1,4 @@
-# This is the official list of SurgeMQ authors for copyright purposes.
+# This is the official list of VolantMQ authors for copyright purposes.
 
 # If you are submitting a patch, please add your name or the name of the
 # organization which holds the copyright to this list in alphabetical order.

CONTRIBUTING.md

@@ -2,12 +2,12 @@
 
 ## Reporting Issues
 
-Before creating a new Issue, please check first if a similar Issue [already exists](https://github.com/surgemq/message/issues?state=open) or was [recently closed](https://github.com/surgemq/message/issues?direction=desc&page=1&sort=updated&state=closed).
+Before creating a new Issue, please check first if a similar Issue [already exists](https://github.com/VolantMQ/volantmq/issues?state=open) or was [recently closed](https://github.com/VolantMQ/volantmq/issues?direction=desc&page=1&sort=updated&state=closed).
 
 [Gophers channel](https://gophers.slack.com/messages/C67KYG1RQ/)
 
 Please provide the following minimum information:
-* Your SurgeMQ version (or git SHA)
+* Your VolantMQ version (or git SHA)
 * Your Go version (run `go version` in your console)
 * A detailed issue description
 * Error Log if present
@@ -39,4 +39,4 @@ If it looks fine to you, comment with "LGTM" (Looks good to me).
 
 If changes are required, notice the reviewers with "PTAL" (Please take another look) after committing the fixes.
 
-Before merging the Pull Request, at least one [team member](https://github.com/orgs/surgemq/people) must have commented with "LGTM".
+Before merging the Pull Request, at least one [team member](https://github.com/orgs/VolantMQ/people) must have commented with "LGTM".

README.md

@@ -1,17 +1,17 @@
-SurgeMQ
+VolantMQ
 =======
 
-[![Build Status](https://travis-ci.org/troian/surgemq.svg?branch=master)](https://travis-ci.org/troian/surgemq)
-[![BCH compliance](https://bettercodehub.com/edge/badge/troian/surgemq?branch=master)](https://bettercodehub.com/)
-[![Codacy Badge](https://api.codacy.com/project/badge/Grade/1a43f2f6e0534fd180d0a1b0b8c93614)](https://www.codacy.com/app/troian/surgemq?utm_source=github.com&utm_medium=referral&utm_content=troian/surgemq&utm_campaign=Badge_Grade)
-[![codecov.io](https://codecov.io/gh/troian/surgemq/coverage.svg?branch=master)](https://codecov.io/gh/troian/surgemq?branch=master)
+[![Build Status](https://travis-ci.org/volantmq/volantmq.svg?branch=master)](https://travis-ci.org/volantmq/volantmq)
+[![BCH compliance](https://bettercodehub.com/edge/badge/volantmq/volantmq?branch=master)](https://bettercodehub.com/)
+[![Codacy Badge](https://api.codacy.com/project/badge/Grade/1a43f2f6e0534fd180d0a1b0b8c93614)](https://www.codacy.com/app/volantmq/volantmq?utm_source=github.com&utm_medium=referral&utm_content=volantmq/volantmq&utm_campaign=Badge_Grade)
+[![codecov.io](https://codecov.io/gh/volantmq/volantmq/coverage.svg?branch=master)](https://codecov.io/gh/volantmq/volantmq?branch=master)
 [![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg)](https://opensource.org/licenses/Apache-2.0)
 
 ### Warning
 **It's currently in active development thus highly not recommended for production**
 **This project should be considered unstable until further notice.**
 
-SurgeMQ is a high performance MQTT broker that aims to be fully compliant with MQTT 3.1 and 3.1.1 specs .
+VolantMQ is a high performance MQTT broker that aims to be fully compliant with MQTT 3.1 and 3.1.1 specs .
 
 ### Features, Limitations, and Future
 
@@ -37,7 +37,7 @@ TBD
 
 ### Compatibility
 
-SurgeMQ has been tested with the following client libraries
+Project has been tested with the following client libraries
 * Paho MQTT Conformance/Interoperability Testing Suite (in Python)
   * Pass with all of the test cases
 * Paho C Client library (in C)
@@ -63,6 +63,6 @@ limitations under the License.
 
 ### Examples
 
-Look into examples/surgemq
+Look into examples
 
-### [Contributing guidelines](https://github.com/troian/surgemq/blob/master/CONTRIBUTING.md)
+### [Contributing guidelines](https://github.com/volantmq/volantmq/blob/master/CONTRIBUTING.md)

clients/session.go

@@ -10,13 +10,13 @@ import (
 
 	"unsafe"
 
-	"github.com/troian/surgemq/auth"
-	"github.com/troian/surgemq/connection"
-	"github.com/troian/surgemq/packet"
-	"github.com/troian/surgemq/persistence/types"
-	"github.com/troian/surgemq/subscriber"
-	"github.com/troian/surgemq/systree"
-	"github.com/troian/surgemq/types"
+	"github.com/VolantMQ/volantmq/auth"
+	"github.com/VolantMQ/volantmq/connection"
+	"github.com/VolantMQ/volantmq/packet"
+	"github.com/VolantMQ/volantmq/persistence/types"
+	"github.com/VolantMQ/volantmq/subscriber"
+	"github.com/VolantMQ/volantmq/systree"
+	"github.com/VolantMQ/volantmq/types"
 )
 
 type exitReason int

clients/sessions.go

@@ -12,14 +12,14 @@ import (
 	"time"
 	"unsafe"
 
-	"github.com/troian/surgemq/auth"
-	"github.com/troian/surgemq/configuration"
-	"github.com/troian/surgemq/packet"
-	"github.com/troian/surgemq/persistence/types"
-	"github.com/troian/surgemq/routines"
-	"github.com/troian/surgemq/subscriber"
-	"github.com/troian/surgemq/systree"
-	"github.com/troian/surgemq/topics/types"
+	"github.com/VolantMQ/volantmq/auth"
+	"github.com/VolantMQ/volantmq/configuration"
+	"github.com/VolantMQ/volantmq/packet"
+	"github.com/VolantMQ/volantmq/persistence/types"
+	"github.com/VolantMQ/volantmq/routines"
+	"github.com/VolantMQ/volantmq/subscriber"
+	"github.com/VolantMQ/volantmq/systree"
+	"github.com/VolantMQ/volantmq/topics/types"
 	"go.uber.org/zap"
 )
 

connection/ack.go

@@ -3,7 +3,7 @@ package connection
 import (
 	"sync"
 
-	"github.com/troian/surgemq/packet"
+	"github.com/VolantMQ/volantmq/packet"
 )
 
 type onRelease func(msg packet.Provider)

connection/connection.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2014 The SurgeMQ Authors. All rights reserved.
+// Copyright (c) 2014 The VolantMQ Authors. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -20,13 +20,13 @@ import (
 	"sync"
 	"time"
 
-	"github.com/troian/surgemq/auth"
-	"github.com/troian/surgemq/configuration"
-	"github.com/troian/surgemq/packet"
-	"github.com/troian/surgemq/persistence/types"
-	"github.com/troian/surgemq/subscriber"
-	"github.com/troian/surgemq/systree"
-	"github.com/troian/surgemq/types"
+	"github.com/VolantMQ/volantmq/auth"
+	"github.com/VolantMQ/volantmq/configuration"
+	"github.com/VolantMQ/volantmq/packet"
+	"github.com/VolantMQ/volantmq/persistence/types"
+	"github.com/VolantMQ/volantmq/subscriber"
+	"github.com/VolantMQ/volantmq/systree"
+	"github.com/VolantMQ/volantmq/types"
 	"go.uber.org/zap"
 )
 

connection/flowControl.go

@@ -5,7 +5,7 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"github.com/troian/surgemq/packet"
+	"github.com/VolantMQ/volantmq/packet"
 )
 
 type packetsFlowControl struct {

connection/netCallbacks.go

@@ -4,10 +4,10 @@ import (
 	"container/list"
 	"sync/atomic"
 
-	"github.com/troian/surgemq/auth"
-	"github.com/troian/surgemq/packet"
-	"github.com/troian/surgemq/persistence/types"
-	"github.com/troian/surgemq/subscriber"
+	"github.com/VolantMQ/volantmq/auth"
+	"github.com/VolantMQ/volantmq/packet"
+	"github.com/VolantMQ/volantmq/persistence/types"
+	"github.com/VolantMQ/volantmq/subscriber"
 	"go.uber.org/zap"
 )
 

connection/receiver.go

@@ -9,7 +9,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/troian/surgemq/packet"
+	"github.com/VolantMQ/volantmq/packet"
 )
 
 type receiverConfig struct {

connection/transmitter.go

@@ -8,7 +8,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/troian/surgemq/packet"
+	"github.com/VolantMQ/volantmq/packet"
 	"go.uber.org/zap"
 )
 

doc.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2014 The SurgeMQ Authors. All rights reserved.
+// Copyright (c) 2014 The VolantMQ Authors. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-// Package surgemq is a high performance MQTT broker and client library that aims to be
+// Package volantmq is a high performance MQTT broker and client library that aims to be
 // fully compliant with MQTT 3.1 and 3.1.1 specs.
 //
 // The primary package that's of interest is package service. It provides the
@@ -44,28 +44,25 @@
 //     network traffic.
 //   - A mechanism to notify interested parties when an abnormal disconnection occurs.
 //
-// Current performance benchmark of SurgeMQ, running all publishers, subscribers
+// Current performance benchmark of VolantMQ, running all publishers, subscribers
 // and broker on a single 4-core (2.8Ghz i7) MacBook Pro, is able to achieve:
 //   - over 400,000 MPS in a 1:1 single publisher and single producer configuration
 //   - over 450,000 MPS in a 20:1 fan-in configuration
 //   - over 750,000 MPS in a 1:20 fan-out configuration
 //   - over 700,000 MPS in a full mesh configuration with 20 clients
 //
-// In addition, SurgeMQ has been tested with the following client libraries and
+// In addition, VolantMQ has been tested with the following client libraries and
 // it _seems_ to work:
 //   - libmosquitto 1.3.5 (C)
 //     - Tested with the bundled test programs msgsps_pub and msgsps_sub
 //   - Paho MQTT Conformance/Interoperability Testing Suite (Python)
-//     - Tested with all 10 test cases, 3 did not pass. They are
-//       1) offline_message_queueing_test which is not supported by SurgeMQ,
-//       2) redelivery_on_reconnect_test which is not yet implemented by SurgeMQ,
-//       3) run_subscribe_failure_test which is not a valid test.
+//     - Tested with all 10 test cases.
 //   - Paho Go Client Library (Go)
 //     - Tested with one of the tests in the library, in fact, that tests is now
-//       part of the tests for SurgeMQ
+//       part of the tests for VolantMQ
 //   - Paho C Client library (C)
 //     - Tested with most of the test cases and failed the same ones as the
 //       conformance test because the features are not yet implemented.
 //     - Actually I think there's a bug in the test suite as it calls the PUBLISH
 //       handler function for non-PUBLISH messages.
-package surgemq
+package volantmq

examples/tcp&ws/auth.go

@@ -1,6 +1,6 @@
 package main
 
-import "github.com/troian/surgemq/auth"
+import "github.com/VolantMQ/volantmq/auth"
 
 type internalAuth struct {
 	creds map[string]string

examples/tcp&ws/surgemq.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2014 The SurgeMQ Authors. All rights reserved.
+// Copyright (c) 2014 The VolantMQ Authors. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -19,12 +19,12 @@ import (
 	"os/signal"
 	"syscall"
 
+	"github.com/VolantMQ/volantmq"
+	"github.com/VolantMQ/volantmq/auth"
+	"github.com/VolantMQ/volantmq/configuration"
+	"github.com/VolantMQ/volantmq/persistence/types"
+	"github.com/VolantMQ/volantmq/transport"
 	"github.com/spf13/viper"
-	"github.com/troian/surgemq"
-	"github.com/troian/surgemq/auth"
-	"github.com/troian/surgemq/configuration"
-	"github.com/troian/surgemq/persistence/types"
-	"github.com/troian/surgemq/transport"
 	"go.uber.org/zap"
 
 	_ "net/http/pprof"
@@ -78,21 +78,21 @@ func main() {
 		os.Exit(1)
 	}
 
-	var srv surgemq.Server
+	var srv volantmq.Server
 
 	listenerStatus := func(id string, status string) {
 		logger.Info("Listener status", zap.String("id", id), zap.String("status", status))
 	}
 
-	serverConfig := surgemq.NewServerConfig()
+	serverConfig := volantmq.NewServerConfig()
 
 	serverConfig.OfflineQoS0 = true
 	serverConfig.Persistence = &persistenceTypes.MemConfig{}
 	serverConfig.TransportStatus = listenerStatus
 	serverConfig.AllowDuplicates = true
 	serverConfig.Authenticators = "internal"
 
-	srv, err = surgemq.NewServer(serverConfig)
+	srv, err = volantmq.NewServer(serverConfig)
 
 	if err != nil {
 		logger.Error("Couldn't create server", zap.Error(err))