rpc

package
v1.67.2 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2022 License: BSD-3-Clause Imports: 40 Imported by: 9

Documentation

Overview

Package rpc chain33 RPC模块包含JSONRpc以及grpc

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitCfg 

func InitCfg(cfg *types.RPC)

InitCfg interfaces

func InitFilterPrintFuncBlacklist 

func InitFilterPrintFuncBlacklist()

InitFilterPrintFuncBlacklist rpc模块打印requet信息时需要过滤掉一些敏感接口的入参打印，比如钱包密码相关的

func InitGrpcFuncBlacklist 

func InitGrpcFuncBlacklist(cfg *types.RPC)

InitGrpcFuncBlacklist init grpc function blacklist

func InitGrpcFuncWhitelist 

func InitGrpcFuncWhitelist(cfg *types.RPC)

InitGrpcFuncWhitelist init grpc function whitelist

func InitIPWhitelist 

func InitIPWhitelist(cfg *types.RPC)

InitIPWhitelist init ip whitelist

func InitJrpcFuncBlacklist 

func InitJrpcFuncBlacklist(cfg *types.RPC)

InitJrpcFuncBlacklist init jrpc function blacklist

func InitJrpcFuncWhitelist 

func InitJrpcFuncWhitelist(cfg *types.RPC)

InitJrpcFuncWhitelist init jrpc function whitelist

Types

type Chain33 

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

Chain33 a channel client

func (*Chain33) AddBlacklist added in v1.65.3 

func (c *Chain33) AddBlacklist(in *types.BlackPeer, result *interface{}) error

AddBlacklist add peer to blacklist ,time deadline:10 years

func (*Chain33) AddPushSubscribe added in v1.65.0 

func (c *Chain33) AddPushSubscribe(in *types.PushSubscribeReq, result *interface{}) error

AddPushSubscribe add Seq CallBack

func (*Chain33) ClosePeer added in v1.65.3 

func (c *Chain33) ClosePeer(in *types.SetPeer, result *interface{}) error

ClosePeer close the specified peer

func (*Chain33) CloseQueue 

func (c *Chain33) CloseQueue(in *types.ReqNil, result *interface{}) error

CloseQueue close queue

func (*Chain33) ConvertExectoAddr 

func (c *Chain33) ConvertExectoAddr(in rpctypes.ExecNameParm, result *string) error

ConvertExectoAddr convert exec to address

func (*Chain33) CreateNoBalanceTransaction 

func (c *Chain33) CreateNoBalanceTransaction(in *types.NoBalanceTx, result *string) error

CreateNoBalanceTransaction create transaction with no balance

func (*Chain33) CreateNoBlanaceTxs 

func (c *Chain33) CreateNoBlanaceTxs(in *types.NoBalanceTxs, result *string) error

CreateNoBlanaceTxs create multiple transaction with no balance

func (*Chain33) CreateRawTransaction 

func (c *Chain33) CreateRawTransaction(in *rpctypes.CreateTx, result *interface{}) error

CreateRawTransaction create rawtransaction by jrpc

func (*Chain33) CreateRawTxGroup 

func (c *Chain33) CreateRawTxGroup(in *types.CreateTransactionGroup, result *interface{}) error

CreateRawTxGroup create rawtransaction with group

func (*Chain33) CreateTransaction 

func (c *Chain33) CreateTransaction(in *rpctypes.CreateTxIn, result *interface{}) error

CreateTransaction create transaction

func (*Chain33) DecodeRawTransaction 

func (c *Chain33) DecodeRawTransaction(in *types.ReqDecodeRawTransaction, result *interface{}) error

DecodeRawTransaction 考虑交易组的解析统一返回ReplyTxList列表

func (*Chain33) DelBlacklist added in v1.65.3 

func (c *Chain33) DelBlacklist(in *types.BlackPeer, result *interface{}) error

DelBlacklist delete peer from blacklist

func (*Chain33) DialPeer added in v1.65.3 

func (c *Chain33) DialPeer(in *types.SetPeer, result *interface{}) error

DialPeer dial the specified peer

func (*Chain33) DumpPrivkey 

func (c *Chain33) DumpPrivkey(in *types.ReqString, result *interface{}) error

DumpPrivkey dump privkey

func (*Chain33) DumpPrivkeysFile 

func (c *Chain33) DumpPrivkeysFile(in *types.ReqPrivkeysFile, result *interface{}) error

DumpPrivkeysFile dumps private key to file.

func (*Chain33) ExecWallet 

func (c *Chain33) ExecWallet(in *rpctypes.ChainExecutor, result *interface{}) error

ExecWallet exec wallet

func (*Chain33) GenSeed 

func (c *Chain33) GenSeed(in *types.GenSeedLang, result *interface{}) error

GenSeed seed

func (*Chain33) GetAccount added in v1.65.0 

