Commons for HTTP handling



    This section is empty.


    View Source
    var (
    	RE_HEX     = regexp.MustCompile(`^(?i)[a-f0-9]+$`)
    	RE_EMAIL   = regexp.MustCompile(`^(?i)(` + dotAtom + `)@(` + dotAtom + `)$`)
    	RE_ADDRESS = regexp.MustCompile(`^(?i)[a-z0-9]{25,34}$`)
    	RE_HOST    = regexp.MustCompile(`^(?i)(` + domain + `)$`)


    func EventSubscriber

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

      EventSubscriber sets object that is used to subscribe / unsubscribe from events - not Goroutine-safe. If none given, default node's eventBus will be used.

      func GetParam

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

      func GetParamByteSlice

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

      func GetParamFloat64

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

      func GetParamInt32

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

      func GetParamInt64

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

      func GetParamRegexp

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

      func GetParamUint

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

      func GetParamUint64

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

      func NewWSConnection

      func NewWSConnection(baseConn *websocket.Conn, funcMap map[string]*RPCFunc,
      	logger *logging.Logger, options ...func(*wsConnection)) *wsConnection

        NewWSConnection wraps websocket.Conn.

        See the commentary on the func(*wsConnection) functions for a detailed description of how to configure ping period and pong wait time. NOTE: if the write buffer is full, pongs may be dropped, which may cause clients to disconnect. see

        func PingPeriod

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

          PingPeriod sets the duration for sending websocket pings. It should only be used in the constructor - not Goroutine-safe.

          func ReadWait

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

            ReadWait sets the amount of time to wait before a websocket read times out. It should only be used in the constructor - not Goroutine-safe.

            func RecoverAndLogHandler

            func RecoverAndLogHandler(handler http.Handler, logger *logging.Logger) http.Handler

              Wraps an HTTP handler, adding error logging. If the inner function panics, the outer function recovers, logs, sends an HTTP 500 error response.

              func RegisterRPCFuncs

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

                RegisterRPCFuncs adds a route for each function in the funcMap, as well as general jsonrpc and websocket handlers for all functions. "result" is the interface on which the result objects are registered, and is popualted with every RPCResponse

                func StartHTTPServer

                func StartHTTPServer(listener net.Listener, handler http.Handler, logger *logging.Logger) (*http.Server, error)

                func WriteChanCapacity

                func WriteChanCapacity(cap int) func(*wsConnection)

                  WriteChanCapacity sets the capacity of the websocket write channel. It should only be used in the constructor - not Goroutine-safe.

                  func WriteRPCResponseHTTP

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

                  func WriteWait

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

                    WriteWait sets the amount of time to wait before a websocket write times out. It should only be used in the constructor - not Goroutine-safe.


                    type RPCFunc

                    type RPCFunc struct {
                    	// contains filtered or unexported fields

                      RPCFunc contains the introspected type information for a function

                      func NewRPCFunc

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

                        NewRPCFunc wraps a function for introspection. f is the function, args are comma separated argument names

                        func NewWSRPCFunc

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

                          NewWSRPCFunc wraps a function for introspection and use in the websockets.

                          type ResponseWriterWrapper

                          type ResponseWriterWrapper struct {
                          	Status int

                            Remember the status for logging

                            func (*ResponseWriterWrapper) Hijack

                              implements http.Hijacker

                              func (*ResponseWriterWrapper) WriteHeader

                              func (w *ResponseWriterWrapper) WriteHeader(status int)

                              type WebsocketManager

                              type WebsocketManager struct {
                              	// contains filtered or unexported fields

                                WebsocketManager is the main manager for all websocket connections. It holds the event switch and a map of functions for routing. NOTE: The websocket path is defined externally, e.g. in node/node.go

                                func NewWebsocketManager

                                func NewWebsocketManager(funcMap map[string]*RPCFunc, logger *logging.Logger,
                                	wsConnOptions ...func(*wsConnection)) *WebsocketManager

                                  NewWebsocketManager returns a new WebsocketManager that routes according to the given funcMap and connects to the server with the given connection options.

                                  func (*WebsocketManager) WebsocketHandler

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

                                    WebsocketHandler upgrades the request/response (via http.Hijack) and starts the wsConnection.