service

Documentation

Index

• Variables
• func AddWebsocketHandler(urlPattern string, uri string) error
• func DefaultListenAndServeWebsocket() error
• func ListenAndServeWebsocket(addr string) error
• func ListenAndServeWebsocketSecure(addr string, cert string, key string) error
• func WebsocketTcpProxy(ws *websocket.Conn, nettype string, host string) error
• type OnCompleteFunc
• type OnPublishFunc
• type Server
  • func NewServer() (srv *Server, err error)
  • func (srv *Server) Close() error
  • func (srv *Server) ListenAndServe(network, address string) error

Variables

var (
	ErrInvalidConnectionType  error = errors.New("service: Invalid connection type")
	ErrInvalidSubscriber      error = errors.New("service: Invalid subscriber")
	ErrBufferNotReady         error = errors.New("service: buffer is not ready")
	ErrBufferInsufficientData error = errors.New("service: buffer has insufficient data.")
)

var (
	ErrServerClosed = errors.New("server: server closed")
)

Functions

func AddWebsocketHandler

func AddWebsocketHandler(urlPattern string, uri string) error

func DefaultListenAndServeWebsocket

func DefaultListenAndServeWebsocket() error

func ListenAndServeWebsocket

func ListenAndServeWebsocket(addr string) error

start a listener that proxies websocket <-> tcp

func ListenAndServeWebsocketSecure

func ListenAndServeWebsocketSecure(addr string, cert string, key string) error

starts an HTTPS listener

func WebsocketTcpProxy

func WebsocketTcpProxy(ws *websocket.Conn, nettype string, host string) error

handler that proxies websocket <-> unix domain socket

Types

type OnCompleteFunc

type OnCompleteFunc func(msg, ack message.Message, err error) error

type OnPublishFunc

type OnPublishFunc func(msg *message.PublishMessage) error

type Server

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

func NewServer

func NewServer() (srv *Server, err error)

func (*Server) Close

func (srv *Server) Close() error

Close terminates the server by shutting down all the client connections and closing the listener. It will, as best it can, clean up after itself.

func (*Server) ListenAndServe

func (srv *Server) ListenAndServe(network, address string) error