rpc

Jun 14, 2018

Changes in this version

+ const MaxGateWayRecvMsgSize

May 22, 2018

Changes in this version

+ const MaxRecvMsgSize

May 8, 2018

Changes in this version

type APIService

+ func (s *APIService) GetTransactionByContract(ctx context.Context, req *rpcpb.GetTransactionByContractRequest) (*rpcpb.TransactionResponse, error)

type AdminService

+ func (s *AdminService) GenerateRandomSeed(ctx context.Context, req *rpcpb.GenerateRandomSeedRequest) (*rpcpb.GenerateRandomSeedResponse, error)

Mar 29, 2018

Changes in this version

+ const API

+ const Admin

+ const DefaultConnectionLimits

+ const DefaultHTTPLimit

+ var ErrEmptyRPCListenList = errors.New("empty rpc listen list")

type APIService

+ func (s *APIService) EstimateGas(ctx context.Context, req *rpcpb.TransactionRequest) (*rpcpb.GasResponse, error)

+ func (s *APIService) GetBlockByHeight(ctx context.Context, req *rpcpb.GetBlockByHeightRequest) (*rpcpb.BlockResponse, error)

+ func (s *APIService) GetDynasty(ctx context.Context, req *rpcpb.ByBlockHeightRequest) (*rpcpb.GetDynastyResponse, error)

+ func (s *APIService) GetEventsByHash(ctx context.Context, req *rpcpb.HashRequest) (*rpcpb.EventsResponse, error)

+ func (s *APIService) GetGasPrice(ctx context.Context, req *rpcpb.NonParamsRequest) (*rpcpb.GasPriceResponse, error)

+ func (s *APIService) GetTransactionReceipt(ctx context.Context, req *rpcpb.GetTransactionByHashRequest) (*rpcpb.TransactionResponse, error)

+ func (s *APIService) LatestIrreversibleBlock(ctx context.Context, req *rpcpb.NonParamsRequest) (*rpcpb.BlockResponse, error)

+ func (s *APIService) Subscribe(req *rpcpb.SubscribeRequest, gs rpcpb.ApiService_SubscribeServer) error

+ type AdminService struct

+ func (s *AdminService) Accounts(ctx context.Context, req *rpcpb.NonParamsRequest) (*rpcpb.AccountsResponse, error)

+ func (s *AdminService) GetConfig(ctx context.Context, req *rpcpb.NonParamsRequest) (*rpcpb.GetConfigResponse, error)

+ func (s *AdminService) LockAccount(ctx context.Context, req *rpcpb.LockAccountRequest) (*rpcpb.LockAccountResponse, error)

+ func (s *AdminService) NewAccount(ctx context.Context, req *rpcpb.NewAccountRequest) (*rpcpb.NewAccountResponse, error)

+ func (s *AdminService) NodeInfo(ctx context.Context, req *rpcpb.NonParamsRequest) (*rpcpb.NodeInfoResponse, error)

+ func (s *AdminService) SendTransaction(ctx context.Context, req *rpcpb.TransactionRequest) (*rpcpb.SendTransactionResponse, error)

+ func (s *AdminService) SendTransactionWithPassphrase(ctx context.Context, req *rpcpb.SendTransactionPassphraseRequest) (*rpcpb.SendTransactionResponse, error)

+ func (s *AdminService) SignHash(ctx context.Context, req *rpcpb.SignHashRequest) (*rpcpb.SignHashResponse, error)

+ func (s *AdminService) SignTransactionWithPassphrase(ctx context.Context, req *rpcpb.SignTransactionPassphraseRequest) (*rpcpb.SignTransactionPassphraseResponse, error)

+ func (s *AdminService) StartPprof(ctx context.Context, req *rpcpb.PprofRequest) (*rpcpb.PprofResponse, error)

+ func (s *AdminService) UnlockAccount(ctx context.Context, req *rpcpb.UnlockAccountRequest) (*rpcpb.UnlockAccountResponse, error)

