jsonrpc

Jan 26, 2023

Changes in this version

+ const ProxyTagNotify

+ const ProxyTagRPCMethod

+ const ProxyTagRetry

+ func DecodeParams(p RawParams) (T, error)

+ func ExtractReverseClient(ctx context.Context) (C, bool)

+ func WithClientHandler(ns string, hnd interface{}) func(c *Config)

+ func WithClientHandlerAlias(alias, original string) func(c *Config)

+ func WithHTTPClient(h *http.Client) func(c *Config)

+ type RawParams json.RawMessage

type ServerOption

+ func WithReverseClient(namespace string) ServerOption

+ func WithServerPingInterval(d time.Duration) ServerOption

Aug 18, 2022

Changes in this version

+ type RPCConnectionError struct

+ func (e *RPCConnectionError) Error() string

+ func (e *RPCConnectionError) Unwrap() error

Jul 19, 2022

Changes in this version

+ const FirstUserCode

+ func WithErrors(es Errors) func(c *Config)

+ type ErrorCode int

+ type Errors struct

+ func NewErrors() Errors

+ func (e *Errors) Register(c ErrorCode, typ interface{})

type ServerOption

+ func WithServerErrors(es Errors) ServerOption

Nov 26, 2020

Changes in this version

+ const DEFAULT_MAX_REQUEST_SIZE

+ func WithNoReconnect() func(c *Config)

+ func WithPingInterval(d time.Duration) func(c *Config)

+ func WithTimeout(d time.Duration) func(c *Config)

type RPCServer

+ func (s *RPCServer) AliasMethod(alias, original string)

type ServerOption

+ func WithMaxRequestSize(max int64) ServerOption

Jul 22, 2020

Changes in this version

+ func WithParamEncoder(t interface{}, encoder ParamEncoder) func(c *Config)

+ func WithReconnectBackoff(minDelay, maxDelay time.Duration) func(c *Config)

+ type ParamDecoder func(json []byte) (reflect.Value, error)

+ type ParamEncoder func(reflect.Value) (reflect.Value, error)

+ type ServerConfig struct

+ type ServerOption func(c *ServerConfig)

+ func WithParamDecoder(t interface{}, decoder ParamDecoder) ServerOption

May 20, 2020

Changes in this version

+ func WithReconnectInterval(d time.Duration) func(c *Config)

+ type ClientCloser func()

+ func NewClient(addr string, namespace string, handler interface{}, requestHeader http.Header) (ClientCloser, error)

+ func NewMergeClient(addr string, namespace string, outs []interface{}, requestHeader http.Header, ...) (ClientCloser, error)

+ type Config struct

+ ReconnectInterval time.Duration

+ type ErrClient struct

+ func (e *ErrClient) Error() string

+ func (e *ErrClient) Unwrap(err error) error

+ type Option func(c *Config)

+ type RPCServer struct

+ func NewServer() *RPCServer

+ func (s *RPCServer) Register(namespace string, handler interface{})

+ func (s *RPCServer) ServeHTTP(w http.ResponseWriter, r *http.Request)