func (c *Chain33) GetAccount(in *types.ReqGetAccount, result *interface{}) error

GetAccount getAddress by lable

func (*Chain33) GetAccounts 

func (c *Chain33) GetAccounts(in *types.ReqAccountList, result *interface{}) error

GetAccounts get accounts

func (*Chain33) GetAccountsV2 

func (c *Chain33) GetAccountsV2(in *types.ReqNil, result *interface{}) error

GetAccountsV2 get accounts for version 2

func (*Chain33) GetAddrOverview 

func (c *Chain33) GetAddrOverview(in *types.ReqAddr, result *interface{}) error

GetAddrOverview get overview of address

func (*Chain33) GetAddressDrivers added in v1.67.1 

func (c *Chain33) GetAddressDrivers(in *types.ReqNil, result *interface{}) error

GetAddressDrivers 获取系统已注册地址插件

func (*Chain33) GetAllExecBalance 

func (c *Chain33) GetAllExecBalance(in *types.ReqAllExecBalance, result *interface{}) error

GetAllExecBalance get all balance of exec

func (*Chain33) GetBalance 

func (c *Chain33) GetBalance(in *types.ReqBalance, result *interface{}) error

GetBalance get balance

func (*Chain33) GetBlockByHashes 

func (c *Chain33) GetBlockByHashes(in rpctypes.ReqHashes, result *interface{}) error

GetBlockByHashes get block information by hashes

func (*Chain33) GetBlockBySeq added in v1.65.1 

func (c *Chain33) GetBlockBySeq(in *types.Int64, result *interface{}) error

GetBlockBySeq get block by seq

func (*Chain33) GetBlockHash 

func (c *Chain33) GetBlockHash(in *types.ReqInt, result *interface{}) error

GetBlockHash get block hash

func (*Chain33) GetBlockOverview 

func (c *Chain33) GetBlockOverview(in rpctypes.QueryParm, result *interface{}) error

GetBlockOverview get overview of block GetBlockOverview(parm *types.ReqHash) (*types.BlockOverview, error)

func (*Chain33) GetBlockSequences 

func (c *Chain33) GetBlockSequences(in rpctypes.BlockParam, result *interface{}) error

GetBlockSequences get the block loading sequence number information for the specified interval

func (*Chain33) GetBlocks 

func (c *Chain33) GetBlocks(in rpctypes.BlockParam, result *interface{}) error

GetBlocks get block information

func (*Chain33) GetChainConfig added in v1.65.3 

func (c *Chain33) GetChainConfig(in *types.ReqNil, result *interface{}) error

GetChainConfig 获取chain config 参数

func (*Chain33) GetChainID added in v1.65.3 

func (c *Chain33) GetChainID(in *types.ReqNil, result *interface{}) error

GetChainID 获取chain ID

func (*Chain33) GetCoinSymbol 

func (c *Chain33) GetCoinSymbol(in *types.ReqNil, result *interface{}) error

GetCoinSymbol get coin symbol

func (*Chain33) GetCryptoList added in v1.65.3 

func (c *Chain33) GetCryptoList(in *types.ReqNil, result *interface{}) error

GetCryptoList 获取加密列表

func (*Chain33) GetExecBalance 

func (c *Chain33) GetExecBalance(in *types.ReqGetExecBalance, result *interface{}) error

GetExecBalance get balance exec

func (*Chain33) GetFatalFailure 

func (c *Chain33) GetFatalFailure(in *types.ReqNil, result *interface{}) error

GetFatalFailure return fatal failure

func (*Chain33) GetHeaders 

func (c *Chain33) GetHeaders(in *types.ReqBlocks, result *interface{}) error

GetHeaders get headers

func (*Chain33) GetHexTxByHash 

func (c *Chain33) GetHexTxByHash(in rpctypes.QueryParm, result *interface{}) error

GetHexTxByHash get hex transaction by hash

func (*Chain33) GetLastBlockSequence 

func (c *Chain33) GetLastBlockSequence(in *types.ReqNil, result *interface{}) error

GetLastBlockSequence get sequence last block

func (*Chain33) GetLastHeader 

func (c *Chain33) GetLastHeader(in *types.ReqNil, result *interface{}) error

GetLastHeader get last header

func (*Chain33) GetLastMemPool 

func (c *Chain33) GetLastMemPool(in *types.ReqNil, result *interface{}) error

GetLastMemPool get contents in last mempool

func (*Chain33) GetMempool 

func (c *Chain33) GetMempool(in *types.ReqGetMempool, result *interface{}) error

GetMempool get mempool information

func (*Chain33) GetNetInfo 

func (c *Chain33) GetNetInfo(in *types.P2PGetNetInfoReq, result *interface{}) error

GetNetInfo get net information

func (*Chain33) GetParaTxByHeight added in v1.65.1 

