rpcserver

Apr 6, 2018

Changes in this version

+ func StartHTTPAndTLSServer(listenAddr string, handler http.Handler, certFile, keyFile string, ...) (listener net.Listener, err error)

Dec 12, 2017

Changes in this version

+ func EventSubscriber(eventSub types.EventSubscriber) func(*wsConnection)

Dec 6, 2017

Changes in this version

+ func OnDisconnect(cb func(remoteAddr string)) func(*wsConnection)

Sep 5, 2017

Changes in this version

+ func PingPeriod(pingPeriod time.Duration) func(*wsConnection)

+ func ReadWait(readWait time.Duration) func(*wsConnection)

+ func WriteChanCapacity(cap int) func(*wsConnection)

+ func WriteWait(writeWait time.Duration) func(*wsConnection)

Jun 3, 2017

Changes in this version

+ var RE_ADDRESS = regexp.MustCompile(`^(?i)[a-z0-9]{25,34}$`)

+ var RE_EMAIL = regexp.MustCompile(`^(?i)(` + dotAtom + `)@(` + dotAtom + `)$`)

+ var RE_HEX = regexp.MustCompile(`^(?i)[a-f0-9]+$`)

+ var RE_HOST = regexp.MustCompile(`^(?i)(` + domain + `)$`)

+ func GetParam(r *http.Request, param string) string

+ func GetParamByteSlice(r *http.Request, param string) ([]byte, error)

+ func GetParamFloat64(r *http.Request, param string) (float64, error)

+ func GetParamInt32(r *http.Request, param string) (int32, error)

+ func GetParamInt64(r *http.Request, param string) (int64, error)

+ func GetParamRegexp(r *http.Request, param string, re *regexp.Regexp) (string, error)

+ func GetParamUint(r *http.Request, param string) (uint, error)

+ func GetParamUint64(r *http.Request, param string) (uint64, error)

+ func NewWSConnection(baseConn *websocket.Conn, funcMap map[string]*RPCFunc, evsw events.EventSwitch) *wsConnection

+ func RecoverAndLogHandler(handler http.Handler, logger log.Logger) http.Handler

+ func RegisterRPCFuncs(mux *http.ServeMux, funcMap map[string]*RPCFunc, logger log.Logger)

+ func StartHTTPServer(listenAddr string, handler http.Handler, logger log.Logger) (listener net.Listener, err error)

+ func WriteRPCResponseHTTP(w http.ResponseWriter, res types.RPCResponse)

+ func WriteRPCResponseHTTPError(w http.ResponseWriter, httpCode int, res types.RPCResponse)

+ type RPCFunc struct

+ func NewRPCFunc(f interface{}, args string) *RPCFunc

+ func NewWSRPCFunc(f interface{}, args string) *RPCFunc

+ type ResponseWriterWrapper struct

+ Status int

+ func (w *ResponseWriterWrapper) Hijack() (net.Conn, *bufio.ReadWriter, error)

+ func (w *ResponseWriterWrapper) WriteHeader(status int)

+ type WebsocketManager struct

+ func NewWebsocketManager(funcMap map[string]*RPCFunc, evsw events.EventSwitch) *WebsocketManager

+ func (wm *WebsocketManager) SetLogger(l log.Logger)

+ func (wm *WebsocketManager) WebsocketHandler(w http.ResponseWriter, r *http.Request)