jsonrpc

Aug 19, 2020

Changes in this version

type Server

+ func (s *Server) ErrHandler(h func(*Error))

Aug 17, 2020

Changes in this version

type Transport

+ func NewUDPClientTransport(header bool, raddr, laddr string) (Transport, error)

+ func NewUDPServerTransport(header bool, addr string) (Transport, error)

+ func NewUDPTransport(header bool, conn *net.UDPConn, connected bool) Transport

Jul 1, 2020

Changes in this version

type Server

+ func (s *Server) RegisterMatcher(m func(string) bool, f interface{})

Feb 26, 2020

Changes in this version

type Error

+ func NewErrorWithError(code int, err error) *Error

+ type ID struct

+ func (id *ID) Equal(val *ID) bool

+ func (id *ID) MarshalJSON() ([]byte, error)

+ func (id *ID) String() string

+ func (id *ID) UnmarshalJSON(data []byte) error

Feb 15, 2020

Changes in this version

+ var ErrInvalidHeader = errors.New("无效的报头格式")

Feb 13, 2020

Changes in this version

type Transport

+ Close func() error

Feb 11, 2020

Changes in this version

type Server

+ func (s *Server) RegisterBefore(f func(method string) error)

type Transport

+ func NewStreamTransport(in io.Reader, out io.Writer) Transport

Feb 4, 2020

Changes in this version

+ type HTTPConn struct

+ func (h *HTTPConn) Notify(method string, params interface{}) error

+ func (h *HTTPConn) Send(method string, params, result interface{}) error

+ func (h *HTTPConn) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) Exists(method string) bool

+ func (s *Server) NewConn(t Transport, errlog *log.Logger) *Conn

+ func (s *Server) NewHTTPConn(url string, errlog *log.Logger) *HTTPConn

+ func (s *Server) Register(method string, f interface{}) bool

+ func (s *Server) Registers(methods map[string]interface{})

Feb 1, 2020

Changes in this version

type HTTPClient

+ func (client *HTTPClient) Send(method string, params, result interface{}) error

Jan 31, 2020

Changes in this version

type Conn

+ func (conn *Conn) Exists(method string) bool

+ func (conn *Conn) Registers(methods map[string]interface{})

Jan 30, 2020

Changes in this version

+ const CodeInternalError

+ const CodeInvalidParams

+ const CodeInvalidRequest

+ const CodeMethodNotFound

+ const CodeParseError

+ const CodeServerErrorEnd

+ const CodeServerErrorStart

+ const CodeServerNotInitialized

+ const CodeUnknownErrorCode

+ const Version

+ var ErrInvalidContentType = errors.New("无效的报头 Content-Type")

+ var ErrMissContentLength = errors.New("缺少 Content-Length 报头")

+ type Conn struct

+ func NewConn(errlog *log.Logger) *Conn

+ func (conn *Conn) Notify(t Transport, method string, in interface{}) error

+ func (conn *Conn) Register(method string, f interface{}) bool

+ func (conn *Conn) Send(t Transport, method string, in, out interface{}) error

+ func (conn *Conn) Serve(ctx context.Context, t Transport) error

+ func (conn *Conn) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Error struct

+ Code int

+ Data interface{}

+ Message string

+ func NewError(code int, msg string) *Error

+ func NewErrorWithData(code int, msg string, data interface{}) *Error

+ func (err *Error) Error() string

+ type HTTPClient struct

+ func NewHTTPClient(path string) *HTTPClient

+ func (client *HTTPClient) Notify(method string, params interface{}) error

+ func (client *HTTPClient) Request(method string, params, result interface{}) error

+ type Transport interface

+ Read func(v interface{}) error

+ Write func(v interface{}) error

+ func NewHTTPTransport(w http.ResponseWriter, r *http.Request) Transport

+ func NewSocketTransport(conn net.Conn) Transport

+ func NewWebsocketTransport(conn *websocket.Conn) Transport