func (c *Chain33) GetParaTxByHeight(req *types.ReqParaTxByHeight, result *interface{}) error

GetParaTxByHeight get paraTx by block height

func (*Chain33) GetParaTxByTitle added in v1.65.1 

func (c *Chain33) GetParaTxByTitle(req *types.ReqParaTxByTitle, result *interface{}) error

GetParaTxByTitle get paraTx by title

func (*Chain33) GetPeerInfo 

func (c *Chain33) GetPeerInfo(in *types.P2PGetPeerReq, result *interface{}) error

GetPeerInfo get peer information

func (*Chain33) GetProperFee 

func (c *Chain33) GetProperFee(in *types.ReqProperFee, result *interface{}) error

GetProperFee get contents in proper fee

func (*Chain33) GetPushSeqLastNum added in v1.65.0 

func (c *Chain33) GetPushSeqLastNum(in *types.ReqString, result *interface{}) error

GetPushSeqLastNum Get Seq Call Back Last Num

func (*Chain33) GetSeed 

func (c *Chain33) GetSeed(in *types.GetSeedByPw, result *interface{}) error

GetSeed get seed

func (*Chain33) GetSequenceByHash added in v1.65.1 

func (c *Chain33) GetSequenceByHash(in rpctypes.ReqHashes, result *interface{}) error

GetSequenceByHash get sequcen by hashes

func (*Chain33) GetServerTime added in v1.65.1 

func (c *Chain33) GetServerTime(in *types.ReqNil, result *interface{}) error

GetServerTime get server time

func (*Chain33) GetTimeStatus 

func (c *Chain33) GetTimeStatus(in *types.ReqNil, result *interface{}) error

GetTimeStatus get status of time

func (*Chain33) GetTotalCoins 

func (c *Chain33) GetTotalCoins(in *types.ReqGetTotalCoins, result *interface{}) error

GetTotalCoins get total coins

func (*Chain33) GetTxByAddr 

func (c *Chain33) GetTxByAddr(in *types.ReqAddr, result *interface{}) error

GetTxByAddr get transaction by address GetTxByAddr(parm *types.ReqAddr) (*types.ReplyTxInfo, error)

func (*Chain33) GetTxByHashes 

func (c *Chain33) GetTxByHashes(in rpctypes.ReqHashes, result *interface{}) error

GetTxByHashes get transaction by hashes

GetTxByHashes(parm *types.ReqHashes) (*types.TransactionDetails, error) GetMempool() (*types.ReplyTxList, error) GetAccounts() (*types.WalletAccounts, error)

func (*Chain33) GetWalletRecoverAddress added in v1.65.3 

func (c *Chain33) GetWalletRecoverAddress(req *types.ReqGetWalletRecoverAddr, result *interface{}) error

GetWalletRecoverAddress get wallet recover chain33 addr

func (*Chain33) GetWalletStatus 

func (c *Chain33) GetWalletStatus(in *types.ReqNil, result *interface{}) error

GetWalletStatus get status of wallet

func (*Chain33) ImportPrivkey 

func (c *Chain33) ImportPrivkey(in *types.ReqWalletImportPrivkey, result *interface{}) error

ImportPrivkey import privkey of wallet

func (*Chain33) ImportPrivkeysFile 

func (c *Chain33) ImportPrivkeysFile(in *types.ReqPrivkeysFile, result *interface{}) error

ImportPrivkeysFile imports private key from file.

func (*Chain33) IsNtpClockSync 

func (c *Chain33) IsNtpClockSync(in *types.ReqNil, result *interface{}) error

IsNtpClockSync is ntp clock sync

func (*Chain33) IsSync 

func (c *Chain33) IsSync(in *types.ReqNil, result *interface{}) error

IsSync is sync or not

func (*Chain33) ListPushes added in v1.65.0 

func (c *Chain33) ListPushes(in *types.ReqNil, result *interface{}) error

ListPushes List Seq CallBack

func (*Chain33) LoadParaTxByTitle added in v1.65.1 

func (c *Chain33) LoadParaTxByTitle(req *types.ReqHeightByTitle, result *interface{}) error

LoadParaTxByTitle load paratx by title

func (*Chain33) Lock 

func (c *Chain33) Lock(in *types.ReqNil, result *interface{}) error

Lock wallet lock

func (*Chain33) MergeBalance 

func (c *Chain33) MergeBalance(in *types.ReqWalletMergeBalance, result *interface{}) error

MergeBalance merge balance

func (*Chain33) NetProtocols added in v1.65.0 

func (c *Chain33) NetProtocols(in *types.ReqNil, result *interface{}) error

NetProtocols get net information

func (*Chain33) NewAccount 

func (c *Chain33) NewAccount(in *types.ReqNewAccount, result *interface{}) error

NewAccount new a account

func (*Chain33) NewRandAccount added in v1.65.3 

