jsonrpc

Jan 8, 2026

Changes in this version

+ func WithClientHandlerFormatter(namer MethodNameFormatter) func(c *Config)

Apr 8, 2025

Changes in this version

+ var DefaultMethodNameFormatter = NewMethodNameFormatter(true, OriginalCase)

+ func WithMethodNameFormatter(namer MethodNameFormatter) func(c *Config)

+ type CaseStyle int

+ const LowerFirstCharCase

+ const OriginalCase

+ type MethodNameFormatter func(namespace, method string) string

+ func NewMethodNameFormatter(includeNamespace bool, nameCase CaseStyle) MethodNameFormatter

type ServerOption

+ func WithServerMethodNameFormatter(formatter MethodNameFormatter) ServerOption

Oct 24, 2024

Changes in this version

+ type JSONRPCError struct

+ Code ErrorCode

+ Data interface{}

+ Message string

+ Meta json.RawMessage

+ func (e *JSONRPCError) Error() string

+ type RPCErrorCodec interface

+ FromJSONRPCError func(JSONRPCError) error

+ ToJSONRPCError func() (JSONRPCError, error)

Aug 5, 2024

Changes in this version

+ type ConnectionType string

+ const ConnectionTypeHTTP

+ const ConnectionTypeUnknown

+ const ConnectionTypeWS

+ func GetConnectionType(ctx context.Context) ConnectionType

type ServerOption

+ func WithTracer(l Tracer) ServerOption

+ type Tracer func(method string, params []reflect.Value, results []reflect.Value, err error)

Jun 6, 2024

Changes in this version

type ClientCloser

+ func NewCustomClient(namespace string, outs []interface{}, ...) (ClientCloser, error)

type RPCServer

+ func (s *RPCServer) HandleRequest(ctx context.Context, r io.Reader, w io.Writer)

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)