jsonrpc

package
v2.2.1 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2022 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const DefGasLimit int64 = 200000

Variables

This section is empty.

Functions

func RandomString 

func RandomString(n int) string

Types

type FastClient 

type FastClient struct {
	Remote string

	log.Logger
	// contains filtered or unexported fields
}

FastClient implement jsonRPCCaller

func NewFastClient 

func NewFastClient(remote string) *FastClient

func (*FastClient) Call 

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

func (*FastClient) SetTimeout 

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

type NodeRPC 

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

func NewNodeRPC 

func NewNodeRPC(caller jsonRPCCaller) *NodeRPC

func (*NodeRPC) ABCIInfo 

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

func (*NodeRPC) ABCIQuery 

func (c *NodeRPC) ABCIQuery(path string, data tmBytes.HexBytes) (*coreTypes.ResultABCIQuery, error)

func (*NodeRPC) ABCIQueryIsOk 

func (c *NodeRPC) ABCIQueryIsOk(path string, data tmBytes.HexBytes) (*coreTypes.ResultABCIQuery, error)

func (*NodeRPC) AppVersion 

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

func (*NodeRPC) Block 

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

func (*NodeRPC) BlockResults 

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

func (*NodeRPC) BlockchainInfo 

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

func (*NodeRPC) BroadcastEvidence 

func (c *NodeRPC) BroadcastEvidence(ev types.Evidence) (*coreTypes.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) (*coreTypes.ResultBroadcastTx, error)

func (*NodeRPC) BroadcastTxCommit 

func (c *NodeRPC) BroadcastTxCommit(tx types.Tx) (*coreTypes.ResultBroadcastTxCommit, error)

func (*NodeRPC) BroadcastTxRawCommit 

func (c *NodeRPC) BroadcastTxRawCommit(txRaw *tx.TxRaw) (*coreTypes.ResultBroadcastTxCommit, error)

func (*NodeRPC) BroadcastTxSync 

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

func (*NodeRPC) BuildTx 

func (c *NodeRPC) BuildTx(privKey cryptotypes.PrivKey, msgs []sdk.Msg) (*tx.TxRaw, error)

func (*NodeRPC) Commit 

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

func (*NodeRPC) ConsensusParams 

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

func (*NodeRPC) ConsensusState 

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

func (*NodeRPC) DumpConsensusState 

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

func (*NodeRPC) EstimatingGas 

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

func (*NodeRPC) Genesis 

func (c *NodeRPC) Genesis() (*coreTypes.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 deprecated 

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

Deprecated: GetGasPrices

func (*NodeRPC) GetGravityAttestation 

func (c *NodeRPC) GetGravityAttestation(cdc codec.Codec, id []byte) (*gravitytypes.Attestation, error)

func (*NodeRPC) GetGravityLastObservedEventNonce 

func (c *NodeRPC) GetGravityLastObservedEventNonce() (uint64, error)

func (*NodeRPC) GetMintDenom 

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

func (*NodeRPC) GetStakeValidators added in v2.2.1 

func (c *NodeRPC) GetStakeValidators(status stakingtypes.BondStatus) (stakingtypes.Validators, error)

func (*NodeRPC) Health 

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

func (*NodeRPC) NetInfo 

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

func (*NodeRPC) NumUnconfirmedTxs 

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

func (*NodeRPC) PeersByAddressPort 

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

func (*NodeRPC) PeersById 

func (c *NodeRPC) PeersById(id string) (*coreTypes.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() (*coreTypes.ResultStatus, error)

func (*NodeRPC) Store 

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

func (*NodeRPC) Tx 

func (c *NodeRPC) Tx(hash []byte) (*coreTypes.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) (
	*coreTypes.ResultTxSearch, error)

func (*NodeRPC) UnconfirmedTxs 

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

func (*NodeRPC) Validators 

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

func (*NodeRPC) WithContext 

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

func (*NodeRPC) WithGasPrices 

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

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(ctx context.Context, url string) (*WSClient, error)

func (*WSClient) ABCIQuery 

func (ws *WSClient) ABCIQuery(path string, data libTypes.HexBytes) (*coreTypes.ResultABCIQuery, error)

func (*WSClient) BlockResults 

func (ws *WSClient) BlockResults(height int64) (*coreTypes.ResultBlockResults, error)

func (*WSClient) Call 

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

func (*WSClient) Close 

func (ws *WSClient) Close()

func (*WSClient) ExitCh 

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

func (*WSClient) Status 

func (ws *WSClient) Status() (*coreTypes.ResultStatus, error)

func (*WSClient) Subscribe 

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

func (*WSClient) SubscribeEvent 

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

SubscribeEvent Experiment

func (*WSClient) TxSearch 

func (ws *WSClient) TxSearch(
	query string,
	prove bool,
	page,
	perPage *int,
	orderBy string,
) (*coreTypes.ResultTxSearch, error)

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.