func (c *Chain33) NewRandAccount(in *types.GenSeedLang, result *interface{}) error

NewRandAccount rand new a account

func (*Chain33) PubKeyToAddr added in v1.65.3 

func (c *Chain33) PubKeyToAddr(in *types.ReqString, result *interface{}) error

PubKeyToAddr pubkey to addr

func (*Chain33) Query 

func (c *Chain33) Query(in rpctypes.Query4Jrpc, result *interface{}) error

Query query

func (*Chain33) QueryChain added in v1.65.1 

func (c *Chain33) QueryChain(in rpctypes.ChainExecutor, result *interface{}) error

QueryChain querychain by chain executor

func (*Chain33) QueryTotalFee 

func (c *Chain33) QueryTotalFee(in *types.LocalDBGet, result *interface{}) error

QueryTotalFee query total fee

func (*Chain33) QueryTransaction 

func (c *Chain33) QueryTransaction(in rpctypes.QueryParm, result *interface{}) error

QueryTransaction query transaction

func (*Chain33) ReWriteRawTx 

func (c *Chain33) ReWriteRawTx(in *rpctypes.ReWriteRawTx, result *interface{}) error

ReWriteRawTx re-write raw tx by jrpc

func (*Chain33) SaveSeed 

func (c *Chain33) SaveSeed(in *types.SaveSeedByPw, result *interface{}) error

SaveSeed save seed

func (*Chain33) SendDelayTransaction added in v1.65.3 

func (c *Chain33) SendDelayTransaction(in *types.ReqString, result *interface{}) error

SendDelayTransaction send delay tx

func (*Chain33) SendToAddress 

func (c *Chain33) SendToAddress(in *types.ReqWalletSendToAddress, result *interface{}) error

SendToAddress send to address of coins

func (*Chain33) SendTransaction 

func (c *Chain33) SendTransaction(in rpctypes.RawParm, result *interface{}) error

SendTransaction send transaction

func (*Chain33) SendTransactionSync added in v1.65.1 

func (c *Chain33) SendTransactionSync(in rpctypes.RawParm, result *interface{}) error

SendTransactionSync send transaction and wait reply

func (*Chain33) SendTransactions added in v1.65.3 

func (c *Chain33) SendTransactions(in rpctypes.ReqStrings, result *interface{}) error

SendTransactions send tx batch

func (*Chain33) SetLabl 

func (c *Chain33) SetLabl(in *types.ReqWalletSetLabel, result *interface{}) error

SetLabl set lable

func (*Chain33) SetPasswd 

func (c *Chain33) SetPasswd(in *types.ReqWalletSetPasswd, result *interface{}) error

SetPasswd set password

func (*Chain33) SetTxFee 

func (c *Chain33) SetTxFee(in *types.ReqWalletSetFee, result *interface{}) error

SetTxFee set tx fee

func (*Chain33) ShowBlacklist added in v1.65.3 

func (c *Chain33) ShowBlacklist(in *types.ReqNil, result *interface{}) error

ShowBlacklist show all peers from blacklist

func (*Chain33) SignRawTx 

func (c *Chain33) SignRawTx(in *types.ReqSignRawTx, result *interface{}) error

SignRawTx signature the rawtransaction

func (*Chain33) SignWalletRecoverTx added in v1.65.3 

func (c *Chain33) SignWalletRecoverTx(req *types.ReqSignWalletRecoverTx, result *interface{}) error

SignWalletRecoverTx sign wallet recover transaction

func (*Chain33) UnLock 

func (c *Chain33) UnLock(in *types.WalletUnLock, result *interface{}) error

UnLock wallet unlock

func (*Chain33) Version 

func (c *Chain33) Version(in *types.ReqNil, result *interface{}) error

Version get software version

func (*Chain33) WalletTxList 

func (c *Chain33) WalletTxList(in rpctypes.ReqWalletTransactionList, result *interface{}) error

WalletTxList transaction list of wallet

type Grpc 

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

Grpc a channelClient

func (*Grpc) AddPushSubscribe added in v1.66.1 

func (g *Grpc) AddPushSubscribe(ctx context.Context, in *pb.PushSubscribeReq) (*pb.ReplySubscribePush, error)

AddPushSubscribe ...

func (*Grpc) CloseQueue 

func (g *Grpc) CloseQueue(ctx context.Context, in *pb.ReqNil) (*pb.Reply, error)

CloseQueue close queue

func (*Grpc) ConvertExectoAddr added in v1.66.1 

func (g *Grpc) ConvertExectoAddr(ctx context.Context, in *pb.ReqString) (*pb.ReplyString, error)

ConvertExectoAddr 根据执行器的名字创建地址

func (*Grpc) CreateNoBalanceTransaction 