+ type GRPCServer interface

+ Neblet func() core.Neblet

+ RunGateway func() error

+ Start func() error

+ Stop func()

type Neblet

+ Consensus func() core.Consensus

+ EventEmitter func() *core.EventEmitter

+ NetService func() nebnet.Service

+ StartPprof func(string) error

Nov 7, 2017

Changes in this version

+ func Run(apiPort uint32, gatewayPort uint32) error

+ type APIServer struct

+ func NewAPIServer(neblet Neblet) *APIServer

+ func (s *APIServer) Address() string

+ func (s *APIServer) Neblet() Neblet

+ func (s *APIServer) RunGateway() error

+ func (s *APIServer) Start() error

+ func (s *APIServer) Stop()

type APIService

+ func (s *APIService) Accounts(ctx context.Context, req *rpcpb.AccountsRequest) (*rpcpb.AccountsResponse, error)

+ func (s *APIService) BlockDump(ctx context.Context, req *rpcpb.BlockDumpRequest) (*rpcpb.BlockDumpResponse, error)

+ func (s *APIService) Call(ctx context.Context, req *rpcpb.CallRequest) (*rpcpb.SendTransactionResponse, error)

+ func (s *APIService) GetBlockByHash(ctx context.Context, req *rpcpb.GetBlockByHashRequest) (*corepb.Block, error)

+ func (s *APIService) GetNebState(ctx context.Context, req *rpcpb.GetNebStateRequest) (*rpcpb.GetNebStateResponse, error)

+ func (s *APIService) GetTransactionByHash(ctx context.Context, req *rpcpb.GetTransactionByHashRequest) (*corepb.Transaction, error)

+ func (s *APIService) SendRawTransaction(ctx context.Context, req *rpcpb.SendRawTransactionRequest) (*rpcpb.SendTransactionResponse, error)

+ type ManagementServer struct

+ func NewManagementServer(neblet Neblet) *ManagementServer

+ func (s *ManagementServer) Address() string

+ func (s *ManagementServer) Neblet() Neblet

+ func (s *ManagementServer) RunGateway() error

+ func (s *ManagementServer) Start() error

+ func (s *ManagementServer) Stop()

+ type ManagementService struct

+ func (s *ManagementService) LockAccount(ctx context.Context, req *rpcpb.LockAccountRequest) (*rpcpb.LockAccountResponse, error)

+ func (s *ManagementService) NewAccount(ctx context.Context, req *rpcpb.NewAccountRequest) (*rpcpb.NewAccountResponse, error)

+ func (s *ManagementService) SendTransactionWithPassphrase(ctx context.Context, req *rpcpb.SendTransactionPassphraseRequest) (*rpcpb.SendTransactionPassphraseResponse, error)

+ func (s *ManagementService) SignTransaction(ctx context.Context, req *rpcpb.SignTransactionRequest) (*rpcpb.SignTransactionResponse, error)

+ func (s *ManagementService) UnlockAccount(ctx context.Context, req *rpcpb.UnlockAccountRequest) (*rpcpb.UnlockAccountResponse, error)

type Server

+ Address func() string

+ RunGateway func() error

Oct 17, 2017

Changes in this version

+ func Address() string

+ func Dial(target string) (*grpc.ClientConn, error)

+ type APIService struct

+ func (s *APIService) GetAccountState(ctx context.Context, req *rpcpb.GetAccountStateRequest) (*rpcpb.GetAccountStateResponse, error)

+ func (s *APIService) SendTransaction(ctx context.Context, req *rpcpb.SendTransactionRequest) (*rpcpb.SendTransactionResponse, error)

+ type Neblet interface

+ AccountManager func() *account.Manager

+ BlockChain func() *core.BlockChain

+ Config func() nebletpb.Config

+ type Server struct

+ func NewServer(neblet Neblet) *Server

+ func (s *Server) Neblet() Neblet

+ func (s *Server) Start() error

+ func (s *Server) Stop()