Versions in this module Expand all Collapse all v0 v0.31.12 Oct 9, 2022 v0.31.11 Oct 29, 2019 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 JSONRPCCaller interface + Call func(method string, params map[string]interface{}, result interface{}) (interface{}, error) + 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) NewRequestBatch() *JSONRPCRequestBatch + func (c *JSONRPCClient) SetCodec(cdc *amino.Codec) + type JSONRPCRequestBatch struct + func (b *JSONRPCRequestBatch) Call(method string, params map[string]interface{}, result interface{}) (interface{}, error) + func (b *JSONRPCRequestBatch) Clear() int + func (b *JSONRPCRequestBatch) Count() int + func (b *JSONRPCRequestBatch) Send() ([]interface{}, error) + 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) 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
Go to main page