server

Documentation

Index

• func CreateListen(hp string, o *Opts) (net.Listener, error)
• func PrintProto(a []byte)
• type Args
  • func GetArgs() Args
  • func (a Args) GetFlag(v string) string
  • func (a Args) IndexOfFlag(v string) int
• type AssetsServer
  • func NewAssetsServer(conf *Opts) (*AssetsServer, error)
  • func (s *AssetsServer) Shutdown()
  • func (s *AssetsServer) Start() error
• type NatsServer
  • func NewNatsServer(o *Opts) (*NatsServer, error)
  • func (s *NatsServer) GetURL() string
  • func (s *NatsServer) HostPort() string
  • func (s *NatsServer) Shutdown()
  • func (s *NatsServer) Start() error
• type Opts
  • func DefaultOpts() Opts
  • func LoadOpts(fp string) (*Opts, error)
  • func ParseOpts(c string) (*Opts, error)
• type ProxyWorker
  • func NewProxyWorker(id uint64, ws *websocket.Conn, natsHostPort string, server *WsServer) (*ProxyWorker, error)
  • func (pw *ProxyWorker) Serve()
• type WsServer
  • func NewWsServer(opts *Opts) (*WsServer, error)
  • func (s *WsServer) GetURL() string
  • func (s *WsServer) Shutdown()
  • func (s *WsServer) Start() error

Functions

func CreateListen

func CreateListen(hp string, o *Opts) (net.Listener, error)

func PrintProto

func PrintProto(a []byte)

Types

type Args

type Args []string

func GetArgs

func GetArgs() Args

func (Args) GetFlag

func (a Args) GetFlag(v string) string

func (Args) IndexOfFlag

func (a Args) IndexOfFlag(v string) int

type AssetsServer

type AssetsServer struct {
	*Opts
	// contains filtered or unexported fields
}

func NewAssetsServer

func NewAssetsServer(conf *Opts) (*AssetsServer, error)

func (*AssetsServer) Shutdown

func (s *AssetsServer) Shutdown()

func (*AssetsServer) Start

func (s *AssetsServer) Start() error

type NatsServer

type NatsServer struct {
	*Opts
	// contains filtered or unexported fields
}

func NewNatsServer

func NewNatsServer(o *Opts) (*NatsServer, error)

func (*NatsServer) GetURL

func (s *NatsServer) GetURL() string

func (*NatsServer) HostPort

func (s *NatsServer) HostPort() string

func (*NatsServer) Shutdown

func (s *NatsServer) Shutdown()

func (*NatsServer) Start

func (s *NatsServer) Start() error

type Opts

type Opts struct {
	CaFile             string
	CertFile           string
	Debug              bool
	Dir                string
	KeyFile            string
	Logger             *logger.Logger
	PidDir             string
	Port               int
	RemoteNatsHostPort string
	NatsHostPort       string
	TextFrames         bool
	Trace              bool
	WSHostPort         string
}

func DefaultOpts

func DefaultOpts() Opts

func LoadOpts

func LoadOpts(fp string) (*Opts, error)

func ParseOpts

func ParseOpts(c string) (*Opts, 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 {
	*Opts
	// contains filtered or unexported fields
}

func NewWsServer

func NewWsServer(opts *Opts) (*WsServer, error)

func (*WsServer) GetURL

func (s *WsServer) GetURL() string

func (*WsServer) Shutdown

func (s *WsServer) Shutdown()

func (*WsServer) Start

func (s *WsServer) Start() error