client

Jun 26, 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)

+ type JSONRPCClient struct

+ func NewJSONRPCClient(remote string) *JSONRPCClient

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

+ type URIClient struct

+ func NewURIClient(remote string) *URIClient

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

+ 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) 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) 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