Minor: Fix muxConnectManaNger typo (#145)

* Minor: Fix muxConnectManaNger typo

* gofmt

Author: temporal-nick

transport/mux_connection_manager.go

@@ -47,7 +47,7 @@ var (
 )
 
 type (
-	muxConnectMananger struct {
+	muxConnectManager struct {
 		config       config.MuxTransportConfig
 		muxTransport *muxTransportImpl
 		shutdownCh   chan struct{}
@@ -59,8 +59,8 @@ type (
 	}
 )
 
-func newMuxConnectManager(cfg config.MuxTransportConfig, logger log.Logger) *muxConnectMananger {
-	cm := &muxConnectMananger{
+func newMuxConnectManager(cfg config.MuxTransportConfig, logger log.Logger) *muxConnectManager {
+	cm := &muxConnectManager{
 		config: cfg,
 		logger: log.With(logger, tag.NewStringTag("Name", cfg.Name), tag.NewStringTag("Mode", string(cfg.Mode))),
 	}
@@ -69,7 +69,7 @@ func newMuxConnectManager(cfg config.MuxTransportConfig, logger log.Logger) *mux
 	return cm
 }
 
-func (m *muxConnectMananger) open() (MuxTransport, error) {
+func (m *muxConnectManager) open() (MuxTransport, error) {
 	if !m.isStarted() {
 		return nil, fmt.Errorf("connection manager is not running")
 	}
@@ -107,7 +107,7 @@ func (m *muxConnectMananger) open() (MuxTransport, error) {
 	return muxTransport, nil
 }
 
-func (m *muxConnectMananger) isShuttingDown() bool {
+func (m *muxConnectManager) isShuttingDown() bool {
 	select {
 	case <-m.shutdownCh:
 		return true
@@ -116,7 +116,7 @@ func (m *muxConnectMananger) isShuttingDown() bool {
 	}
 }
 
-func (m *muxConnectMananger) serverLoop(metricLabels []string, setting config.TCPServerSetting) error {
+func (m *muxConnectManager) serverLoop(metricLabels []string, setting config.TCPServerSetting) error {
 	var tlsConfig *tls.Config
 	var err error
 	if tlsCfg := setting.TLS; tlsCfg.IsEnabled() {
@@ -188,7 +188,7 @@ func (m *muxConnectMananger) serverLoop(metricLabels []string, setting config.TC
 	return nil
 }
 
-func (m *muxConnectMananger) clientLoop(metricLabels []string, setting config.TCPClientSetting) error {
+func (m *muxConnectManager) clientLoop(metricLabels []string, setting config.TCPClientSetting) error {
 	var tlsConfig *tls.Config
 	var err error
 	if tlsCfg := setting.TLS; tlsCfg.IsEnabled() {
@@ -286,7 +286,7 @@ func observeYamuxSession(session *yamux.Session, config config.MuxTransportConfi
 	}
 }
 
-func (m *muxConnectMananger) start() error {
+func (m *muxConnectManager) start() error {
 	if !m.status.CompareAndSwap(
 		int32(statusInitialized),
 		int32(statusStarted),
@@ -324,15 +324,15 @@ func (m *muxConnectMananger) start() error {
 	return nil
 }
 
-func (m *muxConnectMananger) isStarted() bool {
+func (m *muxConnectManager) isStarted() bool {
 	return m.getStatus() == statusStarted
 }
 
-func (m *muxConnectMananger) getStatus() status {
+func (m *muxConnectManager) getStatus() status {
 	return status(m.status.Load())
 }
 
-func (m *muxConnectMananger) stop() {
+func (m *muxConnectManager) stop() {
 	if !m.status.CompareAndSwap(
 		int32(statusStarted),
 		int32(statusStopped),
@@ -345,7 +345,7 @@ func (m *muxConnectMananger) stop() {
 	m.logger.Info("Connection manager stopped")
 }
 
-func (m *muxConnectMananger) waitForReconnect() {
+func (m *muxConnectManager) waitForReconnect() {
 	// Notify transport is connected
 	close(m.connectedCh)
 

transport/mux_connection_manager_test.go

@@ -60,7 +60,7 @@ func (s *service) DescribeCluster(ctx context.Context, in0 *adminservice.Describ
 	}, nil
 }
 
-func connect(t *testing.T, clientCM *muxConnectMananger, serverCM *muxConnectMananger) (MuxTransport, MuxTransport) {
+func connect(t *testing.T, clientCM *muxConnectManager, serverCM *muxConnectManager) (MuxTransport, MuxTransport) {
 	clientTs, err := clientCM.open()
 	require.NoError(t, err)
 	serverTs, err := serverCM.open()

transport/transport.go

@@ -31,7 +31,7 @@ type (
 	}
 
 	TransportManager struct {
-		muxConnManagers map[string]*muxConnectMananger
+		muxConnManagers map[string]*muxConnectManager
 		logger          log.Logger
 	}
 )
@@ -41,7 +41,7 @@ func NewTransportManager(
 	logger log.Logger,
 ) *TransportManager {
 
-	muxConnManagers := make(map[string]*muxConnectMananger)
+	muxConnManagers := make(map[string]*muxConnectManager)
 	s2sConfig := configProvider.GetS2SProxyConfig()
 	for _, cfg := range s2sConfig.MuxTransports {
 		muxConnManagers[cfg.Name] = newMuxConnectManager(cfg, logger)