func (g *Grpc) CreateNoBalanceTransaction(ctx context.Context, in *pb.NoBalanceTx) (*pb.ReplySignRawTx, error)

CreateNoBalanceTransaction create transaction with no balance

func (*Grpc) CreateNoBalanceTxs 

func (g *Grpc) CreateNoBalanceTxs(ctx context.Context, in *pb.NoBalanceTxs) (*pb.ReplySignRawTx, error)

CreateNoBalanceTxs create multiple transaction with no balance

func (*Grpc) CreateRawTransaction 

func (g *Grpc) CreateRawTransaction(ctx context.Context, in *pb.CreateTx) (*pb.UnsignTx, error)

CreateRawTransaction create rawtransaction of grpc

func (*Grpc) CreateRawTxGroup 

func (g *Grpc) CreateRawTxGroup(ctx context.Context, in *pb.CreateTransactionGroup) (*pb.UnsignTx, error)

CreateRawTxGroup create rawtransaction for group

func (*Grpc) CreateTransaction 

func (g *Grpc) CreateTransaction(ctx context.Context, in *pb.CreateTxIn) (*pb.UnsignTx, error)

CreateTransaction create transaction of grpc

func (*Grpc) DumpPrivkey 

func (g *Grpc) DumpPrivkey(ctx context.Context, in *pb.ReqString) (*pb.ReplyString, error)

DumpPrivkey dump Privkey

func (*Grpc) DumpPrivkeysFile 

func (g *Grpc) DumpPrivkeysFile(ctx context.Context, in *pb.ReqPrivkeysFile) (*pb.Reply, error)

DumpPrivkeysFile dumps private key to file.

func (*Grpc) ExecWallet 

func (g *Grpc) ExecWallet(ctx context.Context, in *pb.ChainExecutor) (*pb.Reply, error)

ExecWallet exec wallet

func (*Grpc) GenSeed 

func (g *Grpc) GenSeed(ctx context.Context, in *pb.GenSeedLang) (*pb.ReplySeed, error)

GenSeed seed

func (*Grpc) GetAccount added in v1.65.0 

func (g *Grpc) GetAccount(ctx context.Context, in *pb.ReqGetAccount) (*pb.WalletAccount, error)

GetAccount 通过地址标签获取账户地址以及账户余额信息

func (*Grpc) GetAccounts 

func (g *Grpc) GetAccounts(ctx context.Context, in *pb.ReqNil) (*pb.WalletAccounts, error)

GetAccounts get accounts

func (*Grpc) GetAddrOverview 

func (g *Grpc) GetAddrOverview(ctx context.Context, in *pb.ReqAddr) (*pb.AddrOverview, error)

GetAddrOverview get address overview

func (*Grpc) GetAddressDrivers added in v1.67.1 

func (g *Grpc) GetAddressDrivers(ctx context.Context, in *pb.ReqNil) (*pb.AddressDrivers, error)

GetAddressDrivers 获取已注册地址插件

func (*Grpc) GetAllExecBalance 

func (g *Grpc) GetAllExecBalance(ctx context.Context, in *pb.ReqAllExecBalance) (*pb.AllExecBalance, error)

GetAllExecBalance get balance of exec

func (*Grpc) GetBalance 

func (g *Grpc) GetBalance(ctx context.Context, in *pb.ReqBalance) (*pb.Accounts, error)

GetBalance get balance

func (*Grpc) GetBlockByHashes 

func (g *Grpc) GetBlockByHashes(ctx context.Context, in *pb.ReqHashes) (*pb.BlockDetails, error)

GetBlockByHashes get block by hashes

func (*Grpc) GetBlockBySeq 

func (g *Grpc) GetBlockBySeq(ctx context.Context, in *pb.Int64) (*pb.BlockSeq, error)

GetBlockBySeq get block with hash by seq

func (*Grpc) GetBlockHash 

func (g *Grpc) GetBlockHash(ctx context.Context, in *pb.ReqInt) (*pb.ReplyHash, error)

GetBlockHash get block hash

func (*Grpc) GetBlockOverview 

func (g *Grpc) GetBlockOverview(ctx context.Context, in *pb.ReqHash) (*pb.BlockOverview, error)

GetBlockOverview get block overview GetBlockOverview(parm *types.ReqHash) (*types.BlockOverview, error) //add by hyb

func (*Grpc) GetBlockSequences added in v1.66.1 

func (g *Grpc) GetBlockSequences(ctx context.Context, in *pb.ReqBlocks) (*pb.BlockSequences, error)

GetBlockSequences ...

func (*Grpc) GetBlocks 

func (g *Grpc) GetBlocks(ctx context.Context, in *pb.ReqBlocks) (*pb.Reply, error)

GetBlocks get blocks by grpc

func (*Grpc) GetChainConfig added in v1.65.3 

func (g *Grpc) GetChainConfig(ctx context.Context, in *pb.ReqNil) (*pb.ChainConfigInfo, error)

