rpc

package

Go to main page

Versions in this module

v1

v1.68.2

Apr 12, 2024

v1.68.1

Sep 12, 2023

v1.68.0

Feb 17, 2023

Changes in this version

type Grpc

+ func (g *Grpc) UnSubEvent(ctx context.Context, in *pb.ReqString) (*pb.Reply, error)

v1.67.5

Dec 15, 2022

v1.67.4

Oct 11, 2022

v1.67.3

May 27, 2022

v1.67.2

Apr 18, 2022

v1.67.1

Mar 28, 2022

Changes in this version

type Chain33

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

type Grpc

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

v1.67.0

Dec 27, 2021

v1.66.5

Feb 18, 2022

v1.66.4

Jan 19, 2022

v1.66.3

Jan 14, 2022

v1.66.2

Jan 10, 2022

v1.66.1

Dec 28, 2021

Changes in this version

type Grpc

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

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

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

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

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

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

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

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

+ type PushType int32

v1.66.0

Oct 15, 2021

v1.65.5

Oct 19, 2021

v1.65.4

Oct 15, 2021

v1.65.3

Oct 15, 2021

Changes in this version

type Chain33

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type Grpc

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

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

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

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

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

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

v1.65.2

Mar 25, 2021

v1.65.1

Mar 25, 2021

Changes in this version

type Chain33

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

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

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

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

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

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

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

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

type Grpc

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

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

v1.65.0

Sep 25, 2020

Changes in this version

type Chain33

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

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

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

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

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

type Grpc

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

v1.64.0

May 25, 2020

Changes in this version

+ func InitCfg(cfg *types.RPC)

+ func InitFilterPrintFuncBlacklist()

+ func InitGrpcFuncBlacklist(cfg *types.RPC)

+ func InitGrpcFuncWhitelist(cfg *types.RPC)

+ func InitIPWhitelist(cfg *types.RPC)

+ func InitJrpcFuncBlacklist(cfg *types.RPC)

+ func InitJrpcFuncWhitelist(cfg *types.RPC)

+ type Chain33 struct

+ func (c *Chain33) AddSeqCallBack(in *types.BlockSeqCB, result *interface{}) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type Grpc struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type Grpcserver struct

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

+ func NewGrpcServer() *Grpcserver

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

+ func (j *Grpcserver) Close()

+ type HTTPConn struct

+ func (c *HTTPConn) Close() error

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

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

+ type JSONRPCServer struct

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

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

+ func (s *JSONRPCServer) Close()

+ type RPC struct

+ func New(cfg *types.Chain33Config) *RPC

+ func (r *RPC) Close()

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

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

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

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

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

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

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

Incompatible versions in this module

v6.1.0+incompatible

Jan 28, 2019

Other modules containing this package

github.com/33cn/chain33/v6

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL