Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpc

package

Go to main page

Versions in this module

v0

v0.1.7

Feb 13, 2023

v0.1.7-fc067ad

Feb 13, 2023

v0.1.7-bscAlpha.testnet

Mar 16, 2023

v0.1.7-bscAlpha.1

Mar 3, 2023

v0.1.7-bscAlpha.0

Feb 13, 2023

v0.1.6

Feb 13, 2023

v0.1.5

Feb 11, 2023

v0.1.4

Feb 10, 2023

v0.1.3

Feb 7, 2023

v0.1.2

Feb 6, 2023

v0.1.1

Feb 6, 2023

Changes in this version

+ const AccountStoreName

+ const AtomicSwapStoreName

+ const BridgeStoreName

+ const EmptyRequest

+ const OracleStoreName

+ const ParamABCIPrefix

+ const SideChainStoreName

+ const TimeLockMsgRoute

+ const TimeLockrcNotFoundErrorCode

+ var DefaultTimeout = 5 * time.Second

+ var DelegationKey = []byte

+ var DepthLevelExceedRangeError = fmt.Errorf("the level is out of range [%d, %d]", 0, maxDepthLevel)

+ var EmptyResultError = fmt.Errorf("Empty result ")

+ var ExceedABCIDataLengthError = fmt.Errorf("the abci data exceed max length %d ", maxABCIDataLength)

+ var ExceedABCIPathLengthError = fmt.Errorf("the abci path exceed max length %d ", maxABCIPathLength)

+ var ExceedABCIQueryStrLengthError = fmt.Errorf("the query string exceed max length %d ", maxABCIPathLength)

+ var ExceedMaxUnConfirmedTxsNumError = fmt.Errorf("the limit of unConfirmed tx exceed max limit %d ", maxUnConfirmedTxs)

+ var ExceedTxLengthError = fmt.Errorf("the tx data exceed max length %d ", maxTxLength)

+ var ExceedTxSearchQueryStrLengthError = fmt.Errorf("the query string exceed max length %d ", maxTxSearchStrLength)

+ var HashLengthError = fmt.Errorf("the length of hash is not 32")

+ var HeightNegativeError = fmt.Errorf("the height can't be negative")

+ var KeyMissingError = fmt.Errorf("keymanager is missing, use SetKeyManager to set key")

+ var LimitNegativeError = fmt.Errorf("the limit can't be negative")

+ var MaxMinHeightConflictError = fmt.Errorf("the min height can't be larger than max height")

+ var OffsetNegativeError = fmt.Errorf("offset can't be less than 0")

+ var PairFormatError = fmt.Errorf("the pair should in format 'symbol1_symbol2'")

+ var PoolKey = []byte

+ var RedelegationKey = []byte

+ var SideChainStorePrefixByIdKey = []byte

+ var StakeScStoreKey = "sc"

+ var StakeStoreKey = "stake"

+ var SymbolLengthExceedRangeError = fmt.Errorf("length of symbol should be in range [%d,%d]", tokenSymbolMinLen, ...)

+ var UnbondingDelegationKey = []byte

+ var ValidatorsKey = []byte

+ func ParseTx(cdc *amino.Codec, txBytes []byte) (tx.Tx, error)

+ func ValidateABCIData(data common.HexBytes) error

+ func ValidateABCIPath(path string) error

+ func ValidateABCIQueryStr(query string) error

+ func ValidateDepthLevel(level int) error

+ func ValidateHash(hash []byte) error

+ func ValidateHeight(height *int64) error

+ func ValidateHeightRange(from int64, to int64) error

+ func ValidateLimit(limit int) error

+ func ValidateOffset(offset int) error

+ func ValidatePair(pair string) error

+ func ValidateSymbol(symbol string) error

+ func ValidateTx(tx types.Tx) error

+ func ValidateTxSearchQueryStr(query string) error

+ func ValidateUnConfirmedTxsLimit(limit int) error

+ type ABCIClient interface

+ ABCIInfo func() (*ctypes.ResultABCIInfo, error)

+ ABCIQuery func(path string, data cmn.HexBytes) (*ctypes.ResultABCIQuery, error)

+ ABCIQueryWithOptions func(path string, data cmn.HexBytes, opts client.ABCIQueryOptions) (*ctypes.ResultABCIQuery, error)

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

