manager

package module
v0.0.0-...-c41bede Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 5, 2019 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

View Source
var HostIP string
View Source
var MuxServer = []*http.ServeMux{
	http.NewServeMux(),
	http.NewServeMux(),
}
View Source
var TransportErrorMessage string
View Source
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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL