jsonrpc

Documentation

Index

• func WithReconnectInterval(d time.Duration) func(c *Config)
• type ClientCloser
  • 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
• type ErrClient
  • func (e *ErrClient) Error() string
  • func (e *ErrClient) Unwrap(err error) error
• type Option
• type RPCServer
  • func NewServer() *RPCServer
  • func (s *RPCServer) Register(namespace string, handler interface{})
  • func (s *RPCServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func WithReconnectInterval

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

Types

type ClientCloser

type ClientCloser func()

ClientCloser is used to close Client from further use

func NewClient

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

NewClient creates new jsonrpc 2.0 client

handler must be pointer to a struct with function fields Returned value closes the client connection TODO: Example

func NewMergeClient

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

NewMergeClient is like NewClient, but allows to specify multiple structs to be filled in the same namespace, using one connection

type Config

type Config struct {
	ReconnectInterval time.Duration
	// contains filtered or unexported fields
}

type ErrClient

type ErrClient struct {
	// contains filtered or unexported fields
}

ErrClient is an error which occurred on the client side the library

func (*ErrClient) Error

func (e *ErrClient) Error() string

func (*ErrClient) Unwrap

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

Unwrap unwraps the actual error

type Option

type Option func(c *Config)

type RPCServer

type RPCServer struct {
	// contains filtered or unexported fields
}

RPCServer provides a jsonrpc 2.0 http server handler

func NewServer

func NewServer() *RPCServer

NewServer creates new RPCServer instance

func (*RPCServer) Register

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

Register registers new RPC handler

Handler is any value with methods defined

func (*RPCServer) ServeHTTP

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

TODO: return errors to clients per spec