GetChainConfig 获取chain config 参数

func (*Grpc) GetCoinSymbol added in v1.66.1 

func (g *Grpc) GetCoinSymbol(ctx context.Context, in *pb.ReqNil) (*pb.ReplyString, error)

GetCoinSymbol get coin symbol

func (*Grpc) GetCryptoList added in v1.65.3 

func (g *Grpc) GetCryptoList(ctx context.Context, in *pb.ReqNil) (*pb.CryptoList, error)

GetCryptoList 获取加密算法列表

func (*Grpc) GetFatalFailure 

func (g *Grpc) GetFatalFailure(ctx context.Context, in *pb.ReqNil) (*pb.Int32, error)

GetFatalFailure return fatal of failure

func (*Grpc) GetFork 

func (g *Grpc) GetFork(ctx context.Context, in *pb.ReqKey) (*pb.Int64, error)

GetFork get fork height by fork key

func (*Grpc) GetHeaders 

func (g *Grpc) GetHeaders(ctx context.Context, in *pb.ReqBlocks) (*pb.Headers, error)

GetHeaders return headers

func (*Grpc) GetHexTxByHash 

func (g *Grpc) GetHexTxByHash(ctx context.Context, in *pb.ReqHash) (*pb.HexTx, error)

GetHexTxByHash get hex transaction by hash

func (*Grpc) GetLastBlockSequence 

func (g *Grpc) GetLastBlockSequence(ctx context.Context, in *pb.ReqNil) (*pb.Int64, error)

GetLastBlockSequence get last block sequence

func (*Grpc) GetLastHeader 

func (g *Grpc) GetLastHeader(ctx context.Context, in *pb.ReqNil) (*pb.Header, error)

GetLastHeader get lastheader information

func (*Grpc) GetLastMemPool 

func (g *Grpc) GetLastMemPool(ctx context.Context, in *pb.ReqNil) (*pb.ReplyTxList, error)

GetLastMemPool return last mempool contents

func (*Grpc) GetMemPool 

func (g *Grpc) GetMemPool(ctx context.Context, in *pb.ReqGetMempool) (*pb.ReplyTxList, error)

GetMemPool get mempool contents

func (*Grpc) GetParaTxByHeight 

func (g *Grpc) GetParaTxByHeight(ctx context.Context, in *pb.ReqParaTxByHeight) (*pb.ParaTxDetails, error)

GetParaTxByHeight //通过区块高度列表+title获取平行链交易

func (*Grpc) GetParaTxByTitle 

func (g *Grpc) GetParaTxByTitle(ctx context.Context, in *pb.ReqParaTxByTitle) (*pb.ParaTxDetails, error)

GetParaTxByTitle 通过seq以及title获取对应平行连的交易

func (*Grpc) GetPeerInfo 

func (g *Grpc) GetPeerInfo(ctx context.Context, req *pb.P2PGetPeerReq) (*pb.PeerList, error)

GetPeerInfo get peer information

func (*Grpc) GetProperFee 

func (g *Grpc) GetProperFee(ctx context.Context, in *pb.ReqProperFee) (*pb.ReplyProperFee, error)

GetProperFee return last mempool proper fee

func (*Grpc) GetPushSeqLastNum added in v1.66.1 

func (g *Grpc) GetPushSeqLastNum(ctx context.Context, in *pb.ReqString) (*pb.Int64, error)

GetPushSeqLastNum Get Seq Call Back Last Num

func (*Grpc) GetSeed 

func (g *Grpc) GetSeed(ctx context.Context, in *pb.GetSeedByPw) (*pb.ReplySeed, error)

GetSeed get seed

func (*Grpc) GetSequenceByHash 

func (g *Grpc) GetSequenceByHash(ctx context.Context, in *pb.ReqHash) (*pb.Int64, error)

GetSequenceByHash get block sequece by hash

func (*Grpc) GetServerTime added in v1.65.1 

func (g *Grpc) GetServerTime(ctx context.Context, in *pb.ReqNil) (*pb.ServerTime, error)

GetServerTime get server time

func (*Grpc) GetTransactionByAddr 

func (g *Grpc) GetTransactionByAddr(ctx context.Context, in *pb.ReqAddr) (*pb.ReplyTxInfos, error)

GetTransactionByAddr get transaction by address

func (*Grpc) GetTransactionByHashes 

func (g *Grpc) GetTransactionByHashes(ctx context.Context, in *pb.ReqHashes) (*pb.TransactionDetails, error)

GetTransactionByHashes get transaction by hashes

func (*Grpc) GetWalletRecoverAddress added in v1.65.3 

func (g *Grpc) GetWalletRecoverAddress(ctx context.Context, in *pb.ReqGetWalletRecoverAddr) (*pb.ReplyString, error)

