rpc

Dec 21, 2022

Changes in this version

type HTTP

+ 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) EditValidator(description msg.Description, commissionRate *types.Dec, pubkey string, ...) (*coretypes.ResultBroadcastTx, error)

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

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

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

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

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

+ func (c *HTTP) GetUnBondingDelegationsByValidator(valAddr types.ValAddress) ([]types.UnbondingDelegation, 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) 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) Redelegate(valSrcAddr types.ValAddress, valDstAddr types.ValAddress, amount types.Coin, ...) (*coretypes.ResultBroadcastTx, 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)

type StakingClient

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

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

+ EditValidator func(description msg.Description, commissionRate *types.Dec, sideFeeAddr []byte, ...) (*coretypes.ResultBroadcastTx, error)

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

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

+ GetRedelegationsByValidator func(valAddr types.ValAddress) ([]types.Redelegation, 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)

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

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

Jan 18, 2021

Changes in this version

type DexClient

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

type HTTP

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

Aug 21, 2020

Changes in this version

+ const BridgeStoreName

+ const OracleStoreName

+ const SideChainStoreName

+ var DelegationKey = []byte

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

+ var PoolKey = []byte

+ var RedelegationKey = []byte

+ var SideChainStorePrefixByIdKey = []byte

+ var StakeScStoreKey = "sc"

+ var StakeStoreKey = "stake"

+ var UnbondingDelegationKey = []byte

+ var ValidatorsKey = []byte

type DexClient

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

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

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

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

+ GetProphecy func(chainId sdk.IbcChainID, sequence int64) (*msg.Prophecy, 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)

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

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

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

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

+ func (c *HTTP) Claim(chainId sdk.IbcChainID, sequence uint64, payload []byte, syncType SyncType, ...) (*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) EditSideChainValidator(sideChainId string, description msg.Description, commissionRate *types.Dec, ...) (*coretypes.ResultBroadcastTx, error)

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

+ func (c *HTTP) GetProphecy(chainId sdk.IbcChainID, sequence int64) (*msg.Prophecy, 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) 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) QueryStoreSubspace(key cmn.HexBytes, storeName string) (res []cmn.KVPair, err error)

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

+ 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) 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) Unbind(symbol string, syncType SyncType, options ...tx.Option) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) Vote(proposalID int64, option msg.VoteOption, syncType SyncType, ...) (*core_types.ResultBroadcastTx, 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)

Jun 1, 2020

Changes in this version

type DexClient

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

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

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

type HTTP

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

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

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

Nov 11, 2019

Changes in this version

+ var DefaultTimeout = 2 * time.Second

+ 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 Info struct

+ Hash cmn.HexBytes

+ Height int64

+ Result ResponseDeliverTx

+ Tx tx.Tx

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

Sep 18, 2019

Changes in this version

+ const AtomicSwapStoreName

+ var KeyMissingError = fmt.Errorf("BaseAssetSymbol or QuoteAssetSymbol is missing. ")

type DexClient

+ CancelOrder func(baseAssetSymbol, quoteAssetSymbol, refId string, 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)

+ DepositHTLT func(recipient types.AccAddress, swapID []byte, amount types.Coins, ...) (*core_types.ResultBroadcastTx, 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)

+ HTLT func(recipient types.AccAddress, recipientOtherChain, senderOtherChain string, ...) (*core_types.ResultBroadcastTx, 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)

type HTTP

+ func (c *HTTP) CancelOrder(baseAssetSymbol, quoteAssetSymbol, refId string, 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) CreateOrder(baseAssetSymbol, quoteAssetSymbol string, op int8, price, quantity int64, ...) (*core_types.ResultBroadcastTx, error)

+ func (c *HTTP) DepositHTLT(recipient types.AccAddress, swapID []byte, amount types.Coins, ...) (*core_types.ResultBroadcastTx, 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) HTLT(recipient types.AccAddress, recipientOtherChain, senderOtherChain string, ...) (*core_types.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)

+ type SyncType int

+ const Async

+ const Commit

+ const Sync

Aug 28, 2019

Changes in this version

+ const TimeLockrcNotFoundErrorCode

Aug 20, 2019

Changes in this version

+ const EmptyRequest

type WSClient

+ func (c *WSClient) OnStop()

type WSEvents

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

Aug 7, 2019

Changes in this version

+ const TimeLockMsgRoute

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

+ func ValidateDepthLevel(level int) error

type DexClient

+ GetTimelock func(address string, recordID int64) (types.TimeLockRecord, error)

+ GetTimelocks func(address string) ([]types.TimeLockRecord, error)

type HTTP

+ func (c *HTTP) GetTimelock(address string, recordID int64) (types.TimeLockRecord, error)

+ func (c *HTTP) GetTimelocks(address string) ([]types.TimeLockRecord, error)

Jul 10, 2019

Changes in this version

type DexClient

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

type HTTP

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

Jun 3, 2019

Changes in this version

type DexClient

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

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

type HTTP

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

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

type WSClient

+ func (c *WSClient) GetConnection() *websocket.Conn

+ func (c *WSClient) SetConnection(conn *websocket.Conn)

May 8, 2019

Changes in this version

+ const AccountStoreName

+ const ParamABCIPrefix

+ const TokenStoreName

+ 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 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 SymbolLengthExceedRangeError = fmt.Errorf("length of symbol should be in range [%d,%d]", tokenSymbolMinLen, ...)

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

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

+ 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 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 Client interface

+ type DexClient interface

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

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

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

+ GetOpenOrders func(addr types.AccAddress, pair string) ([]types.OpenOrder, error)

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

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

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

+ TxInfoSearch func(query string, prove bool, page, perPage int) ([]tx.Info, 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) *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) Block(height *int64) (*ctypes.ResultBlock, error)

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

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

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

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

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

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

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

+ func (c *HTTP) DumpConsensusState() (*ctypes.ResultDumpConsensusState, 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) GetDelegatorUnbondingDelegations(delegatorAddr types.AccAddress) ([]types.UnbondingDelegation, error)

+ func (c *HTTP) GetDepth(tradePair string) (*types.OrderBook, error)

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

+ func (c *HTTP) GetOpenOrders(addr types.AccAddress, pair string) ([]types.OpenOrder, error)

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

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

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

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

+ func (c *HTTP) IsActive() bool

+ 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) QueryStore(key cmn.HexBytes, storeName string) ([]byte, error)

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

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

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

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

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

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

+ type OpsClient interface

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

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

+ IsActive func() bool

+ 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, 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) CallWithArrayParams(ctx context.Context, method string, params []interface{}) 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) EmptyRequest() rpctypes.JSONRPCStringID

+ 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) 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) Stop() 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) (*ctypes.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) (*ctypes.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) 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) (*ctypes.ResultTx, error)

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

+ func (w *WSEvents) TxSearch(query string, prove bool, page, perPage int) (*ctypes.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