Versions in this module Expand all Collapse all v0 v0.1.0 Jan 19, 2024 Changes in this version + const URIClientRequestID + func ConvTCM392CM4(c *CM39ResultTx, ret *coretypes.ResultTx) + func ConvTCM39BroadcastCommitTx2CM4(c *CM39ResultBroadcastTxCommit, ret *coretypes.ResultBroadcastTxCommit) + func ConvTCM39ResultABCIQuery2CM4(c *CM39ResultABCIQuery, ret *coretypes.ResultABCIQuery) + func DefaultHTTPClient(remoteAddr string) (*http.Client, error) + 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 CM39ResponseDeliverTx struct + Code uint32 + Codespace string + Data []byte + Events []abci.Event + GasUsed int64 + GasWanted int64 + Info string + Log string + type CM39ResponseQuery struct + Code uint32 + Codespace string + Height int64 + Index int64 + Info string + Key []byte + Log string + Proof *merkle.Proof + Value []byte + type CM39ResultABCIQuery struct + Response CM39ResponseQuery + type CM39ResultBroadcastTxCommit struct + CheckTx abci.ResponseCheckTx + DeliverTx CM39ResponseDeliverTx + Hash bytes.HexBytes + Height int64 + type CM39ResultTx struct + Hash bytes.HexBytes + Height int64 + Index uint32 + Proof types.TxProof + Tx types.Tx + TxResult CM39ResponseDeliverTx + type Caller interface + Call func(method string, params map[string]interface{}, result interface{}) (interface{}, error) + type Client struct + func New(remote string) (*Client, error) + func NewWithHTTPClient(remote string, client *http.Client) (*Client, error) + func (c *Client) Call(method string, params map[string]interface{}, result interface{}) (interface{}, error) + func (c *Client) Codec() *amino.Codec + func (c *Client) NewRequestBatch() *RequestBatch + func (c *Client) SetCodec(cdc *amino.Codec) + type Cm39HttpJSONClientAdapter struct + func NewCm39HttpJSONClient(remote string, client *http.Client) (*Cm39HttpJSONClientAdapter, error) + func (c *Cm39HttpJSONClientAdapter) Call(method string, params map[string]interface{}, result interface{}) (ret interface{}, err error) + type HTTPClient interface + Call func(method string, params map[string]interface{}, result interface{}) (interface{}, error) + Codec func() *amino.Codec + SetCodec func(*amino.Codec) + type RequestBatch struct + func (b *RequestBatch) Call(method string, params map[string]interface{}, result interface{}) (interface{}, error) + func (b *RequestBatch) Clear() int + func (b *RequestBatch) Count() int + func (b *RequestBatch) Send() ([]interface{}, error) + type URIClient struct + func NewURI(remote string) (*URIClient, error) + 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 NewWS(remoteAddr, endpoint string, options ...func(*WSClient)) (*WSClient, error) + 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