jsonrpc

package
v7.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	Remote string

	log.Logger
	// contains filtered or unexported fields
}

Client implement jsonRPCCaller

func NewClient 

func NewClient(remote string) *Client

func (*Client) Call 

func (cli *Client) Call(ctx context.Context, method string, params map[string]interface{}, result interface{}) (err error)

func (*Client) SetTimeout 

func (cli *Client) SetTimeout(t time.Duration)

type NodeRPC 

type NodeRPC struct {
	// contains filtered or unexported fields
}

func NewNodeRPC 

func NewNodeRPC(caller jsonRPCCaller, ctx ...context.Context) *NodeRPC

func (*NodeRPC) ABCIInfo 

func (c *NodeRPC) ABCIInfo() (*ctypes.ResultABCIInfo, error)

func (*NodeRPC) ABCIQuery 

func (c *NodeRPC) ABCIQuery(path string, data tmbytes.HexBytes) (*ctypes.ResultABCIQuery, error)

func (*NodeRPC) ABCIQueryIsOk 

func (c *NodeRPC) ABCIQueryIsOk(path string, data tmbytes.HexBytes) (*ctypes.ResultABCIQuery, error)

func (*NodeRPC) AppVersion 

func (c *NodeRPC) AppVersion() (string, error)

func (*NodeRPC) Block 

func (c *NodeRPC) Block(height int64) (*ctypes.ResultBlock, error)

func (*NodeRPC) BlockResults 

func (c *NodeRPC) BlockResults(height int64) (*ctypes.ResultBlockResults, error)

func (*NodeRPC) BlockSearch 

func (c *NodeRPC) BlockSearch(query string, page, perPage int, orderBy string) (*ctypes.ResultBlockSearch, error)

func (*NodeRPC) BlockchainInfo 

func (c *NodeRPC) BlockchainInfo(minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error)

func (*NodeRPC) BroadcastEvidence 

func (c *NodeRPC) BroadcastEvidence(ev types.Evidence) (*ctypes.ResultBroadcastEvidence, error)

func (*NodeRPC) BroadcastTx 

func (c *NodeRPC) BroadcastTx(txRaw *tx.TxRaw, mode ...tx.BroadcastMode) (*sdk.TxResponse, error)

func (*NodeRPC) BroadcastTxAsync 

func (c *NodeRPC) BroadcastTxAsync(tx types.Tx) (*ctypes.ResultBroadcastTx, error)

func (*NodeRPC) BroadcastTxSync 

func (c *NodeRPC) BroadcastTxSync(tx types.Tx) (*ctypes.ResultBroadcastTx, error)

func (*NodeRPC) BuildTxRaw 

func (c *NodeRPC) BuildTxRaw(privKey cryptotypes.PrivKey, msgs []sdk.Msg, gasLimit, timeout uint64, memo string) (*tx.TxRaw, error)

func (*NodeRPC) Commit 

func (c *NodeRPC) Commit(height int64) (*ctypes.ResultCommit, error)

func (*NodeRPC) ConsensusParams 

func (c *NodeRPC) ConsensusParams(height int64) (*ctypes.ResultConsensusParams, error)

func (*NodeRPC) ConsensusState 

func (c *NodeRPC) ConsensusState() (*ctypes.ResultConsensusState, error)

func (*NodeRPC) DumpConsensusState 

func (c *NodeRPC) DumpConsensusState() (*ctypes.ResultDumpConsensusState, error)

func (*NodeRPC) EstimatingGas 

func (c *NodeRPC) EstimatingGas(raw *tx.TxRaw) (*sdk.GasInfo, error)

func (*NodeRPC) Genesis 

func (c *NodeRPC) Genesis() (*ctypes.ResultGenesis, error)

func (*NodeRPC) GetAddressPrefix 

func (c *NodeRPC) GetAddressPrefix() (prefix string, err error)

func (*NodeRPC) GetBlockHeight 

func (c *NodeRPC) GetBlockHeight() (int64, error)

func (*NodeRPC) GetChainId 

func (c *NodeRPC) GetChainId() (chain string, err error)

func (*NodeRPC) GetGasPrices 

func (c *NodeRPC) GetGasPrices() (sdk.Coins, error)

func (*NodeRPC) GetMintDenom 

func (c *NodeRPC) GetMintDenom() (denom string, err error)

func (*NodeRPC) GetModuleAccounts 

func (c *NodeRPC) GetModuleAccounts() ([]authtypes.AccountI, error)

func (*NodeRPC) Health 

