Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpc

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 23, 2017

v1.1.0

Aug 7, 2017

v1.0.1

Mar 17, 2017

Changes in this version

+ const DefaultHTTPApis

+ const DefaultIPCApis

+ const JSONRPCVersion

+ const LatestBlockNumber

+ const MetadataApi

+ const PendingBlockNumber

+ var ErrNotificationNotFound = errors.New("notification not found")

+ var ErrNotificationsUnsupported = errors.New("notifications not supported")

+ func CreateIPCListener(endpoint string) (net.Listener, error)

+ func NewHTTPServer(corsString string, srv *Server) *http.Server

+ func NewWSServer(allowedOrigins string, handler *Server) *http.Server

+ func SupportedModules(client Client) (map[string]string, error)

+ type API struct

+ Namespace string

+ Public bool

+ Service interface{}

+ Version string

+ type BlockNumber int64

+ func (bn *BlockNumber) Int64() int64

+ func (bn *BlockNumber) UnmarshalJSON(data []byte) error

+ type Client interface

+ Close func()

+ Recv func(msg interface{}) error

+ Send func(req interface{}) error

+ SupportedModules func() (map[string]string, error)

+ func NewHTTPClient(endpoint string) (Client, error)

+ func NewIPCClient(endpoint string) (Client, error)

+ func NewInProcRPCClient(handler *Server) Client

+ func NewWSClient(endpoint string) (Client, error)

+ type CodecOption int

+ const OptionMethodInvocation

+ const OptionSubscriptions

+ type HexNumber big.Int

+ func NewHexNumber(val interface{}) *HexNumber

+ func (h *HexNumber) BigInt() *big.Int

+ func (h *HexNumber) Int() int

+ func (h *HexNumber) Int64() int64

+ func (h *HexNumber) MarshalJSON() ([]byte, error)

+ func (h *HexNumber) Uint() uint

+ func (h *HexNumber) Uint64() uint64

+ func (h *HexNumber) UnmarshalJSON(input []byte) error

+ type JSONErrResponse struct

+ Error JSONError

+ Id interface{}

+ Version string

+ type JSONError struct

+ Code int

+ Data interface{}

+ Message string

+ type JSONRequest struct

+ Id json.RawMessage

+ Method string

+ Payload json.RawMessage

+ Version string

+ type JSONSuccessResponse struct

+ Id interface{}

+ Result interface{}

+ Version string

+ type Notifier interface

+ NewSubscription func(UnsubscribeCallback) (Subscription, error)

+ Unsubscribe func(id string) error

+ func NotifierFromContext(ctx context.Context) (Notifier, bool)

+ type RPCError interface

+ Code func() int

+ Error func() string

+ type RPCService struct

+ func (s *RPCService) Modules() map[string]string

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) RegisterName(name string, rcvr interface{}) error

+ func (s *Server) ServeCodec(codec ServerCodec, options CodecOption)

+ func (s *Server) ServeSingleRequest(codec ServerCodec, options CodecOption)

+ func (s *Server) Stop()

+ type ServerCodec interface

+ Close func()

+ Closed func() <-chan interface{}

+ CreateErrorResponse func(interface{}, RPCError) interface{}

+ CreateErrorResponseWithInfo func(id interface{}, err RPCError, info interface{}) interface{}

+ CreateNotification func(string, interface{}) interface{}

+ CreateResponse func(interface{}, interface{}) interface{}

+ ParseRequestArguments func([]reflect.Type, interface{}) ([]reflect.Value, RPCError)

+ ReadRequestHeaders func() ([]rpcRequest, bool, RPCError)

+ Write func(interface{}) error

+ func NewJSONCodec(rwc io.ReadWriteCloser) ServerCodec

+ type Subscription interface

+ Cancel func() error

+ ID func() string

+ Notify func(data interface{}) error

+ type UnsubscribeCallback func(id string)

Incompatible versions in this module

v3.9.9+incompatible

Mar 25, 2020

v2.9.0+incompatible

Jan 24, 2019

v2.8.1+incompatible

Jan 8, 2019

v2.7.1+incompatible

Jan 5, 2019

v2.7.0+incompatible

Jan 3, 2019

v2.6.2+incompatible

Mar 19, 2018

v2.6.0+incompatible

Feb 23, 2018

v2.5.1+incompatible

Nov 8, 2017

v2.5.0+incompatible

Nov 4, 2017

v2.0.0+incompatible

Sep 3, 2017