rpc

Documentation

Index

• type AergoRPCService
  • func (rpc *AergoRPCService) Blockchain(ctx context.Context, in *types.Empty) (*types.BlockchainStatus, 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) GetBlockTX(ctx context.Context, in *types.SingleBytes) (*types.TxInBlock, 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) GetState(ctx context.Context, in *types.SingleBytes) (*types.State, error)
  • func (rpc *AergoRPCService) GetStateAndProof(ctx context.Context, in *types.AccountAndRoot) (*types.StateProof, 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) 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) NodeState(ctx context.Context, in *types.SingleBytes) (*types.SingleBytes, error)
  • func (rpc *AergoRPCService) QueryContract(ctx context.Context, in *types.Query) (*types.SingleBytes, 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 NewRPC(hub *component.ComponentHub, cfg *config.Config, ...) *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) Statistics() *map[string]interface{}
  • func (ns *RPC) TellRequest(actor string, msg interface{})

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) 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) GetBlockTX

func (rpc *AergoRPCService) GetBlockTX(ctx context.Context, in *types.SingleBytes) (*types.TxInBlock, error)

GetBlockTX handle rpc request gettx

func (*AergoRPCService) GetPeers

func (rpc *AergoRPCService) GetPeers(ctx context.Context, in *types.Empty) (*types.PeerList, error)

GetPeers handle rpc request getpeers

func (*AergoRPCService) GetReceipt

func (rpc *AergoRPCService) GetReceipt(ctx context.Context, in *types.SingleBytes) (*types.Receipt, error)

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.StateProof, 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 handle rpc request listblocks

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) NodeState

func (rpc *AergoRPCService) NodeState(ctx context.Context, in *types.SingleBytes) (*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) 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) SignTX

func (rpc *AergoRPCService) SignTX(ctx context.Context, in *types.Tx) (*types.Tx, error)

SignTX handle rpc request signtx

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(hub *component.ComponentHub, cfg *config.Config, chainAccessor types.ChainAccessor) *RPC

NewRPC create an rpc service

func (*RPC) AfterStart

func (ns *RPC) AfterStart()

func (*RPC) BeforeStart

func (ns *RPC) BeforeStart()

Start start rpc service.

func (*RPC) BeforeStop

func (ns *RPC) BeforeStop()

Stop stops rpc service.

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

func (ns *RPC) CallRequestDefaultTimeout(actor string, msg interface{}) (interface{}, error)

CallRequest implement interface method of ActorService

func (*RPC) FutureRequest

func (ns *RPC) FutureRequest(actor string, msg interface{}, timeout time.Duration) *actor.Future

FutureRequest implement interface method of ActorService

func (*RPC) FutureRequestDefaultTimeout

func (ns *RPC) FutureRequestDefaultTimeout(actor string, msg interface{}) *actor.Future

FutureRequestDefaultTimeout implement interface method of ActorService

func (*RPC) GetChainAccessor

func (ns *RPC) GetChainAccessor() types.ChainAccessor

GetChainAccessor implment interface method of ActorService

func (*RPC) Receive

func (ns *RPC) Receive(context actor.Context)

func (*RPC) SendRequest

func (ns *RPC) SendRequest(actor string, msg interface{})

SendRequest implement interface method of ActorService

func (*RPC) Statistics

func (ns *RPC) Statistics() *map[string]interface{}

func (*RPC) TellRequest

func (ns *RPC) TellRequest(actor string, msg interface{})

TellRequest implement interface method of ActorService