server

Documentation

Index

• type Conf
• type NatsServer
  • func NewNatsServer() (*NatsServer, error)
  • func (server *NatsServer) GetURL() string
  • func (server *NatsServer) HostPort() string
  • func (server *NatsServer) ServerPort() int
  • func (server *NatsServer) Shutdown()
  • func (server *NatsServer) Start() error
• type ProxyWorker
  • func NewProxyWorker(id uint64, ws *websocket.Conn, natsHostPort string, server *WsServer) (*ProxyWorker, error)
  • func (pw *ProxyWorker) Serve()
• type WsServer
  • func NewWsServer(conf Conf, Logger *logger.Logger) (*WsServer, error)
  • func (ws *WsServer) GetURL() string
  • func (ws *WsServer) Shutdown()
  • func (ws *WsServer) Start(natsHostPort string) error

Types

type Conf

type Conf struct {
	HostPort string
	CertFile string
	KeyFile  string
	CaFile   string
	Text     bool
	Debug    bool
	Trace    bool
	Logger   *logger.Logger
}

type NatsServer

type NatsServer struct {
	Server *server.Server
	Logger *logger.Logger
}

func NewNatsServer

func NewNatsServer() (*NatsServer, error)

func (*NatsServer) GetURL

func (server *NatsServer) GetURL() string

func (*NatsServer) HostPort

func (server *NatsServer) HostPort() string

func (*NatsServer) ServerPort

func (server *NatsServer) ServerPort() int

func (*NatsServer) Shutdown

func (server *NatsServer) Shutdown()

func (*NatsServer) Start

func (server *NatsServer) Start() error

type ProxyWorker

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

func NewProxyWorker

func NewProxyWorker(id uint64, ws *websocket.Conn, natsHostPort string, server *WsServer) (*ProxyWorker, error)

func (*ProxyWorker) Serve

func (pw *ProxyWorker) Serve()

type WsServer

type WsServer struct {
	Logger *logger.Logger
	Conf
	// contains filtered or unexported fields
}

func NewWsServer

func NewWsServer(conf Conf, Logger *logger.Logger) (*WsServer, error)

func (*WsServer) GetURL

func (ws *WsServer) GetURL() string

func (*WsServer) Shutdown

func (ws *WsServer) Shutdown()

func (*WsServer) Start

func (ws *WsServer) Start(natsHostPort string) error