Versions in this module Expand all Collapse all v0 v0.0.6 Feb 7, 2023 v0.0.5 Feb 7, 2023 Changes in this version + const DEFAULT_MAX_REQUEST_SIZE + const FirstUserCode + func WithErrors(es Errors) 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() error + type ErrorCode int + type Errors struct + func NewErrors() Errors + func (e *Errors) Register(c ErrorCode, typ interface{}) + 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 RPCConnectionError struct + func (e *RPCConnectionError) Error() string + func (e *RPCConnectionError) Unwrap() 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 + func WithServerErrors(es Errors) ServerOption
Go to main page