func (c *NodeRPC) Health() (*ctypes.ResultHealth, error)

func (*NodeRPC) NetInfo 

func (c *NodeRPC) NetInfo() (*ctypes.ResultNetInfo, error)

func (*NodeRPC) NumUnconfirmedTxs 

func (c *NodeRPC) NumUnconfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error)

func (*NodeRPC) PeersByAddressPort 

func (c *NodeRPC) PeersByAddressPort(port string) (*ctypes.ResultABCIQuery, error)

func (*NodeRPC) PeersById 

func (c *NodeRPC) PeersById(id string) (*ctypes.ResultABCIQuery, error)

func (*NodeRPC) QueryAccount 

func (c *NodeRPC) QueryAccount(address string) (authtypes.AccountI, error)

func (*NodeRPC) QueryBalance 

func (c *NodeRPC) QueryBalance(address string, denom string) (sdk.Coin, error)

func (*NodeRPC) QueryBalances 

func (c *NodeRPC) QueryBalances(address string) (sdk.Coins, error)

func (*NodeRPC) QuerySupply 

func (c *NodeRPC) QuerySupply() (sdk.Coins, error)

func (*NodeRPC) Status 

func (c *NodeRPC) Status() (*ctypes.ResultStatus, error)

func (*NodeRPC) Store 

func (c *NodeRPC) Store(path string) (*ctypes.ResultABCIQuery, error)

func (*NodeRPC) Tx 

func (c *NodeRPC) Tx(hash []byte) (*ctypes.ResultTx, error)

func (*NodeRPC) TxByHash 

func (c *NodeRPC) TxByHash(txHash string) (*sdk.TxResponse, error)

func (*NodeRPC) TxSearch 

func (c *NodeRPC) TxSearch(query string, page, perPage int, orderBy string) (
	*ctypes.ResultTxSearch, error,
)

func (*NodeRPC) UnconfirmedTxs 

func (c *NodeRPC) UnconfirmedTxs(limit int) (*ctypes.ResultUnconfirmedTxs, error)

func (*NodeRPC) Validators 

func (c *NodeRPC) Validators(height int64, page, perPage int) (*ctypes.ResultValidators, error)

func (*NodeRPC) WaitMined 

func (c *NodeRPC) WaitMined(txHash string, timeout, pollInterval time.Duration) (*sdk.TxResponse, error)

func (*NodeRPC) WithBlockHeight 

func (c *NodeRPC) WithBlockHeight(height int64) *NodeRPC

func (*NodeRPC) WithChainId 

func (c *NodeRPC) WithChainId(chainId string) *NodeRPC

func (*NodeRPC) WithContext 

func (c *NodeRPC) WithContext(ctx context.Context) *NodeRPC

func (*NodeRPC) WithGasPrices 

func (c *NodeRPC) WithGasPrices(gasPrices sdk.Coins) *NodeRPC

type RPCError 

type RPCError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Data    string `json:"data,omitempty"`
}

func (RPCError) ServerExit 

func (err RPCError) ServerExit() bool

func (RPCError) String 

func (err RPCError) String() string

type RPCRequest 

type RPCRequest struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      string          `json:"id,omitempty"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params"` // must be map[string]interface{} or []interface{}
}

func NewRPCRequest 

func NewRPCRequest(id, method string, params json.RawMessage) RPCRequest

type RPCResponse 

type RPCResponse struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      string          `json:"id,omitempty"`
	Result  json.RawMessage `json:"result,omitempty"`
	Error   *RPCError       `json:"error,omitempty"`
}

type WSClient 

type WSClient struct {
	log.Logger
	// contains filtered or unexported fields
}

WSClient implement jsonRPCCaller

func NewWsClient 

func NewWsClient(url string, ctx context.Context) (*WSClient, error)

func (*WSClient) Call 

func (ws *WSClient) Call(ctx context.Context, method string, params map[string]interface{}, result interface{}) error

func (*WSClient) Close 

func (ws *WSClient) Close()

func (*WSClient) ExitCh 

func (ws *WSClient) ExitCh() <-chan struct{}

func (*WSClient) Subscribe 

func (ws *WSClient) Subscribe(query string, resp chan RPCResponse) (id string, err error)

func (*WSClient) SubscribeEvent 

func (ws *WSClient) SubscribeEvent(ctx context.Context, query string, event chan<- ctypes.ResultEvent) (err error)

SubscribeEvent Experiment

func (*WSClient) Unsubscribe 

func (ws *WSClient) Unsubscribe(subId string)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.