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

rpctypes

package

Go to main page

Versions in this module

v1

v1.1.0

Aug 8, 2019

v1.0.0

Apr 30, 2019

Changes in this version

type RPCResponse

+ Method string

+ Params json.RawMessage

+ func NewJsonEventNotifyResponse(subscriptionID string, result interface{}) (RPCResponse, error)

+ type Subscription struct

+ ID string

+ func NewSubscription(ID string, eventChan chan interface{}, ...) *Subscription

+ func (sub *Subscription) EventChan() chan interface{}

+ func (sub *Subscription) QuitChan() chan interface{}

+ func (sub *Subscription) Stop()

+ func (sub *Subscription) Subscribers() map[types.EventType]types.Subscriber

v0

v0.2.0

Dec 11, 2018

Changes in this version

+ func SocketType(listenAddr string) string

+ type EventSubscriber interface

+ Subscribe func(ctx context.Context, subscriber string, query tmpubsub.Query, ...) error

+ Unsubscribe func(ctx context.Context, subscriber string, query tmpubsub.Query) error

+ UnsubscribeAll func(ctx context.Context, subscriber string) error

+ type RPCError struct

+ Code int

+ Data string

+ Message string

+ func (err RPCError) Error() string

+ type RPCRequest struct

+ ID interface{}

+ JSONRPC string

+ Method string

+ Params json.RawMessage

+ func ArrayToRequest(cdc *amino.Codec, id interface{}, method string, params []interface{}) (RPCRequest, error)

+ func MapToRequest(cdc *amino.Codec, id interface{}, method string, params map[string]interface{}) (RPCRequest, error)

+ func NewRPCRequest(id interface{}, method string, params json.RawMessage) RPCRequest

+ func (req RPCRequest) String() string

+ type RPCResponse struct

+ Error *RPCError

+ ID interface{}

+ JSONRPC string

+ Result json.RawMessage

+ func NewRPCErrorResponse(id interface{}, code int, msg string, data string) RPCResponse

+ func NewRPCSuccessResponse(cdc *amino.Codec, id interface{}, res interface{}) RPCResponse

+ func RPCInternalError(id interface{}, err error) RPCResponse

+ func RPCInvalidParamsError(id interface{}, err error) RPCResponse

+ func RPCInvalidRequestError(id interface{}, err error) RPCResponse

+ func RPCMethodNotFoundError(id interface{}) RPCResponse

+ func RPCParseError(id interface{}, err error) RPCResponse

+ func RPCServerError(id interface{}, err error) RPCResponse

+ func (resp RPCResponse) String() string

+ type WSRPCConnection interface

+ Codec func() *amino.Codec

+ GetEventSubscriber func() EventSubscriber

+ GetRemoteAddr func() string

+ TryWriteRPCResponse func(resp RPCResponse) bool

+ WriteRPCResponse func(resp RPCResponse)

+ type WSRPCContext struct

+ Request RPCRequest