GetWalletRecoverAddress get recover addr

func (*Grpc) GetWalletStatus 

func (g *Grpc) GetWalletStatus(ctx context.Context, in *pb.ReqNil) (*pb.WalletStatus, error)

GetWalletStatus get wallet status

func (*Grpc) ImportPrivkey 

func (g *Grpc) ImportPrivkey(ctx context.Context, in *pb.ReqWalletImportPrivkey) (*pb.WalletAccount, error)

ImportPrivkey import privkey

func (*Grpc) ImportPrivkeysFile 

func (g *Grpc) ImportPrivkeysFile(ctx context.Context, in *pb.ReqPrivkeysFile) (*pb.Reply, error)

ImportPrivkeysFile imports private key from file.

func (*Grpc) IsNtpClockSync 

func (g *Grpc) IsNtpClockSync(ctx context.Context, in *pb.ReqNil) (*pb.Reply, error)

IsNtpClockSync is ntp clock sync

func (*Grpc) IsSync 

func (g *Grpc) IsSync(ctx context.Context, in *pb.ReqNil) (*pb.Reply, error)

IsSync is the sync

func (*Grpc) ListPushes added in v1.66.1 

func (g *Grpc) ListPushes(ctx context.Context, in *pb.ReqNil) (*pb.PushSubscribes, error)

ListPushes 列举推送服务

func (*Grpc) LoadParaTxByTitle 

func (g *Grpc) LoadParaTxByTitle(ctx context.Context, in *pb.ReqHeightByTitle) (*pb.ReplyHeightByTitle, error)

LoadParaTxByTitle //获取拥有此title交易的区块高度

func (*Grpc) Lock 

func (g *Grpc) Lock(ctx context.Context, in *pb.ReqNil) (*pb.Reply, error)

Lock wallet lock

func (*Grpc) MergeBalance 

func (g *Grpc) MergeBalance(ctx context.Context, in *pb.ReqWalletMergeBalance) (*pb.ReplyHashes, error)

MergeBalance merge balance of wallet

func (*Grpc) NetInfo 

func (g *Grpc) NetInfo(ctx context.Context, in *pb.P2PGetNetInfoReq) (*pb.NodeNetInfo, error)

NetInfo net information

func (*Grpc) NewAccount 

func (g *Grpc) NewAccount(ctx context.Context, in *pb.ReqNewAccount) (*pb.WalletAccount, error)

NewAccount produce new account

func (*Grpc) QueryChain 

func (g *Grpc) QueryChain(ctx context.Context, in *pb.ChainExecutor) (*pb.Reply, error)

QueryChain query chain

func (*Grpc) QueryConsensus 

func (g *Grpc) QueryConsensus(ctx context.Context, in *pb.ChainExecutor) (*pb.Reply, error)

QueryConsensus query consensus

func (*Grpc) QueryRandNum 

func (g *Grpc) QueryRandNum(ctx context.Context, in *pb.ReqRandHash) (*pb.ReplyHash, error)

QueryRandNum query randHash from ticket

func (*Grpc) QueryTransaction 

func (g *Grpc) QueryTransaction(ctx context.Context, in *pb.ReqHash) (*pb.TransactionDetail, error)

QueryTransaction query transaction by grpc

func (*Grpc) ReWriteTx added in v1.66.1 

func (g *Grpc) ReWriteTx(ctx context.Context, in *pb.ReWriteRawTx) (*pb.UnsignTx, error)

ReWriteTx re-write raw tx parameters of grpc

func (*Grpc) SaveSeed 

func (g *Grpc) SaveSeed(ctx context.Context, in *pb.SaveSeedByPw) (*pb.Reply, error)

SaveSeed save seed

func (*Grpc) SendDelayTransaction added in v1.65.3 

func (g *Grpc) SendDelayTransaction(ctx context.Context, in *pb.DelayTx) (*pb.Reply, error)

SendDelayTransaction send delay tx

func (*Grpc) SendToAddress 

func (g *Grpc) SendToAddress(ctx context.Context, in *pb.ReqWalletSendToAddress) (*pb.ReplyHash, error)

SendToAddress send to address of coins

func (*Grpc) SendTransaction 

func (g *Grpc) SendTransaction(ctx context.Context, in *pb.Transaction) (*pb.Reply, error)

SendTransaction send transaction by network

func (*Grpc) SendTransactionSync added in v1.65.1 

func (g *Grpc) SendTransactionSync(ctx context.Context, in *pb.Transaction) (*pb.Reply, error)

SendTransactionSync send transaction by network and query

func (*Grpc) SendTransactions added in v1.65.3 

func (g *Grpc) SendTransactions(ctx context.Context, in *pb.Transactions) (*pb.Replies, error)

SendTransactions send transaction by network

func (*Grpc) SetLabl 

