Versions in this module Expand all Collapse all v6 v6.1.0 Jul 30, 2024 v6.0.0 Dec 25, 2023 Changes in this version + type Client struct + Remote string + func NewClient(remote string) *Client + func (cli *Client) Call(ctx context.Context, method string, params map[string]interface{}, ...) (err error) + func (cli *Client) SetTimeout(t time.Duration) + type NodeRPC struct + func NewNodeRPC(caller jsonRPCCaller, ctx ...context.Context) *NodeRPC + func (c *NodeRPC) ABCIInfo() (*ctypes.ResultABCIInfo, error) + func (c *NodeRPC) ABCIQuery(path string, data tmbytes.HexBytes) (*ctypes.ResultABCIQuery, error) + func (c *NodeRPC) ABCIQueryIsOk(path string, data tmbytes.HexBytes) (*ctypes.ResultABCIQuery, error) + func (c *NodeRPC) AppVersion() (string, error) + func (c *NodeRPC) Block(height int64) (*ctypes.ResultBlock, error) + func (c *NodeRPC) BlockResults(height int64) (*ctypes.ResultBlockResults, error) + func (c *NodeRPC) BlockSearch(query string, page, perPage int, orderBy string) (*ctypes.ResultBlockSearch, error) + func (c *NodeRPC) BlockchainInfo(minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error) + func (c *NodeRPC) BroadcastEvidence(ev types.Evidence) (*ctypes.ResultBroadcastEvidence, error) + func (c *NodeRPC) BroadcastTx(txRaw *tx.TxRaw, mode ...tx.BroadcastMode) (*sdk.TxResponse, error) + func (c *NodeRPC) BroadcastTxAsync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *NodeRPC) BroadcastTxCommit(tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error) + func (c *NodeRPC) BroadcastTxRawCommit(txRaw *tx.TxRaw) (*ctypes.ResultBroadcastTxCommit, error) + func (c *NodeRPC) BroadcastTxSync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *NodeRPC) BuildTx(privKey cryptotypes.PrivKey, msgs []sdk.Msg) (*tx.TxRaw, error) + func (c *NodeRPC) Commit(height int64) (*ctypes.ResultCommit, error) + func (c *NodeRPC) ConsensusParams(height int64) (*ctypes.ResultConsensusParams, error) + func (c *NodeRPC) ConsensusState() (*ctypes.ResultConsensusState, error) + func (c *NodeRPC) DumpConsensusState() (*ctypes.ResultDumpConsensusState, error) + func (c *NodeRPC) EstimatingGas(raw *tx.TxRaw) (*sdk.GasInfo, error) + func (c *NodeRPC) Genesis() (*ctypes.ResultGenesis, error) + func (c *NodeRPC) GetAddressPrefix() (prefix string, err error) + func (c *NodeRPC) GetBlockHeight() (int64, error) + func (c *NodeRPC) GetChainId() (chain string, err error) + func (c *NodeRPC) GetGasPrices() (sdk.Coins, error) + func (c *NodeRPC) GetGravityAttestation(cdc codec.Codec, id []byte) (*gravitytypes.Attestation, error) + func (c *NodeRPC) GetGravityLastObservedEventNonce() (uint64, error) + func (c *NodeRPC) GetMintDenom() (denom string, err error) + func (c *NodeRPC) GetStakeValidators(status stakingtypes.BondStatus) (stakingtypes.Validators, error) + func (c *NodeRPC) GetValAddressByCons(consAddrStr string) (sdk.ValAddress, error) + func (c *NodeRPC) Health() (*ctypes.ResultHealth, error) + func (c *NodeRPC) NetInfo() (*ctypes.ResultNetInfo, error) + func (c *NodeRPC) NumUnconfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error) + func (c *NodeRPC) PeersByAddressPort(port string) (*ctypes.ResultABCIQuery, error) + func (c *NodeRPC) PeersById(id string) (*ctypes.ResultABCIQuery, error) + func (c *NodeRPC) QueryAccount(address string) (authtypes.AccountI, error) + func (c *NodeRPC) QueryBalance(address string, denom string) (sdk.Coin, error) + func (c *NodeRPC) QueryBalances(address string) (sdk.Coins, error) + func (c *NodeRPC) QuerySupply() (sdk.Coins, error) + func (c *NodeRPC) Status() (*ctypes.ResultStatus, error) + func (c *NodeRPC) Store(path string) (*ctypes.ResultABCIQuery, error) + func (c *NodeRPC) Tx(hash []byte) (*ctypes.ResultTx, error) + func (c *NodeRPC) TxByHash(txHash string) (*sdk.TxResponse, error) + func (c *NodeRPC) TxSearch(query string, page, perPage int, orderBy string) (*ctypes.ResultTxSearch, error) + func (c *NodeRPC) UnconfirmedTxs(limit int) (*ctypes.ResultUnconfirmedTxs, error) + func (c *NodeRPC) Validators(height int64, page, perPage int) (*ctypes.ResultValidators, error) + func (c *NodeRPC) WithBlockHeight(height int64) *NodeRPC + func (c *NodeRPC) WithChainId(chainId string) *NodeRPC + func (c *NodeRPC) WithContext(ctx context.Context) *NodeRPC + func (c *NodeRPC) WithGasPrices(gasPrices sdk.Coins) *NodeRPC + type RPCError struct + Code int + Data string + Message string + func (err RPCError) ServerExit() bool + func (err RPCError) String() string + type RPCRequest struct + ID string + JSONRPC string + Method string + Params json.RawMessage + func NewRPCRequest(id, method string, params json.RawMessage) RPCRequest + type RPCResponse struct + Error *RPCError + ID string + JSONRPC string + Result json.RawMessage + type WSClient struct + func NewWsClient(url string, ctx context.Context) (*WSClient, error) + func (ws *WSClient) Call(ctx context.Context, method string, params map[string]interface{}, ...) error + func (ws *WSClient) Close() + func (ws *WSClient) ExitCh() <-chan struct{} + func (ws *WSClient) Subscribe(query string, resp chan RPCResponse) (id string, err error) + func (ws *WSClient) SubscribeEvent(ctx context.Context, query string, event chan<- ctypes.ResultEvent) (err error) + func (ws *WSClient) Unsubscribe(subId string) v6.0.0-rc0 Dec 6, 2023 Other modules containing this package github.com/functionx/fx-core/v2 github.com/functionx/fx-core/v3 github.com/functionx/fx-core/v4 github.com/functionx/fx-core/v5 github.com/functionx/fx-core/v7