Versions in this module Expand all Collapse all v1 v1.0.0 Jul 13, 2019 Changes in this version + const MasterServer + const OpAddMinorBlockHeader + const OpAddMinorBlockListForSync + const OpAddRootBlock + const OpAddTransaction + const OpAddTransactions + const OpAddXshardTxList + const OpBatchAddXshardTxList + const OpBroadcastNewMinorBlock + const OpBroadcastNewTip + const OpBroadcastTransactions + const OpConnectToSlaves + const OpCreateClusterPeerConnection + const OpEstimateGas + const OpExecuteTransaction + const OpGasPrice + const OpGenTx + const OpGetAccountData + const OpGetCode + const OpGetLogs + const OpGetMine + const OpGetMinorBlock + const OpGetMinorBlockHeaderList + const OpGetMinorBlockList + const OpGetNextBlockToMine + const OpGetStorageAt + const OpGetTransaction + const OpGetTransactionListByAddress + const OpGetTransactionReceipt + const OpGetUnconfirmedHeaderList + const OpGetWork + const OpHandleNewMinorBlock + const OpHandleNewTip + const OpHeartBeat + const OpMasterInfo + const OpPing + const OpSetMining + const OpSubmitWork + const SlaveServer + func RegisterMasterServerSideOpServer(s *grpc.Server, srv MasterServerSideOpServer) + func RegisterSlaveServerSideOpServer(s *grpc.Server, srv SlaveServerSideOpServer) + func StartGRPCServer(hostport string, apis []rpc.API) (net.Listener, *grpc.Server, error) + type AccountBranchData struct + Balance *big.Int + Branch uint32 + IsContract bool + TransactionCount uint64 + type AddBlockListForSyncRequest struct + Branch uint32 + MinorBlockHashList []common.Hash + PeerId string + type AddBlockListForSyncResponse struct + ShardStatus *ShardStatus + type AddMinorBlockHeaderRequest struct + MinorBlockHeader *types.MinorBlockHeader + ShardStats *ShardStatus + TxCount uint32 + XShardTxCount uint32 + type AddMinorBlockHeaderResponse struct + ArtificialTxConfig *ArtificialTxConfig + type AddMinorBlockRequest struct + MinorBlockData []byte + type AddRootBlockRequest struct + ExpectSwitch bool + RootBlock *types.RootBlock + type AddRootBlockResponse struct + Switched bool + type AddTransactionRequest struct + Tx *types.Transaction + type AddXshardTxListRequest struct + Branch uint32 + MinorBlockHash common.Hash + TxList []*types.CrossShardTransactionDeposit + type ArtificialTxConfig struct + TargetMinorBlockTime uint32 + TargetRootBlockTime uint32 + type BatchAddXshardTxListRequest struct + AddXshardTxListRequestList []*AddXshardTxListRequest + type BroadcastMinorBlock struct + Branch uint32 + MinorBlock *types.MinorBlock + type BroadcastNewTip struct + Branch uint32 + MinorBlockHeaderList []*types.MinorBlockHeader + RootBlockHeader *types.RootBlockHeader + type BroadcastTransactions struct + Branch uint32 + Txs []*types.Transaction + type Client interface + Call func(hostport string, req *Request) (*Response, error) + GetOpName func(uint32) string + func NewClient(serverType serverType) Client + type ConnectToSlavesRequest struct + SlaveInfoList []*SlaveInfo + type ConnectToSlavesResponse struct + ResultList []*ConnectToSlavesResult + type ConnectToSlavesResult struct + Result []byte + type CrossShardTransactionList struct + TxList []*types.CrossShardTransactionDeposit + type EcoInfo struct + Branch account.Branch + CoinbaseAmount common.Hash + Difficulty *big.Int + Height uint64 + UnconfirmedHeadersCoinbaseAmount common.Hash + type EstimateGasRequest struct + FromAddress *account.Address + Tx *types.Transaction + type EstimateGasResponse struct + Result uint32 + type ExecuteTransactionRequest struct + BlockHeight *uint64 + FromAddress *account.Address + Tx *types.Transaction + type ExecuteTransactionResponse struct + Result []byte + type GasPriceRequest struct + Branch uint32 + type GasPriceResponse struct + Result uint64 + type GenTxRequest struct + NumTxPerShard uint32 + Tx *types.Transaction + XShardPercent uint32 + type GetAccountDataRequest struct + Address *account.Address + BlockHeight *uint64 + type GetAccountDataResponse struct + AccountBranchDataList []*AccountBranchData + type GetCodeRequest struct + Address *account.Address + BlockHeight *uint64 + type GetCodeResponse struct + Result []byte + type GetEcoInfoListResponse struct + EcoInfoList []*EcoInfo + type GetLogRequest struct + Addresses []account.Address + Branch uint32 + EndBlock uint64 + StartBlock uint64 + Topics [][]common.Hash + type GetLogResponse struct + Logs []*types.Log + type GetMinorBlockHeaderListRequest struct + BlockHash common.Hash + Branch uint32 + Direction uint8 + Limit uint32 + PeerID string + type GetMinorBlockHeaderListResponse struct + MinorBlockHeaderList []*types.MinorBlockHeader + type GetMinorBlockListRequest struct + Branch uint32 + MinorBlockHashList []common.Hash + PeerId string + type GetMinorBlockListResponse struct + MinorBlockList []*types.MinorBlock + type GetMinorBlockRequest struct + Branch uint32 + Height uint64 + MinorBlockHash common.Hash + type GetMinorBlockResponse struct + MinorBlock *types.MinorBlock + type GetNextBlockToMineRequest struct + Address account.Address + ArtificialTxConfig *ArtificialTxConfig + Branch account.Branch + type GetNextBlockToMineResponse struct + Block *types.MinorBlock + type GetStorageRequest struct + Address *account.Address + BlockHeight *uint64 + Key common.Hash + type GetStorageResponse struct + Result common.Hash + type GetTransactionListByAddressRequest struct + Address *account.Address + Limit uint32 + Start []byte + type GetTransactionListByAddressResponse struct + Next []byte + TxList []*TransactionDetail + type GetTransactionReceiptRequest struct + Branch uint32 + TxHash common.Hash + type GetTransactionReceiptResponse struct + Index uint32 + MinorBlock *types.MinorBlock + Receipt *types.Receipt + type GetTransactionRequest struct + Branch uint32 + TxHash common.Hash + type GetTransactionResponse struct + Index uint32 + MinorBlock *types.MinorBlock + type GetUnconfirmedHeadersResponse struct + HeadersInfoList []*HeadersInfo + type GetWorkRequest struct + Branch uint32 + type GetWorkResponse struct + Difficulty *big.Int + HeaderHash common.Hash + Height uint64 + type HandleNewTipRequest struct + MinorBlockHeaderList []*types.MinorBlockHeader + PeerID string + RootBlockHeader *types.RootBlockHeader + type HashList struct + Hashes []common.Hash + type HeadersInfo struct + Branch uint32 + HeaderList []*types.MinorBlockHeader + type ISlaveConn interface + AddRootBlock func(rootBlock *types.RootBlock, expectSwitch bool) error + AddTransaction func(tx *types.Transaction) error + EstimateGas func(tx *types.Transaction, fromAddress *account.Address) (uint32, error) + ExecuteTransaction func(tx *types.Transaction, fromAddress *account.Address, height *uint64) ([]byte, error) + GasPrice func(branch account.Branch) (uint64, error) + GenTx func(numTxPerShard, xShardPercent uint32, tx *types.Transaction) error + GetAccountData func(address *account.Address, height *uint64) (*GetAccountDataResponse, error) + GetCode func(address *account.Address, height *uint64) ([]byte, error) + GetLogs func(branch account.Branch, address []account.Address, topics [][]common.Hash, ...) ([]*types.Log, error) + GetMinorBlockByHash func(blockHash common.Hash, branch account.Branch) (*types.MinorBlock, error) + GetMinorBlockByHeight func(height uint64, branch account.Branch) (*types.MinorBlock, error) + GetShardMaskList func() []*types.ChainMask + GetSlaveID func() string + GetStorageAt func(address *account.Address, key common.Hash, height *uint64) (common.Hash, error) + GetTransactionByHash func(txHash common.Hash, branch account.Branch) (*types.MinorBlock, uint32, error) + GetTransactionReceipt func(txHash common.Hash, branch account.Branch) (*types.MinorBlock, uint32, *types.Receipt, error) + GetTransactionsByAddress func(address *account.Address, start []byte, limit uint32) ([]*TransactionDetail, []byte, error) + GetUnconfirmedHeaders func() (*GetUnconfirmedHeadersResponse, error) + GetWork func(branch account.Branch) (*consensus.MiningWork, error) + HasShard func(fullShardID uint32) bool + HeartBeat func() bool + MasterInfo func(ip string, port uint16, rootTip *types.RootBlock) error + SendMiningConfigToSlaves func(artificialTxConfig *ArtificialTxConfig, mining bool) error + SendPing func() ([]byte, []*types.ChainMask, error) + SetMining func(mining bool) error + SubmitWork func(work *SubmitWorkRequest) (success bool, err error) + type MasterInfo struct + Ip string + Port uint16 + RootTip *types.RootBlock + type MasterServerSideOpClient interface + AddMinorBlockHeader func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + BroadcastNewMinorBlock func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + BroadcastNewTip func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + BroadcastTransactions func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetMinorBlockHeaderList func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetMinorBlockList func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + func NewMasterServerSideOpClient(cc *grpc.ClientConn) MasterServerSideOpClient + type MasterServerSideOpServer interface + AddMinorBlockHeader func(context.Context, *Request) (*Response, error) + BroadcastNewMinorBlock func(context.Context, *Request) (*Response, error) + BroadcastNewTip func(context.Context, *Request) (*Response, error) + BroadcastTransactions func(context.Context, *Request) (*Response, error) + GetMinorBlockHeaderList func(context.Context, *Request) (*Response, error) + GetMinorBlockList func(context.Context, *Request) (*Response, error) + type MineRequest struct + ArtificialTxConfig *ArtificialTxConfig + Mining bool + type NetworkError struct + Msg string + func (e *NetworkError) Error() string + type PeerInfoForDisPlay struct + ID []byte + IP uint32 + Port uint32 + type Ping struct + ChainMaskList []*types.ChainMask + Id []byte + type Pong struct + ChainMaskList []*types.ChainMask + Id []byte + type Request struct + Data []byte + Op uint32 + RpcId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetData() []byte + func (m *Request) GetOp() uint32 + func (m *Request) GetRpcId() int64 + func (m *Request) Reset() + func (m *Request) String() string + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type Response struct + Data []byte + RpcId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetData() []byte + func (m *Response) GetRpcId() int64 + func (m *Response) Reset() + func (m *Response) String() string + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type ShardConnForP2P interface + AddBlockListForSync func(request *AddBlockListForSyncRequest) (*ShardStatus, error) + AddTransactions func(request *p2p.NewTransactionList) (*HashList, error) + GetMinorBlockHeaders func(request *p2p.GetMinorBlockHeaderListRequest) (*p2p.GetMinorBlockHeaderListResponse, error) + GetMinorBlocks func(request *GetMinorBlockListRequest) (*p2p.GetMinorBlockListResponse, error) + HandleNewMinorBlock func(request *p2p.NewBlockMinor) (bool, error) + HandleNewTip func(request *HandleNewTipRequest) (bool, error) + type ShardStatus struct + BlockCount60s uint32 + Branch account.Branch + CoinbaseAddress account.Address + Difficulty *big.Int + Height uint64 + LastBlockTime uint64 + PendingTxCount uint32 + StaleBlockCount60s uint32 + Timestamp uint64 + TotalTxCount uint32 + TxCount60s uint32 + type SlaveInfo struct + ChainMaskList []*types.ChainMask + Host string + Id string + Port uint16 + type SlaveServerSideOpClient interface + AddMinorBlockListForSync func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + AddRootBlock func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + AddTransaction func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + AddTransactions func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + AddXshardTxList func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + BatchAddXshardTxList func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + EstimateGas func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + ExecuteTransaction func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GasPrice func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GenTx func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetAccountData func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetCode func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetLogs func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetMinorBlock func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetMinorBlockHeaderList func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetMinorBlockList func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetStorageAt func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetTransaction func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetTransactionListByAddress func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetTransactionReceipt func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetUnconfirmedHeaderList func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + GetWork func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + HandleNewMinorBlock func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + HandleNewTip func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + HeartBeat func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + MasterInfo func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + Ping func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + SetMining func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + SubmitWork func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + func NewSlaveServerSideOpClient(cc *grpc.ClientConn) SlaveServerSideOpClient + type SlaveServerSideOpServer interface + AddMinorBlockListForSync func(context.Context, *Request) (*Response, error) + AddRootBlock func(context.Context, *Request) (*Response, error) + AddTransaction func(context.Context, *Request) (*Response, error) + AddTransactions func(context.Context, *Request) (*Response, error) + AddXshardTxList func(context.Context, *Request) (*Response, error) + BatchAddXshardTxList func(context.Context, *Request) (*Response, error) + EstimateGas func(context.Context, *Request) (*Response, error) + ExecuteTransaction func(context.Context, *Request) (*Response, error) + GasPrice func(context.Context, *Request) (*Response, error) + GenTx func(context.Context, *Request) (*Response, error) + GetAccountData func(context.Context, *Request) (*Response, error) + GetCode func(context.Context, *Request) (*Response, error) + GetLogs func(context.Context, *Request) (*Response, error) + GetMinorBlock func(context.Context, *Request) (*Response, error) + GetMinorBlockHeaderList func(context.Context, *Request) (*Response, error) + GetMinorBlockList func(context.Context, *Request) (*Response, error) + GetStorageAt func(context.Context, *Request) (*Response, error) + GetTransaction func(context.Context, *Request) (*Response, error) + GetTransactionListByAddress func(context.Context, *Request) (*Response, error) + GetTransactionReceipt func(context.Context, *Request) (*Response, error) + GetUnconfirmedHeaderList func(context.Context, *Request) (*Response, error) + GetWork func(context.Context, *Request) (*Response, error) + HandleNewMinorBlock func(context.Context, *Request) (*Response, error) + HandleNewTip func(context.Context, *Request) (*Response, error) + HeartBeat func(context.Context, *Request) (*Response, error) + MasterInfo func(context.Context, *Request) (*Response, error) + Ping func(context.Context, *Request) (*Response, error) + SetMining func(context.Context, *Request) (*Response, error) + SubmitWork func(context.Context, *Request) (*Response, error) + type SubmitWorkRequest struct + Branch uint32 + HeaderHash common.Hash + MixHash common.Hash + Nonce uint64 + type SubmitWorkResponse struct + Success bool + type TransactionDetail struct + BlockHeight uint64 + FromAddress account.Address + Success bool + Timestamp uint64 + ToAddress *account.Address + TxHash common.Hash + Value serialize.Uint256 + type UnimplementedMasterServerSideOpServer struct + func (*UnimplementedMasterServerSideOpServer) AddMinorBlockHeader(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedMasterServerSideOpServer) BroadcastNewMinorBlock(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedMasterServerSideOpServer) BroadcastNewTip(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedMasterServerSideOpServer) BroadcastTransactions(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedMasterServerSideOpServer) GetMinorBlockHeaderList(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedMasterServerSideOpServer) GetMinorBlockList(ctx context.Context, req *Request) (*Response, error) + type UnimplementedSlaveServerSideOpServer struct + func (*UnimplementedSlaveServerSideOpServer) AddMinorBlockListForSync(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) AddRootBlock(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) AddTransaction(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) AddTransactions(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) AddXshardTxList(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) BatchAddXshardTxList(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) EstimateGas(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) ExecuteTransaction(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GasPrice(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GenTx(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetAccountData(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetCode(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetLogs(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetMinorBlock(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetMinorBlockHeaderList(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetMinorBlockList(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetStorageAt(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetTransaction(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetTransactionListByAddress(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetTransactionReceipt(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetUnconfirmedHeaderList(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) GetWork(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) HandleNewMinorBlock(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) HandleNewTip(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) HeartBeat(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) MasterInfo(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) Ping(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) SetMining(ctx context.Context, req *Request) (*Response, error) + func (*UnimplementedSlaveServerSideOpServer) SubmitWork(ctx context.Context, req *Request) (*Response, error)
Go to main page