Versions in this module Expand all Collapse all v1 v1.1.21 Jul 5, 2021 Changes in this version + type QueueProtocol struct + func (q *QueueProtocol) AddPushSubscribe(param *types.PushSubscribeReq) (*types.ReplySubscribePush, error) + func (q *QueueProtocol) Close() + func (q *QueueProtocol) CloseQueue() (*types.Reply, error) + func (q *QueueProtocol) ExecWallet(param *types.ChainExecutor) (types.Message, error) + func (q *QueueProtocol) ExecWalletFunc(driver string, funcname string, param types.Message) (types.Message, error) + func (q *QueueProtocol) GetAddrOverview(param *types.ReqAddr) (*types.AddrOverview, error) + func (q *QueueProtocol) GetBlockByHashes(param *types.ReqHashes) (*types.BlockDetails, error) + func (q *QueueProtocol) GetBlockBySeq(param *types.Int64) (*types.BlockSeq, error) + func (q *QueueProtocol) GetBlockHash(param *types.ReqInt) (*types.ReplyHash, error) + func (q *QueueProtocol) GetBlockOverview(param *types.ReqHash) (*types.BlockOverview, error) + func (q *QueueProtocol) GetBlockSequences(param *types.ReqBlocks) (*types.BlockSequences, error) + func (q *QueueProtocol) GetBlocks(param *types.ReqBlocks) (*types.BlockDetails, error) + func (q *QueueProtocol) GetConfig() *types.TuringchainConfig + func (q *QueueProtocol) GetHeaders(param *types.ReqBlocks) (*types.Headers, error) + func (q *QueueProtocol) GetLastBlockMainSequence() (*types.Int64, error) + func (q *QueueProtocol) GetLastBlockSequence() (*types.Int64, error) + func (q *QueueProtocol) GetLastHeader() (*types.Header, error) + func (q *QueueProtocol) GetLastMempool() (*types.ReplyTxList, error) + func (q *QueueProtocol) GetMainSequenceByHash(param *types.ReqHash) (*types.Int64, error) + func (q *QueueProtocol) GetMempool(req *types.ReqGetMempool) (*types.ReplyTxList, error) + func (q *QueueProtocol) GetNetInfo(req *types.P2PGetNetInfoReq) (*types.NodeNetInfo, error) + func (q *QueueProtocol) GetParaTxByHeight(param *types.ReqParaTxByHeight) (*types.ParaTxDetails, error) + func (q *QueueProtocol) GetParaTxByTitle(param *types.ReqParaTxByTitle) (*types.ParaTxDetails, error) + func (q *QueueProtocol) GetProperFee(req *types.ReqProperFee) (*types.ReplyProperFee, error) + func (q *QueueProtocol) GetPushSeqLastNum(param *types.ReqString) (*types.Int64, error) + func (q *QueueProtocol) GetSequenceByHash(param *types.ReqHash) (*types.Int64, error) + func (q *QueueProtocol) GetTransactionByAddr(param *types.ReqAddr) (*types.ReplyTxInfos, error) + func (q *QueueProtocol) GetTransactionByHash(param *types.ReqHashes) (*types.TransactionDetails, error) + func (q *QueueProtocol) GetTxList(param *types.TxHashList) (*types.ReplyTxList, error) + func (q *QueueProtocol) IsNtpClockSync() (*types.Reply, error) + func (q *QueueProtocol) IsSync() (*types.Reply, error) + func (q *QueueProtocol) ListPushes() (*types.PushSubscribes, error) + func (q *QueueProtocol) LoadParaTxByTitle(param *types.ReqHeightByTitle) (*types.ReplyHeightByTitle, error) + func (q *QueueProtocol) LocalBegin(param *types.Int64) error + func (q *QueueProtocol) LocalClose(param *types.Int64) error + func (q *QueueProtocol) LocalCommit(param *types.Int64) error + func (q *QueueProtocol) LocalGet(param *types.LocalDBGet) (*types.LocalReplyValue, error) + func (q *QueueProtocol) LocalList(param *types.LocalDBList) (*types.LocalReplyValue, error) + func (q *QueueProtocol) LocalNew(readOnly bool) (*types.Int64, error) + func (q *QueueProtocol) LocalRollback(param *types.Int64) error + func (q *QueueProtocol) LocalSet(param *types.LocalDBSet) error + func (q *QueueProtocol) NetProtocols(req *types.ReqNil) (*types.NetProtocolInfos, error) + func (q *QueueProtocol) NewMessage(topic string, msgid int64, data interface{}) *queue.Message + func (q *QueueProtocol) Notify(topic string, ty int64, data interface{}) (*queue.Message, error) + func (q *QueueProtocol) PeerInfo(req *types.P2PGetPeerReq) (*types.PeerList, error) + func (q *QueueProtocol) Query(driver, funcname string, param types.Message) (types.Message, error) + func (q *QueueProtocol) QueryChain(param *types.ChainExecutor) (types.Message, error) + func (q *QueueProtocol) QueryConsensus(param *types.ChainExecutor) (types.Message, error) + func (q *QueueProtocol) QueryConsensusFunc(driver string, funcname string, param types.Message) (types.Message, error) + func (q *QueueProtocol) QueryTx(param *types.ReqHash) (*types.TransactionDetail, error) + func (q *QueueProtocol) SendTx(param *types.Transaction) (*types.Reply, error) + func (q *QueueProtocol) StoreCommit(param *types.ReqHash) (*types.ReplyHash, error) + func (q *QueueProtocol) StoreDel(param *types.StoreDel) (*types.ReplyHash, error) + func (q *QueueProtocol) StoreGet(param *types.StoreGet) (*types.StoreReplyValue, error) + func (q *QueueProtocol) StoreGetTotalCoins(param *types.IterateRangeByStateHash) (*types.ReplyGetTotalCoins, error) + func (q *QueueProtocol) StoreList(param *types.StoreList) (*types.StoreListReply, error) + func (q *QueueProtocol) StoreMemSet(param *types.StoreSetWithSync) (*types.ReplyHash, error) + func (q *QueueProtocol) StoreRollback(param *types.ReqHash) (*types.ReplyHash, error) + func (q *QueueProtocol) StoreSet(param *types.StoreSetWithSync) (*types.ReplyHash, error) + func (q *QueueProtocol) Version() (*types.VersionInfo, error) + type QueueProtocolAPI interface + AddPushSubscribe func(param *types.PushSubscribeReq) (*types.ReplySubscribePush, error) + Close func() + CloseQueue func() (*types.Reply, error) + ExecWallet func(param *types.ChainExecutor) (types.Message, error) + ExecWalletFunc func(driver string, funcname string, param types.Message) (types.Message, error) + GetAddrOverview func(param *types.ReqAddr) (*types.AddrOverview, error) + GetBlockByHashes func(param *types.ReqHashes) (*types.BlockDetails, error) + GetBlockBySeq func(param *types.Int64) (*types.BlockSeq, error) + GetBlockHash func(param *types.ReqInt) (*types.ReplyHash, error) + GetBlockOverview func(param *types.ReqHash) (*types.BlockOverview, error) + GetBlockSequences func(param *types.ReqBlocks) (*types.BlockSequences, error) + GetBlocks func(param *types.ReqBlocks) (*types.BlockDetails, error) + GetConfig func() *types.TuringchainConfig + GetHeaders func(param *types.ReqBlocks) (*types.Headers, error) + GetLastBlockMainSequence func() (*types.Int64, error) + GetLastBlockSequence func() (*types.Int64, error) + GetLastHeader func() (*types.Header, error) + GetLastMempool func() (*types.ReplyTxList, error) + GetMainSequenceByHash func(param *types.ReqHash) (*types.Int64, error) + GetMempool func(req *types.ReqGetMempool) (*types.ReplyTxList, error) + GetNetInfo func(param *types.P2PGetNetInfoReq) (*types.NodeNetInfo, error) + GetParaTxByHeight func(param *types.ReqParaTxByHeight) (*types.ParaTxDetails, error) + GetParaTxByTitle func(param *types.ReqParaTxByTitle) (*types.ParaTxDetails, error) + GetProperFee func(req *types.ReqProperFee) (*types.ReplyProperFee, error) + GetPushSeqLastNum func(param *types.ReqString) (*types.Int64, error) + GetSequenceByHash func(param *types.ReqHash) (*types.Int64, error) + GetTransactionByAddr func(param *types.ReqAddr) (*types.ReplyTxInfos, error) + GetTransactionByHash func(param *types.ReqHashes) (*types.TransactionDetails, error) + GetTxList func(param *types.TxHashList) (*types.ReplyTxList, error) + IsNtpClockSync func() (*types.Reply, error) + IsSync func() (*types.Reply, error) + ListPushes func() (*types.PushSubscribes, error) + LoadParaTxByTitle func(param *types.ReqHeightByTitle) (*types.ReplyHeightByTitle, error) + LocalBegin func(param *types.Int64) error + LocalClose func(param *types.Int64) error + LocalCommit func(param *types.Int64) error + LocalGet func(param *types.LocalDBGet) (*types.LocalReplyValue, error) + LocalList func(param *types.LocalDBList) (*types.LocalReplyValue, error) + LocalNew func(readOnly bool) (*types.Int64, error) + LocalRollback func(param *types.Int64) error + LocalSet func(param *types.LocalDBSet) error + NetProtocols func(*types.ReqNil) (*types.NetProtocolInfos, error) + NewMessage func(topic string, msgid int64, data interface{}) *queue.Message + Notify func(topic string, ty int64, data interface{}) (*queue.Message, error) + PeerInfo func(param *types.P2PGetPeerReq) (*types.PeerList, error) + Query func(driver, funcname string, param types.Message) (types.Message, error) + QueryChain func(param *types.ChainExecutor) (types.Message, error) + QueryConsensus func(param *types.ChainExecutor) (types.Message, error) + QueryConsensusFunc func(driver string, funcname string, param types.Message) (types.Message, error) + QueryTx func(param *types.ReqHash) (*types.TransactionDetail, error) + SendTx func(param *types.Transaction) (*types.Reply, error) + StoreCommit func(param *types.ReqHash) (*types.ReplyHash, error) + StoreDel func(param *types.StoreDel) (*types.ReplyHash, error) + StoreGet func(*types.StoreGet) (*types.StoreReplyValue, error) + StoreGetTotalCoins func(*types.IterateRangeByStateHash) (*types.ReplyGetTotalCoins, error) + StoreList func(param *types.StoreList) (*types.StoreListReply, error) + StoreMemSet func(param *types.StoreSetWithSync) (*types.ReplyHash, error) + StoreRollback func(param *types.ReqHash) (*types.ReplyHash, error) + StoreSet func(param *types.StoreSetWithSync) (*types.ReplyHash, error) + Version func() (*types.VersionInfo, error) + func New(client queue.Client, option *QueueProtocolOption) (QueueProtocolAPI, error) + type QueueProtocolOption struct + SendTimeout time.Duration + WaitTimeout time.Duration
Go to main page