Add.generic.msg.sink (#797)

* reworks MsgMux

- rename MsgMux to ConnMux, as it muxes Conns
- rename sinkId to connId, as that is the language of Conn's
- add doc
- add generic meta data for MsgSink
- remove jwt refreshing client test program

Author: andrewpmartinez

xgress/xgress.go

@@ -61,7 +61,7 @@ type AckSender interface {
 
 type OptionsData map[interface{}]interface{}
 
-// The BindHandlers are invoked to install the appropriate handlers.
+// BindHandler is an interface invoked to install the appropriate handlers.
 type BindHandler interface {
 	HandleXgressBind(x *Xgress)
 }
@@ -923,7 +923,7 @@ func (self *Xgress) SendEmptyAck() {
 func (self *Xgress) GetSequence() uint64 {
 	self.rxSequenceLock.Lock()
 	defer self.rxSequenceLock.Unlock()
-	return uint64(self.rxSequence)
+	return self.rxSequence
 }
 
 func (self *Xgress) getLastBufferSizeSent() uint32 {

ziti/edge/conn.go

@@ -18,10 +18,6 @@ package edge
 
 import (
 	"fmt"
-	"github.com/openziti/edge-api/rest_model"
-	"github.com/openziti/foundation/v2/concurrenz"
-	"github.com/openziti/sdk-golang/xgress"
-	"github.com/openziti/secretstream/kx"
 	"io"
 	"net"
 	"os"
@@ -31,7 +27,11 @@ import (
 	"github.com/google/uuid"
 	"github.com/michaelquigley/pfxlog"
 	"github.com/openziti/channel/v4"
+	"github.com/openziti/edge-api/rest_model"
+	"github.com/openziti/foundation/v2/concurrenz"
 	"github.com/openziti/foundation/v2/sequence"
+	"github.com/openziti/sdk-golang/xgress"
+	"github.com/openziti/secretstream/kx"
 )
 
 const (