func (g *Grpc) SetLabl(ctx context.Context, in *pb.ReqWalletSetLabel) (*pb.WalletAccount, error)

SetLabl set labl

func (*Grpc) SetPasswd 

func (g *Grpc) SetPasswd(ctx context.Context, in *pb.ReqWalletSetPasswd) (*pb.Reply, error)

SetPasswd set password

func (*Grpc) SetTxFee 

func (g *Grpc) SetTxFee(ctx context.Context, in *pb.ReqWalletSetFee) (*pb.Reply, error)

SetTxFee set tx fee

func (*Grpc) SignRawTx 

func (g *Grpc) SignRawTx(ctx context.Context, in *pb.ReqSignRawTx) (*pb.ReplySignRawTx, error)

SignRawTx signature rawtransaction

func (*Grpc) SignWalletRecoverTx added in v1.65.3 

func (g *Grpc) SignWalletRecoverTx(ctx context.Context, in *pb.ReqSignWalletRecoverTx) (*pb.ReplySignRawTx, error)

SignWalletRecoverTx sign wallet recover tx

func (*Grpc) SubEvent added in v1.66.1 

func (g *Grpc) SubEvent(in *pb.ReqSubscribe, resp pb.Chain33_SubEventServer) error

SubEvent 订阅消息推送服务

func (*Grpc) UnLock 

func (g *Grpc) UnLock(ctx context.Context, in *pb.WalletUnLock) (*pb.Reply, error)

UnLock wallet unlock

func (*Grpc) Version 

func (g *Grpc) Version(ctx context.Context, in *pb.ReqNil) (*pb.VersionInfo, error)

Version version

func (*Grpc) WalletTransactionList 

func (g *Grpc) WalletTransactionList(ctx context.Context, in *pb.ReqWalletTransactionList) (*pb.WalletTxDetails, error)

WalletTransactionList transaction list of wallet

type Grpcserver 

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

Grpcserver a object

func NewGRpcServer 

func NewGRpcServer(c queue.Client, api client.QueueProtocolAPI) *Grpcserver

NewGRpcServer new grpcserver object

func NewGrpcServer 

func NewGrpcServer() *Grpcserver

NewGrpcServer new GrpcServer object

func (*Grpcserver) Close 

func (j *Grpcserver) Close()

Close grpcserver close

func (*Grpcserver) Listen 

func (g *Grpcserver) Listen() (int, error)

Listen grpcserver listen

type HTTPConn 

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

HTTPConn adapt HTTP connection to ReadWriteCloser

func (*HTTPConn) Close 

func (c *HTTPConn) Close() error

Close rewrite the close of http

func (*HTTPConn) Read 

func (c *HTTPConn) Read(p []byte) (n int, err error)

Read rewrite the read of http

func (*HTTPConn) Write 

func (c *HTTPConn) Write(d []byte) (n int, err error)

Write rewrite the write of http

type JSONRPCServer 

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

JSONRPCServer a json rpcserver object

func NewJSONRPCServer 

func NewJSONRPCServer(c queue.Client, api client.QueueProtocolAPI) *JSONRPCServer

NewJSONRPCServer new json rpcserver object

func (*JSONRPCServer) Close 

func (s *JSONRPCServer) Close()

Close json rpcserver close

func (*JSONRPCServer) Listen 

func (j *JSONRPCServer) Listen() (int, error)

Listen jsonsever listen

type PushType added in v1.66.1 

type PushType int32

PushType ...

type RPC 

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

RPC a type object

func New 

func New(cfg *types.Chain33Config) *RPC

New produce a rpc by cfg

func (*RPC) Close 

func (r *RPC) Close()

Close rpc close

func (*RPC) GRPC 

func (r *RPC) GRPC() *grpc.Server

GRPC return grpc rpc

func (*RPC) GetQueueClient 

func (r *RPC) GetQueueClient() queue.Client

GetQueueClient get queue client

func (*RPC) JRPC 

func (r *RPC) JRPC() *rpc.Server

JRPC return jrpc

func (*RPC) Listen 

func (r *RPC) Listen() (port1 int, port2 int)

Listen rpc listen

func (*RPC) SetAPI 

func (r *RPC) SetAPI(api client.QueueProtocolAPI)

SetAPI set api of rpc

func (*RPC) SetQueueClient 

func (r *RPC) SetQueueClient(c queue.Client)

SetQueueClient set queue client

func (*RPC) SetQueueClientNoListen 

func (r *RPC) SetQueueClientNoListen(c queue.Client)

SetQueueClientNoListen set queue client with no listen

Source Files

View all Source files

Directories

Path Synopsis
Package jsonclient 实现JSON rpc客户端请求功能
 Package jsonclient 实现JSON rpc客户端请求功能
Package types rpc相关的一些结构体定义以及转化函数
 Package types rpc相关的一些结构体定义以及转化函数

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.