rpcclient

Oct 28, 2017

Changes in this version

type WSClient

+ ResponsesCh chan types.RPCResponse

Oct 10, 2017

Changes in this version

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

Sep 5, 2017

Changes in this version

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

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

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

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

type WSClient

+ PingPongLatencyTimer metrics.Timer

+ 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) Send(ctx context.Context, request types.RPCRequest) error

+ func (c *WSClient) Stop() bool

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

Jun 3, 2017

Changes in this version

+ 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

+ ErrorsCh chan error

+ ResultsCh chan json.RawMessage

+ func NewWSClient(remoteAddr, endpoint string) *WSClient

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

+ func (wsc *WSClient) OnReset() error

+ func (wsc *WSClient) OnStart() error

+ func (wsc *WSClient) OnStop()

+ func (wsc *WSClient) String() string

+ func (wsc *WSClient) Subscribe(eventid string) error

+ func (wsc *WSClient) Unsubscribe(eventid string) error