rpc

package
v0.0.0-...-d5522c5 Latest Latest
Warning

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

Go to latest
Published: Jun 8, 2021 License: Apache-2.0 Imports: 37 Imported by: 0

README

Adapter RPC

适配旧版本rpc接口,保持旧版本接口和pb兼容。

需要兼容接口(30个)

EndorserCall

PostTx QueryTx

PreExec PreExecWithSelectUTXO DeployNativeCode NativeCodeStatus

SelectUTXO SelectUTXOBySize QueryUtxoRecord GetBalance GetBalanceDetail GetFrozenBalance

QueryACL QueryContractStatData GetAccountContracts

GetBlock GetBlockByHeight

GetBlockChainStatus GetBlockChains GetSystemStatus GetNetURL GetAccountByAK

DposCandidates DposNominateRecords DposNomineeRecords DposVoteRecords DposVotedRecords DposCheckResults DposStatus

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RpcServ

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

func NewRpcServ

func NewRpcServ(engine ecom.Engine, log logs.Logger) *RpcServ

func (*RpcServ) ConfirmBlockChainStatus

func (t *RpcServ) ConfirmBlockChainStatus(gctx context.Context, req *pb.BCStatus) (*pb.BCTipStatus, error)

ConfirmBlockChainStatus confirm is_trunk

func (*RpcServ) DposCandidates

func (t *RpcServ) DposCandidates(gctx context.Context, req *pb.DposCandidatesRequest) (*pb.DposCandidatesResponse, error)

DposCandidates get all candidates of the tdpos consensus

func (*RpcServ) DposCheckResults

func (t *RpcServ) DposCheckResults(gctx context.Context, req *pb.DposCheckResultsRequest) (*pb.DposCheckResultsResponse, error)

DposCheckResults get check results of a specific term

func (*RpcServ) DposNominateRecords

DposNominateRecords get all records nominated by an user

func (*RpcServ) DposNomineeRecords

func (t *RpcServ) DposNomineeRecords(gctx context.Context, req *pb.DposNomineeRecordsRequest) (*pb.DposNomineeRecordsResponse, error)

DposNomineeRecords get nominated record of a candidate

func (*RpcServ) DposStatus

func (t *RpcServ) DposStatus(gctx context.Context, req *pb.DposStatusRequest) (*pb.DposStatusResponse, error)

DposStatus get dpos status

func (*RpcServ) DposVoteRecords

func (t *RpcServ) DposVoteRecords(gctx context.Context, req *pb.DposVoteRecordsRequest) (*pb.DposVoteRecordsResponse, error)

DposVoteRecords get all vote records voted by an user

func (*RpcServ) DposVotedRecords

func (t *RpcServ) DposVotedRecords(gctx context.Context, req *pb.DposVotedRecordsRequest) (*pb.DposVotedRecordsResponse, error)

DposVotedRecords get all vote records of a candidate

func (*RpcServ) GetAccountByAK

func (t *RpcServ) GetAccountByAK(gctx context.Context, req *pb.AK2AccountRequest) (*pb.AK2AccountResponse, error)

GetAccountByAK get account list with contain ak

func (*RpcServ) GetAccountContracts

GetAccountContracts get account request

func (*RpcServ) GetAddressContracts

func (t *RpcServ) GetAddressContracts(gctx context.Context, req *pb.AddressContractsRequest) (*pb.AddressContractsResponse, error)

GetAddressContracts get contracts of accounts contain a specific address

func (*RpcServ) GetBalance

func (t *RpcServ) GetBalance(gctx context.Context, req *pb.AddressStatus) (*pb.AddressStatus, error)

GetBalance get balance for account or addr

func (*RpcServ) GetBalanceDetail

func (t *RpcServ) GetBalanceDetail(gctx context.Context, req *pb.AddressBalanceStatus) (*pb.AddressBalanceStatus, error)

GetBalanceDetail get balance frozened for account or addr

func (*RpcServ) GetBlock

func (t *RpcServ) GetBlock(gctx context.Context, req *pb.BlockID) (*pb.Block, error)

GetBlock get block info according to blockID

