manager

Documentation

Index

• Variables
• func BackendWSdataSession(conn *websocket.Conn, backendChannel chan string)
• func FrontendWSdataSession(conn *websocket.Conn, clientChannel chan string, backendChannel chan string)
• func InitDataSession(muxServer *http.ServeMux, regData RegData) (dataConn *websocket.Conn)
• func RegisterAsTransportMgr(regData *RegData, protocol string)
• type ClientHandler
• type ClientServer
• type HttpChannel
• type HttpServer
  • func (server HttpServer) InitClientServer(muxServer *http.ServeMux)
• type HttpWSsession
  • func (httpCoreSocketSession HttpWSsession) TransportHubFrontendWSsession(dataConn *websocket.Conn, appClientChannel []chan string)
• type RegData
• type TransportHubFrontendWSSession
• type WsChannel
• type WsServer
  • func (server WsServer) InitClientServer(muxServer *http.ServeMux, serverIndex *int)
• type WsWSsession
  • func (wsCoreSocketSession WsWSsession) TransportHubFrontendWSsession(dataConn *websocket.Conn, appClientChannel []chan string)

Variables

var AppClientChan = []chan string{
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
	make(chan string),
}

the number of channel array elements sets the limit for max number of parallel WS app clients

var HostIP string

var MuxServer = []*http.ServeMux{
	http.NewServeMux(),
	http.NewServeMux(),
}

var TransportErrorMessage string

var Upgrader = websocket.Upgrader{
	ReadBufferSize:  1024,
	WriteBufferSize: 1024,
}

Functions

func BackendWSdataSession

func BackendWSdataSession(conn *websocket.Conn, backendChannel chan string)

func FrontendWSdataSession

func FrontendWSdataSession(conn *websocket.Conn, clientChannel chan string, backendChannel chan string)

func InitDataSession

func InitDataSession(muxServer *http.ServeMux, regData RegData) (dataConn *websocket.Conn)

func RegisterAsTransportMgr

func RegisterAsTransportMgr(regData *RegData, protocol string)

* * registerAsTransportMgr: * Registers with servercore as WebSocket protocol manager, and stores response in regData *

Types

type ClientHandler

type ClientHandler interface {
	// contains filtered or unexported methods
}

********************************************************************* Client response handlers *********************

type ClientServer

type ClientServer interface {
	InitClientServer(muxServer *http.ServeMux)
}

type HttpChannel

type HttpChannel struct {
}

type HttpServer

type HttpServer struct {
}

func (HttpServer) InitClientServer

func (server HttpServer) InitClientServer(muxServer *http.ServeMux)

type HttpWSsession

type HttpWSsession struct {
}

func (HttpWSsession) TransportHubFrontendWSsession

func (httpCoreSocketSession HttpWSsession) TransportHubFrontendWSsession(dataConn *websocket.Conn, appClientChannel []chan string)

type RegData

type RegData struct {
	Portnum int
	Urlpath string
	Mgrid   int
}

type TransportHubFrontendWSSession

type TransportHubFrontendWSSession interface {
	// contains filtered or unexported methods
}

**********Server Core Communications *******************************************************************************

type WsChannel

type WsChannel struct {
	// contains filtered or unexported fields
}

type WsServer

type WsServer struct {
	ClientBackendChannel []chan string
}

func (WsServer) InitClientServer

func (server WsServer) InitClientServer(muxServer *http.ServeMux, serverIndex *int)

type WsWSsession

type WsWSsession struct {
	ClientBackendChannel []chan string
}

func (WsWSsession) TransportHubFrontendWSsession

func (wsCoreSocketSession WsWSsession) TransportHubFrontendWSsession(dataConn *websocket.Conn, appClientChannel []chan string)