+ BroadcastTxCommit func(tx types.Tx) (*ResultBroadcastTxCommit, error)

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

+ type ABCIResponses struct

+ BeginBlock *ResponseBeginBlock

+ DeliverTx []*ResponseDeliverTx

+ EndBlock *ResponseEndBlock

+ type Client interface

+ type DexClient interface

+ Bind func(symbol string, amount int64, contractAddress msg.SmartChainAddress, ...) (*core_types.ResultBroadcastTx, error)

+ Broadcast func(m msg.Msg, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ CancelOrder func(baseAssetSymbol, quoteAssetSymbol, refId string, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ Claim func(chainId sdk.IbcChainID, sequence uint64, payload []byte, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ ClaimHTLT func(swapID []byte, randomNumber []byte, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ CreateOrder func(baseAssetSymbol, quoteAssetSymbol string, op int8, price, quantity int64, ...) (*core_types.ResultBroadcastTx, error)

+ Deposit func(proposalID int64, amount types.Coins, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ DepositHTLT func(recipient types.AccAddress, swapID []byte, amount types.Coins, ...) (*core_types.ResultBroadcastTx, error)

+ GetAccount func(addr types.AccAddress) (acc types.Account, err error)

+ GetBalance func(addr types.AccAddress, symbol string) (*types.TokenBalance, error)

+ GetBalances func(addr types.AccAddress) ([]types.TokenBalance, error)

+ GetCommitAccount func(addr types.AccAddress) (acc types.Account, err error)

+ GetCurrentOracleSequence func(chainId sdk.IbcChainID) (int64, error)

+ GetFee func() ([]types.FeeParam, error)

+ GetMiniTokenInfo func(symbol string) (*types.MiniToken, error)

+ GetProphecy func(chainId sdk.IbcChainID, sequence int64) (*msg.Prophecy, error)

+ GetProposal func(proposalId int64) (types.Proposal, error)

+ GetProposals func(status types.ProposalStatus, numLatest int64) ([]types.Proposal, error)

+ GetSideChainParams func(sideChainId string) ([]msg.SCParam, error)

+ GetSideChainProposal func(proposalId int64, sideChainId string) (types.Proposal, error)

+ GetSideChainProposals func(status types.ProposalStatus, numLatest int64, sideChainId string) ([]types.Proposal, error)

+ GetSwapByCreator func(creatorAddr string, offset int64, limit int64) ([]types.SwapBytes, error)

+ GetSwapByID func(swapID types.SwapBytes) (types.AtomicSwap, error)

+ GetSwapByRecipient func(recipientAddr string, offset int64, limit int64) ([]types.SwapBytes, error)

+ GetTimelock func(addr types.AccAddress, recordID int64) (*types.TimeLockRecord, error)

+ GetTimelocks func(addr types.AccAddress) ([]types.TimeLockRecord, error)

+ GetTokenInfo func(symbol string) (*types.Token, error)

+ HTLT func(recipient types.AccAddress, recipientOtherChain, senderOtherChain string, ...) (*core_types.ResultBroadcastTx, error)

+ ListAllMiniTokens func(offset int, limit int) ([]types.MiniToken, error)

+ ListAllTokens func(offset int, limit int) ([]types.Token, error)

+ RefundHTLT func(swapID []byte, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ SendToken func(transfers []msg.Transfer, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ SetKeyManager func(k keys.KeyManager)

+ SideChainDeposit func(proposalID int64, amount types.Coins, sideChainId string, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ SideChainSubmitCSCParamsProposal func(title string, cscParam msg.CSCParamChange, initialDeposit types.Coins, ...) (*core_types.ResultBroadcastTx, error)

+ SideChainSubmitProposal func(title string, description string, proposalType msg.ProposalKind, ...) (*core_types.ResultBroadcastTx, error)

+ SideChainSubmitSCParamsProposal func(title string, scParam msg.SCChangeParams, initialDeposit types.Coins, ...) (*core_types.ResultBroadcastTx, error)

+ SideChainVote func(proposalID int64, option msg.VoteOption, sideChainId string, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ SubmitListProposal func(title string, param msg.ListTradingPairParams, proposalType msg.ProposalKind, ...) (*core_types.ResultBroadcastTx, error)

+ SubmitProposal func(title string, description string, proposalType msg.ProposalKind, ...) (*core_types.ResultBroadcastTx, error)

+ TransferOut func(to msg.SmartChainAddress, amount types.Coin, expireTime int64, ...) (*core_types.ResultBroadcastTx, error)

+ TransferTokenOwnership func(symbol string, newOwner types.AccAddress, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ TxInfoSearch func(query string, prove bool, page, perPage int) ([]Info, error)

+ Unbind func(symbol string, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ Vote func(proposalID int64, option msg.VoteOption, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ type EventsClient interface

+ Subscribe func(query string, outCapacity ...int) (out chan ctypes.ResultEvent, err error)

+ Unsubscribe func(query string) error

+ UnsubscribeAll func() error

+ type HTTP struct

+ func NewHTTP(remote, wsEndpoint string) *HTTP

+ func NewRPCClient(nodeURI string, network ntypes.ChainNetwork) *HTTP

+ func (c *HTTP) ABCIInfo() (*ctypes.ResultABCIInfo, error)

+ func (c *HTTP) ABCIQuery(path string, data cmn.HexBytes) (*ctypes.ResultABCIQuery, error)

+ func (c *HTTP) ABCIQueryWithOptions(path string, data cmn.HexBytes, opts client.ABCIQueryOptions) (*ctypes.ResultABCIQuery, error)

+ func (c *HTTP) Bind(symbol string, amount int64, contractAddress msg.SmartChainAddress, ...) (*core_types.ResultBroadcastTx, error)

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

+ func (c *HTTP) BlockResults(height *int64) (*ResultBlockResults, error)

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

+ func (c *HTTP) Broadcast(m msg.Msg, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

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

+ func (c *HTTP) BroadcastTxCommit(tx types.Tx) (*ResultBroadcastTxCommit, error)

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

+ func (c *HTTP) CancelOrder(baseAssetSymbol, quoteAssetSymbol, refId string, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) Claim(chainId sdk.IbcChainID, sequence uint64, payload []byte, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) ClaimHTLT(swapID []byte, randomNumber []byte, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

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

+ func (c *HTTP) ConsensusState() (*ctypes.ResultConsensusState, error)

+ func (c *HTTP) CreateOrder(baseAssetSymbol, quoteAssetSymbol string, op int8, price, quantity int64, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) CreateSideChainValidator(delegation types.Coin, description msg.Description, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) CreateValidatorOpen(delegation types.Coin, description msg.Description, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) Delegate(valAddr types.ValAddress, delegation types.Coin, syncType SyncType, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) Deposit(proposalID int64, amount types.Coins, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) DepositHTLT(recipient types.AccAddress, swapID []byte, amount types.Coins, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) DumpConsensusState() (*ctypes.ResultDumpConsensusState, error)

+ func (c *HTTP) EditSideChainValidator(sideChainId string, description msg.Description, commissionRate *types.Dec, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) EditValidator(description msg.Description, commissionRate *types.Dec, pubkey string, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) Genesis() (*ctypes.ResultGenesis, error)

+ func (c *HTTP) GetAccount(addr types.AccAddress) (acc types.Account, err error)

+ func (c *HTTP) GetAllValidatorsCount(jailInvolved bool) (int, error)

+ func (c *HTTP) GetBalance(addr types.AccAddress, symbol string) (*types.TokenBalance, error)

+ func (c *HTTP) GetBalances(addr types.AccAddress) ([]types.TokenBalance, error)

+ func (c *HTTP) GetCommitAccount(addr types.AccAddress) (acc types.Account, err error)

+ func (c *HTTP) GetCurrentOracleSequence(chainId sdk.IbcChainID) (int64, error)

+ func (c *HTTP) GetDelegatorUnbondingDelegations(delegatorAddr types.AccAddress) ([]types.UnbondingDelegation, error)

+ func (c *HTTP) GetFee() ([]types.FeeParam, error)

+ func (c *HTTP) GetLastTotalPower() (power *int64, err error)

+ func (c *HTTP) GetMiniTokenInfo(symbol string) (*types.MiniToken, error)

+ func (c *HTTP) GetOracleRelayers() (relayers []msg.OracleRelayer, err error)

+ func (c *HTTP) GetPool() (*types.Pool, error)

+ func (c *HTTP) GetProphecy(chainId sdk.IbcChainID, sequence int64) (*msg.Prophecy, error)

+ func (c *HTTP) GetProposal(proposalId int64) (types.Proposal, error)

+ func (c *HTTP) GetProposals(status types.ProposalStatus, numLatest int64) ([]types.Proposal, error)

+ func (c *HTTP) GetRedelegationsByValidator(valAddr types.ValAddress) ([]types.Redelegation, error)

+ func (c *HTTP) GetSideChainAllValidatorsCount(sideChainId string, jailInvolved bool) (int, error)

+ func (c *HTTP) GetSideChainParams(sideChainId string) ([]msg.SCParam, error)

+ func (c *HTTP) GetSideChainPool(sideChainId string) (*types.Pool, error)

+ func (c *HTTP) GetSideChainProposal(proposalId int64, sideChainId string) (types.Proposal, error)

+ func (c *HTTP) GetSideChainProposals(status types.ProposalStatus, numLatest int64, sideChainId string) ([]types.Proposal, error)

+ func (c *HTTP) GetSideChainRedelegationsByValidator(sideChainId string, valAddr types.ValAddress) ([]types.Redelegation, error)

+ func (c *HTTP) GetSideChainUnBondingDelegationsByValidator(sideChainId string, valAddr types.ValAddress) ([]types.UnbondingDelegation, error)

+ func (c *HTTP) GetStakeValidators() ([]types.Validator, error)

+ func (c *HTTP) GetSwapByCreator(creatorAddr string, offset int64, limit int64) ([]types.SwapBytes, error)

+ func (c *HTTP) GetSwapByID(swapID types.SwapBytes) (types.AtomicSwap, error)

+ func (c *HTTP) GetSwapByRecipient(recipientAddr string, offset int64, limit int64) ([]types.SwapBytes, error)

+ func (c *HTTP) GetTimelock(addr types.AccAddress, recordID int64) (*types.TimeLockRecord, error)

+ func (c *HTTP) GetTimelocks(addr types.AccAddress) ([]types.TimeLockRecord, error)

+ func (c *HTTP) GetTokenInfo(symbol string) (*types.Token, error)

+ func (c *HTTP) GetUnBondingDelegationsByValidator(valAddr types.ValAddress) ([]types.UnbondingDelegation, error)

+ func (c *HTTP) HTLT(recipient types.AccAddress, recipientOtherChain, senderOtherChain string, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) Health() (*ctypes.ResultHealth, error)

+ func (c *HTTP) IsActive() bool

+ func (c *HTTP) ListAllMiniTokens(offset int, limit int) ([]types.MiniToken, error)

+ func (c *HTTP) ListAllTokens(offset int, limit int) ([]types.Token, error)

+ func (c *HTTP) NetInfo() (*ctypes.ResultNetInfo, error)

+ func (c *HTTP) NumUnconfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error)

+ func (c *HTTP) QueryDelegation(delAddr types.AccAddress, valAddr types.ValAddress) (*types.DelegationResponse, error)

+ func (c *HTTP) QueryDelegations(delAddr types.AccAddress) ([]types.DelegationResponse, error)

+ func (c *HTTP) QueryRedelegation(delAddr types.AccAddress, valSrcAddr types.ValAddress, ...) (*types.Redelegation, error)

+ func (c *HTTP) QueryRedelegations(delAddr types.AccAddress) ([]types.Redelegation, error)

+ func (c *HTTP) QuerySideChainDelegation(sideChainId string, delAddr types.AccAddress, valAddr types.ValAddress) (*types.DelegationResponse, error)

+ func (c *HTTP) QuerySideChainDelegations(sideChainId string, delAddr types.AccAddress) ([]types.DelegationResponse, error)

+ func (c *HTTP) QuerySideChainRedelegation(sideChainId string, delAddr types.AccAddress, valSrcAddr types.ValAddress, ...) (*types.Redelegation, error)

+ func (c *HTTP) QuerySideChainRedelegations(sideChainId string, delAddr types.AccAddress) ([]types.Redelegation, error)

+ func (c *HTTP) QuerySideChainTopValidators(sideChainId string, top int) ([]types.Validator, error)

+ func (c *HTTP) QuerySideChainUnbondingDelegation(sideChainId string, valAddr types.ValAddress, delAddr types.AccAddress) (*types.UnbondingDelegation, error)

+ func (c *HTTP) QuerySideChainUnbondingDelegations(sideChainId string, delAddr types.AccAddress) ([]types.UnbondingDelegation, error)

+ func (c *HTTP) QuerySideChainValidator(sideChainId string, valAddr types.ValAddress) (*types.Validator, error)

+ func (c *HTTP) QueryStore(key cmn.HexBytes, storeName string) ([]byte, error)

+ func (c *HTTP) QueryStoreSubspace(key cmn.HexBytes, storeName string) (res []cmn.KVPair, err error)

+ func (c *HTTP) QueryTopValidators(top int) ([]types.Validator, error)

+ func (c *HTTP) QueryUnbondingDelegation(valAddr types.ValAddress, delAddr types.AccAddress) (*types.UnbondingDelegation, error)

+ func (c *HTTP) QueryUnbondingDelegations(delAddr types.AccAddress) ([]types.UnbondingDelegation, error)

+ func (c *HTTP) QueryValidator(valAddr types.ValAddress) (*types.Validator, error)

+ func (c *HTTP) QueryWithData(path string, data cmn.HexBytes) ([]byte, error)

+ func (c *HTTP) Redelegate(valSrcAddr types.ValAddress, valDstAddr types.ValAddress, amount types.Coin, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) RefundHTLT(swapID []byte, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) SendToken(transfers []msg.Transfer, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) SetKeyManager(k keys.KeyManager)

+ func (c *HTTP) SideChainDelegate(sideChainId string, valAddr types.ValAddress, delegation types.Coin, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainDeposit(proposalID int64, amount types.Coins, sideChainId string, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainRedelegate(sideChainId string, valSrcAddr types.ValAddress, valDstAddr types.ValAddress, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainSubmitCSCParamsProposal(title string, cscParam msg.CSCParamChange, initialDeposit types.Coins, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainSubmitProposal(title string, description string, proposalType msg.ProposalKind, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainSubmitSCParamsProposal(title string, scParam msg.SCChangeParams, initialDeposit types.Coins, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainUnbond(sideChainId string, valAddr types.ValAddress, amount types.Coin, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainUnjail(sideChainId string, valAddr types.ValAddress, syncType SyncType, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) SideChainVote(proposalID int64, option msg.VoteOption, sideChainId string, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) Status() (*ctypes.ResultStatus, error)

+ func (c *HTTP) SubmitListProposal(title string, param msg.ListTradingPairParams, proposalType msg.ProposalKind, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) SubmitProposal(title string, description string, proposalType msg.ProposalKind, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) TransferOut(to msg.SmartChainAddress, amount types.Coin, expireTime int64, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) TransferTokenOwnership(symbol string, newOwner types.AccAddress, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) Tx(hash []byte, prove bool) (*ResultTx, error)

+ func (c *HTTP) TxInfoSearch(query string, prove bool, page, perPage int) ([]Info, error)

+ func (c *HTTP) TxSearch(query string, prove bool, page, perPage int) (*ResultTxSearch, error)

+ func (c *HTTP) Unbind(symbol string, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

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

+ func (c *HTTP) Undelegate(valAddr types.ValAddress, amount types.Coin, syncType SyncType, ...) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) Unjail(valAddr types.ValAddress, syncType SyncType, options ...tx.Option) (*coretypes.ResultBroadcastTx, error)

+ func (c *HTTP) Validators(height *int64) (*ctypes.ResultValidators, error)

+ func (c *HTTP) Vote(proposalID int64, option msg.VoteOption, syncType SyncType, ...) (*core_types.ResultBroadcastTx, error)

+ type Info struct

+ Hash cmn.HexBytes

+ Height int64

+ Result ResponseDeliverTx

+ Tx tx.Tx

+ func FormatTxResults(cdc *amino.Codec, res []*ResultTx) ([]Info, error)

+ type OpsClient interface

+ GetDelegatorUnbondingDelegations func(delegatorAddr types.AccAddress) ([]types.UnbondingDelegation, error)

+ GetStakeValidators func() ([]types.Validator, error)

+ IsActive func() bool

+ type ResponseBeginBlock struct

+ Events []types.Event

+ Tags []cmn.KVPair

+ type ResponseCheckTx struct

+ Code uint32

+ Codespace string

+ Data []byte

+ Events []types.Event

+ GasUsed int64

+ GasWanted int64

+ Info string

+ Log string

+ Tags []cmn.KVPair

+ func (r ResponseCheckTx) IsErr() bool

+ type ResponseDeliverTx struct

+ Code uint32

+ Codespace string

+ Data []byte

+ Events []types.Event

+ GasUsed int64

+ GasWanted int64

+ Info string

+ Log string

+ Tags []cmn.KVPair

+ type ResponseEndBlock struct

+ ConsensusParamUpdates *types.ConsensusParams

+ Events []types.Event

+ Tags []cmn.KVPair

+ ValidatorUpdates []types.ValidatorUpdate

+ type ResultBlockResults struct

+ Height int64

+ Results *ABCIResponses

+ type ResultBroadcastTxCommit struct

+ CheckTx ResponseCheckTx

+ DeliverTx ResponseDeliverTx

+ Hash cmn.HexBytes

+ Height int64

+ type ResultTx struct

+ Hash cmn.HexBytes

+ Height int64

+ Index uint32

+ Proof abci.TxProof

+ Tx abci.Tx

+ TxResult ResponseDeliverTx

+ type ResultTxSearch struct

+ TotalCount int

+ Txs []*ResultTx

+ type SignClient interface

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

+ BlockResults func(height *int64) (*ResultBlockResults, error)

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

+ Tx func(hash []byte, prove bool) (*ResultTx, error)

+ TxSearch func(query string, prove bool, page, perPage int) (*ResultTxSearch, error)

+ Validators func(height *int64) (*ctypes.ResultValidators, error)

+ type StakingClient interface

+ CreateSideChainValidator func(delegation types.Coin, description msg.Description, ...) (*coretypes.ResultBroadcastTx, error)

+ CreateValidatorOpen func(delegation types.Coin, description msg.Description, ...) (*coretypes.ResultBroadcastTx, error)

+ Delegate func(valAddr types.ValAddress, delegation types.Coin, syncType SyncType, ...) (*coretypes.ResultBroadcastTx, error)

+ EditSideChainValidator func(sideChainId string, description msg.Description, commissionRate *types.Dec, ...) (*coretypes.ResultBroadcastTx, error)

+ EditValidator func(description msg.Description, commissionRate *types.Dec, pubkey string, ...) (*coretypes.ResultBroadcastTx, error)

+ GetAllValidatorsCount func(jailInvolved bool) (int, error)

+ GetPool func() (*types.Pool, error)

+ GetRedelegationsByValidator func(valAddr types.ValAddress) ([]types.Redelegation, error)

+ GetSideChainAllValidatorsCount func(sideChainId string, jailInvolved bool) (int, error)

+ GetSideChainPool func(sideChainId string) (*types.Pool, error)

+ GetSideChainRedelegationsByValidator func(sideChainId string, valAddr types.ValAddress) ([]types.Redelegation, error)

+ GetSideChainUnBondingDelegationsByValidator func(sideChainId string, valAddr types.ValAddress) ([]types.UnbondingDelegation, error)

+ GetUnBondingDelegationsByValidator func(valAddr types.ValAddress) ([]types.UnbondingDelegation, error)

+ QueryDelegation func(delAddr types.AccAddress, valAddr types.ValAddress) (*types.DelegationResponse, error)

+ QueryDelegations func(delAddr types.AccAddress) ([]types.DelegationResponse, error)

+ QueryRedelegation func(delAddr types.AccAddress, valSrcAddr types.ValAddress, ...) (*types.Redelegation, error)

+ QueryRedelegations func(delAddr types.AccAddress) ([]types.Redelegation, error)

+ QuerySideChainDelegation func(sideChainId string, delAddr types.AccAddress, valAddr types.ValAddress) (*types.DelegationResponse, error)

+ QuerySideChainDelegations func(sideChainId string, delAddr types.AccAddress) ([]types.DelegationResponse, error)

+ QuerySideChainRedelegation func(sideChainId string, delAddr types.AccAddress, valSrcAddr types.ValAddress, ...) (*types.Redelegation, error)

+ QuerySideChainRedelegations func(sideChainId string, delAddr types.AccAddress) ([]types.Redelegation, error)

+ QuerySideChainTopValidators func(sideChainId string, top int) ([]types.Validator, error)

+ QuerySideChainUnbondingDelegation func(sideChainId string, valAddr types.ValAddress, delAddr types.AccAddress) (*types.UnbondingDelegation, error)

+ QuerySideChainUnbondingDelegations func(sideChainId string, delAddr types.AccAddress) ([]types.UnbondingDelegation, error)

+ QuerySideChainValidator func(sideChainId string, valAddr types.ValAddress) (*types.Validator, error)

+ QueryTopValidators func(top int) ([]types.Validator, error)

+ QueryUnbondingDelegation func(valAddr types.ValAddress, delAddr types.AccAddress) (*types.UnbondingDelegation, error)

+ QueryUnbondingDelegations func(delAddr types.AccAddress) ([]types.UnbondingDelegation, error)

+ QueryValidator func(valAddr types.ValAddress) (*types.Validator, error)

+ Redelegate func(valSrcAddr types.ValAddress, valDstAddr types.ValAddress, amount types.Coin, ...) (*coretypes.ResultBroadcastTx, error)

+ SideChainDelegate func(sideChainId string, valAddr types.ValAddress, delegation types.Coin, ...) (*coretypes.ResultBroadcastTx, error)

+ SideChainRedelegate func(sideChainId string, valSrcAddr types.ValAddress, valDstAddr types.ValAddress, ...) (*coretypes.ResultBroadcastTx, error)

+ SideChainUnbond func(sideChainId string, valAddr types.ValAddress, amount types.Coin, ...) (*coretypes.ResultBroadcastTx, error)

+ SideChainUnjail func(sideChainId string, valAddr types.ValAddress, syncType SyncType, ...) (*coretypes.ResultBroadcastTx, error)

+ Undelegate func(valAddr types.ValAddress, amount types.Coin, syncType SyncType, ...) (*coretypes.ResultBroadcastTx, error)

+ Unjail func(valAddr types.ValAddress, syncType SyncType, options ...tx.Option) (*coretypes.ResultBroadcastTx, error)

+ type SyncType int

+ const Async

+ const Commit

+ const Sync

+ type WSClient struct

+ Address string

+ Dialer func(string, string) (net.Conn, error)

+ Endpoint string

+ func NewWSClient(remoteAddr, endpoint string, responsesCh chan<- rpctypes.RPCResponse, ...) *WSClient

+ func (c *WSClient) ABCIInfo(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) ABCIQueryWithOptions(ctx context.Context, id rpctypes.JSONRPCStringID, path string, ...) error

+ func (c *WSClient) Block(ctx context.Context, id rpctypes.JSONRPCStringID, height *int64) error

+ func (c *WSClient) BlockResults(ctx context.Context, id rpctypes.JSONRPCStringID, height *int64) error

+ func (c *WSClient) BlockchainInfo(ctx context.Context, id rpctypes.JSONRPCStringID, minHeight, maxHeight int64) error

+ func (c *WSClient) BroadcastTx(ctx context.Context, id rpctypes.JSONRPCStringID, route string, tx types.Tx) error

+ func (c *WSClient) BroadcastTxCommit(ctx context.Context, id rpctypes.JSONRPCStringID, tx types.Tx) error

+ func (c *WSClient) Call(ctx context.Context, method string, id rpctypes.JSONRPCStringID, ...) error

+ func (c *WSClient) Codec() *amino.Codec

+ func (c *WSClient) Commit(ctx context.Context, id rpctypes.JSONRPCStringID, height *int64) error

+ func (c *WSClient) ConsensusState(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) DumpConsensusState(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) GenRequestId() (rpctypes.JSONRPCStringID, error)

+ func (c *WSClient) Genesis(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) Health(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) IsActive() bool

+ func (c *WSClient) IsDialing() bool

+ func (c *WSClient) NetInfo(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) NumUnconfirmedTxs(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) OnStart() error

+ func (c *WSClient) OnStop()

+ func (c *WSClient) Send(ctx context.Context, request rpctypes.RPCRequest) error

+ func (c *WSClient) SetCodec(cdc *amino.Codec)

+ func (c *WSClient) Status(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) String() string

+ func (c *WSClient) Subscribe(ctx context.Context, id rpctypes.JSONRPCStringID, query string) error

+ func (c *WSClient) Tx(ctx context.Context, id rpctypes.JSONRPCStringID, hash []byte, prove bool) error

+ func (c *WSClient) TxSearch(ctx context.Context, id rpctypes.JSONRPCStringID, query string, prove bool, ...) error

+ func (c *WSClient) UnconfirmedTxs(ctx context.Context, id rpctypes.JSONRPCStringID, limit int) error

+ func (c *WSClient) Unsubscribe(ctx context.Context, id rpctypes.JSONRPCStringID, query string) error

+ func (c *WSClient) UnsubscribeAll(ctx context.Context, id rpctypes.JSONRPCStringID) error

+ func (c *WSClient) Validators(ctx context.Context, id rpctypes.JSONRPCStringID, height *int64) error

+ type WSEvents struct

+ func (c *WSEvents) IsActive() bool

+ func (w *WSEvents) ABCIInfo() (*ctypes.ResultABCIInfo, error)

+ func (w *WSEvents) ABCIQueryWithOptions(path string, data cmn.HexBytes, opts client.ABCIQueryOptions) (*ctypes.ResultABCIQuery, error)

+ func (w *WSEvents) Block(height *int64) (*ctypes.ResultBlock, error)

+ func (w *WSEvents) BlockResults(height *int64) (*ResultBlockResults, error)

+ func (w *WSEvents) BlockchainInfo(minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error)

+ func (w *WSEvents) BroadcastTx(route string, tx types.Tx) (*ctypes.ResultBroadcastTx, error)

+ func (w *WSEvents) BroadcastTxCommit(tx types.Tx) (*ResultBroadcastTxCommit, error)

+ func (w *WSEvents) Commit(height *int64) (*ctypes.ResultCommit, error)

+ func (w *WSEvents) ConsensusState() (*ctypes.ResultConsensusState, error)

+ func (w *WSEvents) DumpConsensusState() (*ctypes.ResultDumpConsensusState, error)

+ func (w *WSEvents) Genesis() (*ctypes.ResultGenesis, error)

+ func (w *WSEvents) Health() (*ctypes.ResultHealth, error)

+ func (w *WSEvents) NetInfo() (*ctypes.ResultNetInfo, error)

+ func (w *WSEvents) NewContext() (context.Context, context.CancelFunc)

+ func (w *WSEvents) NumUnconfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error)

+ func (w *WSEvents) OnStart() error

+ func (w *WSEvents) OnStop()

+ func (w *WSEvents) PendingRequest() int

+ func (w *WSEvents) SetLogger(logger log.Logger)

+ func (w *WSEvents) SetTimeOut(timeout time.Duration)

+ func (w *WSEvents) SimpleCall(doRpc func(ctx context.Context, id rpctypes.JSONRPCStringID) error, ...) error

+ func (w *WSEvents) Status() (*ctypes.ResultStatus, error)

+ func (w *WSEvents) Subscribe(query string, outCapacity ...int) (out chan ctypes.ResultEvent, err error)

+ func (w *WSEvents) Tx(hash []byte, prove bool) (*ResultTx, error)

+ func (w *WSEvents) TxInfoSearch(query string, prove bool, page, perPage int) ([]Info, error)

+ func (w *WSEvents) TxSearch(query string, prove bool, page, perPage int) (*ResultTxSearch, error)

+ func (w *WSEvents) UnconfirmedTxs(limit int) (*ctypes.ResultUnconfirmedTxs, error)

+ func (w *WSEvents) Unsubscribe(query string) error

+ func (w *WSEvents) UnsubscribeAll() error

+ func (w *WSEvents) Validators(height *int64) (*ctypes.ResultValidators, error)

+ func (w *WSEvents) WaitForEventResponse(requestId interface{}, in chan rpctypes.RPCResponse, ...)

+ func (w *WSEvents) WaitForResponse(ctx context.Context, outChan chan rpctypes.RPCResponse, result interface{}, ...) error