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

rpcclient

package

Go to main page

Versions in this module

v1

v1.1.0

Aug 8, 2019

v1.0.0

Apr 30, 2019

v0

v0.2.0

Dec 11, 2018

Changes in this version

+ func MaxReconnectAttempts(max int) func(*WSClient)

+ func OnReconnect(cb func()) func(*WSClient)

+ func PingPeriod(pingPeriod time.Duration) func(*WSClient)

+ func ReadWait(readWait time.Duration) func(*WSClient)

+ func WriteWait(writeWait time.Duration) func(*WSClient)

+ type HTTPClient interface

+ Call func(method string, params map[string]interface{}, result interface{}) (interface{}, error)

+ Codec func() *amino.Codec

+ SetCodec func(*amino.Codec)

+ type JSONRPCClient struct

+ func NewJSONRPCClient(remote string) *JSONRPCClient

+ func (c *JSONRPCClient) Call(method string, params map[string]interface{}, result interface{}) (interface{}, error)

+ func (c *JSONRPCClient) Codec() *amino.Codec

+ func (c *JSONRPCClient) SetCodec(cdc *amino.Codec)

+ type URIClient struct

+ func NewURIClient(remote string) *URIClient

+ func (c *URIClient) Call(method string, params map[string]interface{}, result interface{}) (interface{}, error)

+ func (c *URIClient) Codec() *amino.Codec

+ func (c *URIClient) SetCodec(cdc *amino.Codec)

+ type WSClient struct

+ Address string

+ Dialer func(string, string) (net.Conn, error)

+ Endpoint string

+ PingPongLatencyTimer metrics.Timer

+ ResponsesCh chan types.RPCResponse

+ func NewWSClient(remoteAddr, endpoint string, options ...func(*WSClient)) *WSClient

+ func (c *WSClient) Call(ctx context.Context, method string, params map[string]interface{}) error

+ func (c *WSClient) CallWithArrayParams(ctx context.Context, method string, params []interface{}) error

+ func (c *WSClient) Codec() *amino.Codec

+ func (c *WSClient) IsActive() bool

+ func (c *WSClient) IsReconnecting() bool

+ func (c *WSClient) OnStart() error

+ func (c *WSClient) OnStop()

+ func (c *WSClient) Send(ctx context.Context, request types.RPCRequest) error

+ func (c *WSClient) SetCodec(cdc *amino.Codec)

+ func (c *WSClient) Stop() error

+ func (c *WSClient) String() string

+ func (c *WSClient) Subscribe(ctx context.Context, query string) error

+ func (c *WSClient) Unsubscribe(ctx context.Context, query string) error

+ func (c *WSClient) UnsubscribeAll(ctx context.Context) error