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

v1

v1.2.11

Sep 23, 2022

v1.2.10

Sep 23, 2022

v1.2.9

Sep 23, 2022

v1.2.8

Sep 23, 2022

v1.2.7

Sep 23, 2022

v1.0.0

Sep 23, 2022

Changes in this version

+ const AccountStoreName

+ const AtomicSwapStoreName

+ const BridgeStoreName

+ 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 MaxReconnectAttempts(max int) func(*WSClient)

+ func OnReconnect(cb func()) func(*WSClient)

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

+ func PingPeriod(pingPeriod time.Duration) func(*WSClient)

+ func ReadWait(readWait time.Duration) func(*WSClient)

+ func ValidateABCIData(data libbytes.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

+ func WriteWait(writeWait time.Duration) func(*WSClient)

+ type ABCIClient interface

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

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

+ ABCIQueryWithOptions func(path string, data libbytes.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)

+ GetDepth func(tradePair string, level int) (*types.OrderBook, error)

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

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

+ GetMiniTradingPairs func(offset int, limit int) ([]types.TradingPair, error)

+ GetOpenOrders func(addr types.AccAddress, pair string) ([]types.OpenOrder, 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)

+ GetTradingPairs func(offset int, limit int) ([]types.TradingPair, 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 libbytes.HexBytes) (*ctypes.ResultABCIQuery, error)

+ func (c *HTTP) ABCIQueryWithOptions(path string, data libbytes.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) 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) Genesis() (*ctypes.ResultGenesis, error)

+ func (c *HTTP) GetAccount(addr types.AccAddress) (acc types.Account, err 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) GetDepth(tradePair string, level int) (*types.OrderBook, error)

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

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

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

+ func (c *HTTP) GetOpenOrders(addr types.AccAddress, pair string) ([]types.OpenOrder, 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) 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) GetTradingPairs(offset int, limit int) ([]types.TradingPair, 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) 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 libbytes.HexBytes, storeName string) ([]byte, error)

+ func (c *HTTP) QueryStoreSubspace(key libbytes.HexBytes, storeName string) (res []abcitypes.EventAttribute, err error)

+ func (c *HTTP) QueryWithData(path string, data libbytes.HexBytes) ([]byte, 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) 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 libbytes.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 []types.EventAttribute

+ type ResponseCheckTx struct

+ Code uint32

+ Codespace string

+ Data []byte

+ Events []types.Event

+ GasUsed int64

+ GasWanted int64

+ Info string

+ Log string

+ Tags []types.EventAttribute

+ 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 []types.EventAttribute

+ type ResponseEndBlock struct

+ ConsensusParamUpdates *types.ConsensusParams

+ Events []types.Event

+ Tags []types.EventAttribute

+ ValidatorUpdates []types.ValidatorUpdate

+ type ResultBlockResults struct

+ Height int64

+ Results *ABCIResponses

+ type ResultBroadcastTxCommit struct

+ CheckTx ResponseCheckTx

+ DeliverTx ResponseDeliverTx

+ Hash libbytes.HexBytes

+ Height int64

+ type ResultTx struct

+ Hash libbytes.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)

+ EditSideChainValidator func(sideChainId string, description msg.Description, commissionRate *types.Dec, ...) (*coretypes.ResultBroadcastTx, 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)

+ 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)

+ 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)

+ type SyncType int

+ const Async

+ const Commit

+ const Sync

+ type WSClient struct

+ Address string

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

+ Endpoint string

+ ResponsesCh chan rpctypes.RPCResponse

+ func NewWSClient(remoteAddr, endpoint string, options ...func(*WSClient)) *WSClient

+ func (c *WSClient) ABCIInfo(ctx context.Context) error

+ func (c *WSClient) ABCIQueryWithOptions(ctx context.Context, path string, data libbytes.HexBytes, ...) error

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

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

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

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

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

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

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

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

+ func (c *WSClient) ConsensusState(ctx context.Context) error

+ func (c *WSClient) DumpConsensusState(ctx context.Context) error

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

+ func (c *WSClient) Genesis(ctx context.Context) error

+ func (c *WSClient) Health(ctx context.Context) error

+ func (c *WSClient) IsActive() bool

+ func (c *WSClient) IsReconnecting() bool

+ func (c *WSClient) NetInfo(ctx context.Context) error

+ func (c *WSClient) NumUnconfirmedTxs(ctx context.Context) error

+ func (c *WSClient) OnStart() error

+ 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) error

+ func (c *WSClient) Stop() error

+ func (c *WSClient) String() string

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

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

+ func (c *WSClient) TxSearch(ctx context.Context, query string, prove bool, page, perPage int) error

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

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

+ func (c *WSClient) UnsubscribeAll(ctx context.Context) error

+ func (c *WSClient) Validators(ctx context.Context, 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 libbytes.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) 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) error, ws *WSClient, proto interface{}) error

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

+ func (w *WSEvents) Subscribe(ctx context.Context, subscriber, 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(ctx context.Context, subscriber, query string) error

+ func (w *WSEvents) UnsubscribeAll(ctx context.Context, subscriber string) error

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

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