Versions in this module Expand all Collapse all v0 v0.1.6 Sep 29, 2021 Changes in this version + const DEFAULT_MAX_REQUEST_SIZE + func WithIgnoreID() func(c *Config) + func WithNoReconnect() func(c *Config) + func WithParamEncoder(t interface{}, encoder ParamEncoder) func(c *Config) + func WithPingInterval(d time.Duration) func(c *Config) + func WithReconnectBackoff(minDelay, maxDelay time.Duration) func(c *Config) + func WithTimeout(d time.Duration) func(c *Config) + type ClientCloser func() + func NewClient(ctx context.Context, addr string, namespace string, handler interface{}, ...) (ClientCloser, error) + func NewMergeClient(ctx context.Context, addr string, namespace string, outs []interface{}, ...) (ClientCloser, error) + type Config struct + type ErrClient struct + func (e *ErrClient) Error() string + func (e *ErrClient) Unwrap(err error) error + type Option func(c *Config) + type ParamDecoder func(ctx context.Context, json []byte) (reflect.Value, error) + type ParamEncoder func(reflect.Value) (reflect.Value, error) + type RPCServer struct + func NewServer(opts ...ServerOption) *RPCServer + func (s *RPCServer) AliasMethod(alias, original string) + func (s *RPCServer) Register(namespace string, handler interface{}) + func (s *RPCServer) ServeHTTP(w http.ResponseWriter, r *http.Request) + type ServerConfig struct + type ServerOption func(c *ServerConfig) + func WithMaxRequestSize(max int64) ServerOption + func WithParamDecoder(t interface{}, decoder ParamDecoder) ServerOption