@@ -1,7 +1,7 @@
package cpn
import (
- "git.wanbits.io/joe/nnet"
+ "git.wenlab.co/joe/nnet"
)
func NewTcpClient(cf *nnet.HubConfig, cb nnet.ISessionCallback, p nnet.IProtocol, opts ...ClientOption) nnet.IHub {
@@ -1,10 +1,11 @@
- "github.com/gorilla/websocket"
"net"
"time"
+
+ "github.com/gorilla/websocket"
const (
"math/rand"
"sync"
type Hub struct {
@@ -2,8 +2,9 @@ package cpn
type TcpServer struct {
@@ -3,9 +3,9 @@ package cpn
"net/http"
"github.com/gorilla/mux"
"github.com/gorilla/websocket"
type CallbackWsPath func(http.ResponseWriter, *http.Request)
@@ -1,11 +1,12 @@
"sync/atomic"
@@ -1,6 +1,6 @@
-module git.wanbits.io/joe/nnet
+module git.wenlab.co/joe/nnet
-go 1.15
+go 1.17
require (
github.com/gorilla/mux v1.8.0
@@ -3,12 +3,13 @@ package main
"bufio"
"fmt"
- "git.wanbits.io/joe/nnet/cpn"
"net/url"
"os"
"strings"
+ "git.wenlab.co/joe/nnet/cpn"
var (
@@ -5,7 +5,8 @@ import (
"encoding/json"
"io"
type EchoPacket struct {
"os/signal"
"syscall"