Documentation ¶
Index ¶
- type AergoRPCService
- func (rpc *AergoRPCService) Blockchain(ctx context.Context, in *types.Empty) (*types.BlockchainStatus, error)
- func (rpc *AergoRPCService) BroadcastToListBlockMetadataStream(meta *types.BlockMetadata) error
- func (rpc *AergoRPCService) BroadcastToListBlockStream(block *types.Block) error
- func (rpc *AergoRPCService) CommitTX(ctx context.Context, in *types.TxList) (*types.CommitResultList, error)
- func (rpc *AergoRPCService) CreateAccount(ctx context.Context, in *types.Personal) (*types.Account, error)
- func (rpc *AergoRPCService) ExportAccount(ctx context.Context, in *types.Personal) (*types.SingleBytes, error)
- func (rpc *AergoRPCService) GetABI(ctx context.Context, in *types.SingleBytes) (*types.ABI, error)
- func (rpc *AergoRPCService) GetAccounts(ctx context.Context, in *types.Empty) (*types.AccountList, error)
- func (rpc *AergoRPCService) GetBlock(ctx context.Context, in *types.SingleBytes) (*types.Block, error)
- func (rpc *AergoRPCService) GetBlockBody(ctx context.Context, in *types.BlockBodyParams) (*types.BlockBodyPaged, error)
- func (rpc *AergoRPCService) GetBlockMetadata(ctx context.Context, in *types.SingleBytes) (*types.BlockMetadata, error)
- func (rpc *AergoRPCService) GetBlockTX(ctx context.Context, in *types.SingleBytes) (*types.TxInBlock, error)
- func (rpc *AergoRPCService) GetChainInfo(ctx context.Context, in *types.Empty) (*types.ChainInfo, error)
- func (rpc *AergoRPCService) GetNameInfo(ctx context.Context, in *types.Name) (*types.NameInfo, error)
- func (rpc *AergoRPCService) GetPeers(ctx context.Context, in *types.Empty) (*types.PeerList, error)
- func (rpc *AergoRPCService) GetReceipt(ctx context.Context, in *types.SingleBytes) (*types.Receipt, error)
- func (rpc *AergoRPCService) GetStaking(ctx context.Context, in *types.SingleBytes) (*types.Staking, error)
- func (rpc *AergoRPCService) GetState(ctx context.Context, in *types.SingleBytes) (*types.State, error)
- func (rpc *AergoRPCService) GetStateAndProof(ctx context.Context, in *types.AccountAndRoot) (*types.AccountProof, error)
- func (rpc *AergoRPCService) GetTX(ctx context.Context, in *types.SingleBytes) (*types.Tx, error)
- func (rpc *AergoRPCService) GetVotes(ctx context.Context, in *types.SingleBytes) (*types.VoteList, error)
- func (rpc *AergoRPCService) ImportAccount(ctx context.Context, in *types.ImportFormat) (*types.Account, error)
- func (rpc *AergoRPCService) ListBlockHeaders(ctx context.Context, in *types.ListParams) (*types.BlockHeaderList, error)
- func (rpc *AergoRPCService) ListBlockMetadata(ctx context.Context, in *types.ListParams) (*types.BlockMetadataList, error)
- func (rpc *AergoRPCService) ListBlockMetadataStream(in *types.Empty, stream types.AergoRPCService_ListBlockMetadataStreamServer) error
- func (rpc *AergoRPCService) ListBlockStream(in *types.Empty, stream types.AergoRPCService_ListBlockStreamServer) error
- func (rpc *AergoRPCService) LockAccount(ctx context.Context, in *types.Personal) (*types.Account, error)
- func (rpc *AergoRPCService) Metric(ctx context.Context, req *types.MetricsRequest) (*types.Metrics, error)
- func (rpc *AergoRPCService) NodeState(ctx context.Context, in *types.NodeReq) (*types.SingleBytes, error)
- func (rpc *AergoRPCService) QueryContract(ctx context.Context, in *types.Query) (*types.SingleBytes, error)
- func (rpc *AergoRPCService) QueryContractState(ctx context.Context, in *types.StateQuery) (*types.StateQueryProof, error)
- func (rpc *AergoRPCService) SendTX(ctx context.Context, tx *types.Tx) (*types.CommitResult, error)
- func (rpc *AergoRPCService) SignTX(ctx context.Context, in *types.Tx) (*types.Tx, error)
- func (rpc *AergoRPCService) UnlockAccount(ctx context.Context, in *types.Personal) (*types.Account, error)
- func (rpc *AergoRPCService) VerifyTX(ctx context.Context, in *types.Tx) (*types.VerifyResult, error)
- type RPC
- func (ns *RPC) AfterStart()
- func (ns *RPC) BeforeStart()
- func (ns *RPC) BeforeStop()
- func (ns *RPC) CallRequest(actor string, msg interface{}, timeout time.Duration) (interface{}, error)
- func (ns *RPC) CallRequestDefaultTimeout(actor string, msg interface{}) (interface{}, error)
- func (ns *RPC) FutureRequest(actor string, msg interface{}, timeout time.Duration) *actor.Future
- func (ns *RPC) FutureRequestDefaultTimeout(actor string, msg interface{}) *actor.Future
- func (ns *RPC) GetChainAccessor() types.ChainAccessor
- func (ns *RPC) Receive(context actor.Context)
- func (ns *RPC) SendRequest(actor string, msg interface{})
- func (ns *RPC) SetHub(hub *component.ComponentHub)
- func (ns *RPC) Statistics() *map[string]interface{}
- func (ns *RPC) TellRequest(actor string, msg interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AergoRPCService ¶
type AergoRPCService struct {
// contains filtered or unexported fields
}
AergoRPCService implements GRPC server which is defined in rpc.proto
func (*AergoRPCService) Blockchain ¶
func (rpc *AergoRPCService) Blockchain(ctx context.Context, in *types.Empty) (*types.BlockchainStatus, error)
Blockchain handle rpc request blockchain. It has no additional input parameter
func (*AergoRPCService) BroadcastToListBlockMetadataStream ¶ added in v0.9.0
func (rpc *AergoRPCService) BroadcastToListBlockMetadataStream(meta *types.BlockMetadata) error
func (*AergoRPCService) BroadcastToListBlockStream ¶
func (rpc *AergoRPCService) BroadcastToListBlockStream(block *types.Block) error
func (*AergoRPCService) CommitTX ¶
func (rpc *AergoRPCService) CommitTX(ctx context.Context, in *types.TxList) (*types.CommitResultList, error)
CommitTX handle rpc request commit
func (*AergoRPCService) CreateAccount ¶
func (rpc *AergoRPCService) CreateAccount(ctx context.Context, in *types.Personal) (*types.Account, error)
CreateAccount handle rpc request newaccount
func (*AergoRPCService) ExportAccount ¶
func (rpc *AergoRPCService) ExportAccount(ctx context.Context, in *types.Personal) (*types.SingleBytes, error)
func (*AergoRPCService) GetABI ¶
func (rpc *AergoRPCService) GetABI(ctx context.Context, in *types.SingleBytes) (*types.ABI, error)
func (*AergoRPCService) GetAccounts ¶
func (rpc *AergoRPCService) GetAccounts(ctx context.Context, in *types.Empty) (*types.AccountList, error)
GetAccounts handle rpc request getaccounts
func (*AergoRPCService) GetBlock ¶
func (rpc *AergoRPCService) GetBlock(ctx context.Context, in *types.SingleBytes) (*types.Block, error)
GetBlock handle rpc request getblock
func (*AergoRPCService) GetBlockBody ¶ added in v0.9.0
func (rpc *AergoRPCService) GetBlockBody(ctx context.Context, in *types.BlockBodyParams) (*types.BlockBodyPaged, error)
GetBlockBody handle rpc request getblockbody
func (*AergoRPCService) GetBlockMetadata ¶ added in v0.9.0
func (rpc *AergoRPCService) GetBlockMetadata(ctx context.Context, in *types.SingleBytes) (*types.BlockMetadata, error)
GetBlockMetadata handle rpc request getblock
func (*AergoRPCService) GetBlockTX ¶
func (rpc *AergoRPCService) GetBlockTX(ctx context.Context, in *types.SingleBytes) (*types.TxInBlock, error)
GetBlockTX handle rpc request gettx
func (*AergoRPCService) GetChainInfo ¶ added in v0.9.0
func (rpc *AergoRPCService) GetChainInfo(ctx context.Context, in *types.Empty) (*types.ChainInfo, error)
GetChainInfo handles a getchaininfo RPC request.
func (*AergoRPCService) GetNameInfo ¶ added in v0.9.0
func (*AergoRPCService) GetReceipt ¶
func (rpc *AergoRPCService) GetReceipt(ctx context.Context, in *types.SingleBytes) (*types.Receipt, error)
func (*AergoRPCService) GetStaking ¶ added in v0.8.1
func (rpc *AergoRPCService) GetStaking(ctx context.Context, in *types.SingleBytes) (*types.Staking, error)
GetStaking handle rpc request getstaking
func (*AergoRPCService) GetState ¶
func (rpc *AergoRPCService) GetState(ctx context.Context, in *types.SingleBytes) (*types.State, error)
GetState handle rpc request getstate
func (*AergoRPCService) GetStateAndProof ¶
func (rpc *AergoRPCService) GetStateAndProof(ctx context.Context, in *types.AccountAndRoot) (*types.AccountProof, error)
GetStateAndProof handle rpc request getstateproof
func (*AergoRPCService) GetTX ¶
func (rpc *AergoRPCService) GetTX(ctx context.Context, in *types.SingleBytes) (*types.Tx, error)
GetTX handle rpc request gettx
func (*AergoRPCService) GetVotes ¶
func (rpc *AergoRPCService) GetVotes(ctx context.Context, in *types.SingleBytes) (*types.VoteList, error)
GetVotes handle rpc request getvotes
func (*AergoRPCService) ImportAccount ¶
func (rpc *AergoRPCService) ImportAccount(ctx context.Context, in *types.ImportFormat) (*types.Account, error)
func (*AergoRPCService) ListBlockHeaders ¶
func (rpc *AergoRPCService) ListBlockHeaders(ctx context.Context, in *types.ListParams) (*types.BlockHeaderList, error)
ListBlockHeaders (Deprecated) handle rpc request listblocks
func (*AergoRPCService) ListBlockMetadata ¶ added in v0.9.0
func (rpc *AergoRPCService) ListBlockMetadata(ctx context.Context, in *types.ListParams) (*types.BlockMetadataList, error)
ListBlockMetadata handle rpc request
func (*AergoRPCService) ListBlockMetadataStream ¶ added in v0.9.0
func (rpc *AergoRPCService) ListBlockMetadataStream(in *types.Empty, stream types.AergoRPCService_ListBlockMetadataStreamServer) error
func (*AergoRPCService) ListBlockStream ¶
func (rpc *AergoRPCService) ListBlockStream(in *types.Empty, stream types.AergoRPCService_ListBlockStreamServer) error
real-time streaming most recent block header
func (*AergoRPCService) LockAccount ¶
func (rpc *AergoRPCService) LockAccount(ctx context.Context, in *types.Personal) (*types.Account, error)
LockAccount handle rpc request lockaccount
func (*AergoRPCService) Metric ¶ added in v0.8.2
func (rpc *AergoRPCService) Metric(ctx context.Context, req *types.MetricsRequest) (*types.Metrics, error)
func (*AergoRPCService) NodeState ¶
func (rpc *AergoRPCService) NodeState(ctx context.Context, in *types.NodeReq) (*types.SingleBytes, error)
NodeState handle rpc request nodestate
func (*AergoRPCService) QueryContract ¶
func (rpc *AergoRPCService) QueryContract(ctx context.Context, in *types.Query) (*types.SingleBytes, error)
func (*AergoRPCService) QueryContractState ¶ added in v0.8.1
func (rpc *AergoRPCService) QueryContractState(ctx context.Context, in *types.StateQuery) (*types.StateQueryProof, error)
QueryContractState queries the state of a contract state variable without executing a contract function.
func (*AergoRPCService) SendTX ¶
func (rpc *AergoRPCService) SendTX(ctx context.Context, tx *types.Tx) (*types.CommitResult, error)
SendTX try to fill the nonce, sign, hash in the transaction automatically and commit it
func (*AergoRPCService) UnlockAccount ¶
func (rpc *AergoRPCService) UnlockAccount(ctx context.Context, in *types.Personal) (*types.Account, error)
UnlockAccount handle rpc request unlockaccount
func (*AergoRPCService) VerifyTX ¶
func (rpc *AergoRPCService) VerifyTX(ctx context.Context, in *types.Tx) (*types.VerifyResult, error)
VerifyTX handle rpc request verifytx
type RPC ¶
type RPC struct { *component.BaseComponent // contains filtered or unexported fields }
RPC is actor for providing rpc service
func NewRPC ¶
func NewRPC(cfg *config.Config, chainAccessor types.ChainAccessor) *RPC
NewRPC create an rpc service
func (*RPC) AfterStart ¶
func (ns *RPC) AfterStart()
func (*RPC) CallRequest ¶
func (ns *RPC) CallRequest(actor string, msg interface{}, timeout time.Duration) (interface{}, error)
CallRequest implement interface method of ActorService
func (*RPC) CallRequestDefaultTimeout ¶
CallRequest implement interface method of ActorService
func (*RPC) FutureRequest ¶
FutureRequest implement interface method of ActorService
func (*RPC) FutureRequestDefaultTimeout ¶
FutureRequestDefaultTimeout implement interface method of ActorService
func (*RPC) GetChainAccessor ¶
func (ns *RPC) GetChainAccessor() types.ChainAccessor
GetChainAccessor implment interface method of ActorService
func (*RPC) SendRequest ¶
SendRequest implement interface method of ActorService
func (*RPC) SetHub ¶ added in v0.8.2
func (ns *RPC) SetHub(hub *component.ComponentHub)
func (*RPC) Statistics ¶
func (*RPC) TellRequest ¶
TellRequest implement interface method of ActorService