func (*RpcServ) GetBlockByHeight

func (t *RpcServ) GetBlockByHeight(gctx context.Context, req *pb.BlockHeight) (*pb.Block, error)

GetBlockByHeight get trunk block by height

func (*RpcServ) GetBlockChainStatus

func (t *RpcServ) GetBlockChainStatus(gctx context.Context, req *pb.BCStatus) (*pb.BCStatus, error)

GetBlockChainStatus get systemstatus

func (*RpcServ) GetBlockChains

func (t *RpcServ) GetBlockChains(gctx context.Context, req *pb.CommonIn) (*pb.BlockChains, error)

GetBlockChains get BlockChains

func (*RpcServ) GetConsensusStatus

func (t *RpcServ) GetConsensusStatus(gctx context.Context, req *pb.ConsensusStatRequest) (*pb.ConsensusStatus, error)

func (*RpcServ) GetFrozenBalance

func (t *RpcServ) GetFrozenBalance(gctx context.Context, req *pb.AddressStatus) (*pb.AddressStatus, error)

GetFrozenBalance get balance frozened for account or addr

func (*RpcServ) GetNetURL

func (t *RpcServ) GetNetURL(gctx context.Context, req *pb.CommonIn) (*pb.RawUrl, error)

GetNetURL get net url in p2p_base

func (*RpcServ) GetSystemStatus

func (t *RpcServ) GetSystemStatus(gctx context.Context, req *pb.CommonIn) (*pb.SystemsStatusReply, error)

GetSystemStatus get systemstatus

func (*RpcServ) PostTx

func (t *RpcServ) PostTx(gctx context.Context, req *pb.TxStatus) (*pb.CommonReply, error)

PostTx post transaction to blockchain network

func (*RpcServ) PreExec

func (t *RpcServ) PreExec(gctx context.Context, req *pb.InvokeRPCRequest) (*pb.InvokeRPCResponse, error)

PreExec smart contract preExec process

func (*RpcServ) PreExecWithSelectUTXO

PreExecWithSelectUTXO preExec + selectUtxo

func (*RpcServ) QueryACL

func (t *RpcServ) QueryACL(gctx context.Context, req *pb.AclStatus) (*pb.AclStatus, error)

QueryACL query some account info

func (*RpcServ) QueryContractStatData

func (t *RpcServ) QueryContractStatData(gctx context.Context,
	req *pb.ContractStatDataRequest) (*pb.ContractStatDataResponse, error)

QueryContractStatData query statistic info about contract

func (*RpcServ) QueryTx

func (t *RpcServ) QueryTx(gctx context.Context, req *pb.TxStatus) (*pb.TxStatus, error)

QueryTx Get transaction details

func (*RpcServ) QueryUtxoRecord

func (t *RpcServ) QueryUtxoRecord(gctx context.Context,
	req *pb.UtxoRecordDetail) (*pb.UtxoRecordDetail, error)

QueryUtxoRecord query utxo records

func (*RpcServ) SelectUTXO

func (t *RpcServ) SelectUTXO(gctx context.Context, req *pb.UtxoInput) (*pb.UtxoOutput, error)

SelectUTXO select utxo inputs depending on amount

func (*RpcServ) SelectUTXOBySize

func (t *RpcServ) SelectUTXOBySize(gctx context.Context, req *pb.UtxoInput) (*pb.UtxoOutput, error)

SelectUTXOBySize select utxo inputs depending on size

func (*RpcServ) UnaryInterceptor

func (t *RpcServ) UnaryInterceptor() grpc.UnaryServerInterceptor

UnaryInterceptor provides a hook to intercept the execution of a unary RPC on the server.

type RpcServMG

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

rpc server启停控制管理

func NewRpcServMG

func NewRpcServMG(scfg *sconf.ServConf, engine engines.BCEngine) (*RpcServMG, error)

func (*RpcServMG) Exit

func (t *RpcServMG) Exit()

退出rpc服务,释放相关资源,需要幂等

func (*RpcServMG) Run

func (t *RpcServMG) Run() error

启动rpc服务,阻塞运行

Jump to

Keyboard shortcuts

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