Documentation ¶
Overview ¶
Package ptn implements the PalletOne protocol.
Package ptn is a generated GoMock package.
Index ¶
- Constants
- Variables
- func CreateDB(ctx *node.ServiceContext, config *Config) (palletdb.Database, palletdb.Database, error)
- type BloomIndexer
- type Config
- type LesServer
- type Mockproducer
- func (m *Mockproducer) AddToDealBuf(deal *mediatorplugin.VSSDealEvent)
- func (m *Mockproducer) AddToResponseBuf(resp *mediatorplugin.VSSResponseEvent)
- func (m *Mockproducer) AddToTBLSRecoverBuf(sigShare *mediatorplugin.SigShareEvent, header *modules.Header)
- func (m *Mockproducer) AddToTBLSSignBufs(newHash common.Hash)
- func (m *Mockproducer) ClearGroupSignBufs(stableUnit *modules.Unit)
- func (m *Mockproducer) EXPECT() *MockproducerMockRecorder
- func (m *Mockproducer) IsLocalMediator(add common.Address) bool
- func (m *Mockproducer) LocalHaveActiveMediator() bool
- func (m *Mockproducer) LocalHavePrecedingMediator() bool
- func (m *Mockproducer) SubscribeGroupSigEvent(ch chan<- mediatorplugin.GroupSigEvent) event.Subscription
- func (m *Mockproducer) SubscribeNewProducedUnitEvent(ch chan<- mediatorplugin.NewProducedUnitEvent) event.Subscription
- func (m *Mockproducer) SubscribeSigShareEvent(ch chan<- mediatorplugin.SigShareEvent) event.Subscription
- func (m *Mockproducer) SubscribeVSSDealEvent(ch chan<- mediatorplugin.VSSDealEvent) event.Subscription
- func (m *Mockproducer) SubscribeVSSResponseEvent(ch chan<- mediatorplugin.VSSResponseEvent) event.Subscription
- func (m *Mockproducer) UpdateMediatorsDKG(isRenew bool)
- type MockproducerMockRecorder
- func (mr *MockproducerMockRecorder) AddToDealBuf(deal interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) AddToResponseBuf(resp interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) AddToTBLSRecoverBuf(sigShare, header interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) AddToTBLSSignBufs(newHash interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) ClearGroupSignBufs(stableUnit interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) IsLocalMediator(add interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) LocalHaveActiveMediator() *gomock.Call
- func (mr *MockproducerMockRecorder) LocalHavePrecedingMediator() *gomock.Call
- func (mr *MockproducerMockRecorder) SubscribeGroupSigEvent(ch interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) SubscribeNewProducedUnitEvent(ch interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) SubscribeSigShareEvent(ch interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) SubscribeVSSDealEvent(ch interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) SubscribeVSSResponseEvent(ch interface{}) *gomock.Call
- func (mr *MockproducerMockRecorder) UpdateMediatorsDKG(isRenew interface{}) *gomock.Call
- type NodeInfo
- type PalletOne
- func (s *PalletOne) APIs() []rpc.API
- func (s *PalletOne) AccountManager() *accounts.Manager
- func (s *PalletOne) AdapterBroadcast(event jury.AdapterEvent)
- func (p *PalletOne) AddCorsServer(cs LesServer) *PalletOne
- func (p *PalletOne) AddLesServer(ls LesServer)
- func (s *PalletOne) ContractBroadcast(event jury.ContractEvent, local bool)
- func (s *PalletOne) ContractProcessor() *jury.Processor
- func (s *PalletOne) CorsProtocols() []p2p.Protocol
- func (s *PalletOne) CorsServer() LesServer
- func (s *PalletOne) Dag() dag.IDag
- func (s *PalletOne) Downloader() *downloader.Downloader
- func (s *PalletOne) ElectionBroadcast(event jury.ElectionEvent, local bool)
- func (s *PalletOne) Engine() core.ConsensusEngine
- func (s *PalletOne) EthVersion() int
- func (s *PalletOne) EventMux() *event.TypeMux
- func (s *PalletOne) GenesisHash() common.Hash
- func (p *PalletOne) GetKeyStore() *keystore.KeyStore
- func (s *PalletOne) GetLocalActiveMediators() []common.Address
- func (s *PalletOne) GetLocalMediators() []common.Address
- func (s *PalletOne) IsListening() bool
- func (s *PalletOne) LocalHaveActiveMediator() bool
- func (s *PalletOne) MockContractLocalSend(event jury.ContractEvent)
- func (s *PalletOne) NetVersion() uint64
- func (s *PalletOne) ProManager() *ProtocolManager
- func (s *PalletOne) Protocols() []p2p.Protocol
- func (p *PalletOne) SignAndSendTransaction(addr common.Address, tx *modules.Transaction) error
- func (p *PalletOne) SignGenericTransaction(from common.Address, tx *modules.Transaction) (*modules.Transaction, error)
- func (s *PalletOne) Start(srvr *p2p.Server, corss *p2p.Server) error
- func (s *PalletOne) Stop() error
- func (s *PalletOne) TxPool() txspool.ITxPool
- func (s *PalletOne) UnitDb() ptndb.Database
- type PeerInfo
- type PrivateDebugAPI
- func (api *PrivateDebugAPI) Preimage(ctx context.Context, hash common.Hash) (hexutil.Bytes, error)
- func (api *PrivateDebugAPI) TraceBlock(ctx context.Context, blob []byte, config *TraceConfig) ([]*txTraceResult, error)
- func (api *PrivateDebugAPI) TraceBlockByHash(ctx context.Context, hash common.Hash, config *TraceConfig) ([]*txTraceResult, error)
- func (api *PrivateDebugAPI) TraceBlockByNumber(ctx context.Context, number rpc.BlockNumber, config *TraceConfig) ([]*txTraceResult, error)
- func (api *PrivateDebugAPI) TraceBlockFromFile(ctx context.Context, file string, config *TraceConfig) ([]*txTraceResult, error)
- func (api *PrivateDebugAPI) TraceChain(ctx context.Context, start, end rpc.BlockNumber, config *TraceConfig) (*rpc.Subscription, error)
- func (api *PrivateDebugAPI) TraceTransaction(ctx context.Context, hash common.Hash, config *TraceConfig) (interface{}, error)
- type ProtocolManager
- func (pm *ProtocolManager) AdapterBroadcast(event jury.AdapterEvent)
- func (pm *ProtocolManager) AdapterMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) BlockBodiesMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) BlockHeadersMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) BroadcastCe(ce []byte)
- func (pm *ProtocolManager) BroadcastGroupSig(groupSig *mp.GroupSigEvent)
- func (pm *ProtocolManager) BroadcastSigShare(sigShare *mp.SigShareEvent)
- func (pm *ProtocolManager) BroadcastTx(hash common.Hash, tx *modules.Transaction)
- func (pm *ProtocolManager) BroadcastUnit(unit *modules.Unit, propagate bool)
- func (pm *ProtocolManager) BroadcastVSSDeal(deal *mp.VSSDealEvent)
- func (pm *ProtocolManager) BroadcastVSSResponse(deal *mp.VSSResponseEvent)
- func (pm *ProtocolManager) ContractBroadcast(event jury.ContractEvent, local bool)
- func (pm *ProtocolManager) ContractMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) ContractReqLocalSend(event jury.ContractEvent)
- func (pm *ProtocolManager) ElectionBroadcast(event jury.ElectionEvent, local bool)
- func (pm *ProtocolManager) ElectionMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) GetActiveMediatorPeers() map[string]*peer
- func (pm *ProtocolManager) GetBlockBodiesMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) GetBlockHeadersMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) GetLeafNodesMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) GetNodeDataMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) GetPeer(node *discover.Node) (p *peer, self bool)
- func (pm *ProtocolManager) GroupSigMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) IsExistInCache(id []byte) bool
- func (pm *ProtocolManager) LocalHandle(p *peer) error
- func (pm *ProtocolManager) NewBlockHashesMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) NewBlockMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) NodeDataMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) NodeInfo(genesisHash common.Hash) *NodeInfo
- func (pm *ProtocolManager) SigShareMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) Start(srvr *p2p.Server, maxPeers int, syncCh chan bool)
- func (pm *ProtocolManager) StatusMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) Stop()
- func (pm *ProtocolManager) TxMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) VSSDealMsg(msg p2p.Msg, p *peer) error
- func (pm *ProtocolManager) VSSResponseMsg(msg p2p.Msg, p *peer) error
- type PtnApiBackend
- func (b *PtnApiBackend) AccountManager() *accounts.Manager
- func (b *PtnApiBackend) BloomStatus() (uint64, uint64)
- func (b *PtnApiBackend) ChainDb() ptndb.Database
- func (b *PtnApiBackend) ContractDeploy(templateId []byte, txid string, args [][]byte, timeout time.Duration) (deployId []byte, err error)
- func (b *PtnApiBackend) ContractDeployReqTx(from, to common.Address, daoAmount, daoFee uint64, templateId []byte, ...) (common.Hash, common.Address, error)
- func (b *PtnApiBackend) ContractDeployReqTxFee(from, to common.Address, daoAmount, daoFee uint64, templateId []byte, ...) (fee float64, size float64, tm uint32, err error)
- func (b *PtnApiBackend) ContractInstall(ccName string, ccPath string, ccVersion string, ...) ([]byte, error)
- func (b *PtnApiBackend) ContractInstallReqTx(from, to common.Address, daoAmount, daoFee uint64, ...) (reqId common.Hash, tplId []byte, err error)
- func (b *PtnApiBackend) ContractInstallReqTxFee(from, to common.Address, daoAmount, daoFee uint64, ...) (fee float64, size float64, tm uint32, err error)
- func (b *PtnApiBackend) ContractInvoke(deployId []byte, txid string, args [][]byte, timeout time.Duration) ([]byte, error)
- func (b *PtnApiBackend) ContractInvokeReqTokenTx(from, to common.Address, token *modules.Asset, amountToken, fee uint64, ...) (reqId common.Hash, err error)
- func (b *PtnApiBackend) ContractInvokeReqTx(from, to common.Address, daoAmount, daoFee uint64, certID *big.Int, ...) (reqId common.Hash, err error)
- func (b *PtnApiBackend) ContractInvokeReqTxFee(from, to common.Address, daoAmount, daoFee uint64, certID *big.Int, ...) (fee float64, size float64, tm uint32, err error)
- func (b *PtnApiBackend) ContractQuery(id []byte, args [][]byte, timeout time.Duration) (rspPayload []byte, err error)
- func (b *PtnApiBackend) ContractStop(deployId []byte, txid string, deleteImage bool) error
- func (b *PtnApiBackend) ContractStopReqTx(from, to common.Address, daoAmount, daoFee uint64, contractId common.Address, ...) (reqId common.Hash, err error)
- func (b *PtnApiBackend) ContractStopReqTxFee(from, to common.Address, daoAmount, daoFee uint64, contractId common.Address, ...) (fee float64, size float64, tm uint32, err error)
- func (b *PtnApiBackend) Dag() dag.IDag
- func (b *PtnApiBackend) DecodeJsonTx(hexStr string) (string, error)
- func (b *PtnApiBackend) DecodeTx(hexStr string) (string, error)
- func (b *PtnApiBackend) Downloader() *downloader.Downloader
- func (b *PtnApiBackend) ElectionVrf(id uint32) ([]byte, error)
- func (b *PtnApiBackend) EncodeTx(jsonStr string) (string, error)
- func (b *PtnApiBackend) EventMux() *event.TypeMux
- func (b *PtnApiBackend) GetAddrByOutPoint(outPoint *modules.OutPoint) (common.Address, error)
- func (b *PtnApiBackend) GetAddrOutpoints(addr string) ([]modules.OutPoint, error)
- func (b *PtnApiBackend) GetAddrRawUtxos(addr string) (map[modules.OutPoint]*modules.Utxo, error)
- func (b *PtnApiBackend) GetAddrTokenFlow(addr, token string) ([]*ptnjson.TokenFlowJson, error)
- func (b *PtnApiBackend) GetAddrTxHistory(addr string) ([]*ptnjson.TxHistoryJson, error)
- func (b *PtnApiBackend) GetAddrUtxoTxs(addr string) ([]*ptnjson.TxWithUnitInfoJson, error)
- func (b *PtnApiBackend) GetAddrUtxos2(addr string) ([]*ptnjson.UtxoJson, error)
- func (b *PtnApiBackend) GetAddressBalanceStatistics(token string, topN int) (*statistics.TokenAddressBalanceJson, error)
- func (b *PtnApiBackend) GetAddressCount() int
- func (b *PtnApiBackend) GetAllContractTpl() ([]*ptnjson.ContractTemplateJson, error)
- func (b *PtnApiBackend) GetAllContracts() ([]*ptnjson.ContractJson, error)
- func (b *PtnApiBackend) GetAllData() ([][]byte, [][]byte)
- func (b *PtnApiBackend) GetAllUtxos() ([]*ptnjson.UtxoJson, error)
- func (b *PtnApiBackend) GetAssetExistence(asset string) ([]*ptnjson.ProofOfExistenceJson, error)
- func (b *PtnApiBackend) GetAssetTxHistory(asset *modules.Asset) ([]*ptnjson.TxHistoryJson, error)
- func (b *PtnApiBackend) GetChainParameters() *core.ChainParameters
- func (b *PtnApiBackend) GetCommon(key []byte, stableDb bool) ([]byte, error)
- func (b *PtnApiBackend) GetCommonByPrefix(prefix []byte, stableDb bool) map[string][]byte
- func (b *PtnApiBackend) GetContract(addr common.Address) (*ptnjson.ContractJson, error)
- func (b *PtnApiBackend) GetContractInvokeHistory(addr string) ([]*ptnjson.ContractInvokeHistoryJson, error)
- func (b *PtnApiBackend) GetContractState(contractid []byte, key string) ([]byte, *modules.StateVersion, error)
- func (b *PtnApiBackend) GetContractStateJsonByPrefix(contractid []byte, prefix string) ([]ptnjson.ContractStateJson, error)
- func (b *PtnApiBackend) GetContractStatesByPrefix(contractid []byte, prefix string) (map[string]*modules.ContractStateValue, error)
- func (b *PtnApiBackend) GetContractTpl(tplId []byte) (*modules.ContractTemplate, error)
- func (b *PtnApiBackend) GetContractsByTpl(tplId []byte) ([]*ptnjson.ContractJson, error)
- func (b *PtnApiBackend) GetContractsWithJuryAddr(addr common.Hash) []*modules.Contract
- func (b *PtnApiBackend) GetDagAddrUtxos(addr string) ([]*ptnjson.UtxoJson, error)
- func (b *PtnApiBackend) GetFileInfo(filehash string) ([]*modules.ProofOfExistencesInfo, error)
- func (b *PtnApiBackend) GetHeader(hash common.Hash) (*modules.Header, error)
- func (b *PtnApiBackend) GetHeaderByHash(hash common.Hash) (*modules.Header, error)
- func (b *PtnApiBackend) GetHeaderByNumber(number *modules.ChainIndex) (*modules.Header, error)
- func (b *PtnApiBackend) GetJuryAccount() []common.Address
- func (b *PtnApiBackend) GetKeyStore() *keystore.KeyStore
- func (b *PtnApiBackend) GetPoolAddrUtxos(addr common.Address, token *modules.Asset) (map[modules.OutPoint]*modules.Utxo, error)
- func (b *PtnApiBackend) GetPoolTransaction(hash common.Hash) *modules.Transaction
- func (b *PtnApiBackend) GetPoolTransactions() (modules.Transactions, error)
- func (b *PtnApiBackend) GetPrefix(prefix string) map[string][]byte
- func (b *PtnApiBackend) GetProofOfExistencesByMaindata(maindata string) ([]*modules.ProofOfExistencesInfo, error)
- func (s *PtnApiBackend) GetProofTxInfoByHash(strtxhash string) ([][]byte, error)
- func (b *PtnApiBackend) GetStxoEntry(outpoint *modules.OutPoint) (*ptnjson.StxoJson, error)
- func (b *PtnApiBackend) GetTd(blockHash common.Hash) *big.Int
- func (b *PtnApiBackend) GetTrieSyncProgress() (uint64, error)
- func (b *PtnApiBackend) GetTxByHash(hash common.Hash) (*ptnjson.TxWithUnitInfoJson, error)
- func (b *PtnApiBackend) GetTxByReqId(hash common.Hash) (*ptnjson.TxWithUnitInfoJson, error)
- func (b *PtnApiBackend) GetTxByTxid_back(txid string) (*ptnjson.GetTxIdResult, error)
- func (b *PtnApiBackend) GetTxHashByReqId(reqid common.Hash) (common.Hash, error)
- func (b *PtnApiBackend) GetTxPackInfo(txHash common.Hash) (*ptnjson.TxPackInfoJson, error)
- func (b *PtnApiBackend) GetTxPoolTxByHash(hash common.Hash) (*ptnjson.TxPoolTxJson, error)
- func (b *PtnApiBackend) GetTxSearchEntry(hash common.Hash) (*ptnjson.TxSerachEntryJson, error)
- func (b *PtnApiBackend) GetUnit(hash common.Hash) *modules.Unit
- func (b *PtnApiBackend) GetUnitByHash(hash common.Hash) *modules.Unit
- func (b *PtnApiBackend) GetUnitByNumber(number *modules.ChainIndex) *modules.Unit
- func (b *PtnApiBackend) GetUnitNumber(hash common.Hash) uint64
- func (b *PtnApiBackend) GetUnitTxsHashHex(hash common.Hash) ([]string, error)
- func (b *PtnApiBackend) GetUnitTxsInfo(hash common.Hash) ([]*ptnjson.TxSummaryJson, error)
- func (b *PtnApiBackend) GetUnitsByIndex(start, end decimal.Decimal, asset string) []*modules.Unit
- func (b *PtnApiBackend) GetUnpackedTxsByAddr(addr string) ([]*txspool.TxPoolTransaction, error)
- func (b *PtnApiBackend) GetUnstableUnits() []*ptnjson.UnitSummaryJson
- func (b *PtnApiBackend) GetUtxoEntry(outpoint *modules.OutPoint) (*ptnjson.UtxoJson, error)
- func (b *PtnApiBackend) HeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*modules.Header, error)
- func (b *PtnApiBackend) Lock()
- func (b *PtnApiBackend) MemdagInfos() (*modules.MemdagInfos, error)
- func (s *PtnApiBackend) ProofTransactionByHash(tx string) (string, error)
- func (s *PtnApiBackend) ProofTransactionByRlptx(rlptx [][]byte) (string, error)
- func (b *PtnApiBackend) ProtocolVersion() int
- func (b *PtnApiBackend) QueryDbByKey(key []byte) *ptnjson.DbRowJson
- func (b *PtnApiBackend) QueryDbByPrefix(prefix []byte) []*ptnjson.DbRowJson
- func (b *PtnApiBackend) QueryProofOfExistenceByReference(ref string) ([]*ptnjson.ProofOfExistenceJson, error)
- func (b *PtnApiBackend) Queued() ([]*txspool.TxPoolTransaction, error)
- func (b *PtnApiBackend) SaveCommon(key, val []byte) error
- func (b *PtnApiBackend) SendConsensus(ctx context.Context) error
- func (b *PtnApiBackend) SendContractInvokeReqTx(requestTx *modules.Transaction) (common.Hash, error)
- func (b *PtnApiBackend) SendTx(ctx context.Context, tx *modules.Transaction) error
- func (b *PtnApiBackend) SendTxs(ctx context.Context, signedTxs []*modules.Transaction) []error
- func (b *PtnApiBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)
- func (b *PtnApiBackend) SetHead(number uint64)
- func (b *PtnApiBackend) SignAndSendRequest(addr common.Address, tx *modules.Transaction) error
- func (b *PtnApiBackend) SignAndSendTransaction(addr common.Address, tx *modules.Transaction) error
- func (b *PtnApiBackend) StartCorsSync() (string, error)
- func (b *PtnApiBackend) StateAndHeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*state.StateDB, *modules.Header, error)
- func (b *PtnApiBackend) Status() (int, int, int)
- func (b *PtnApiBackend) SubscribeTxPreEvent(ch chan<- modules.TxPreEvent) event.Subscription
- func (b *PtnApiBackend) SuggestPrice(ctx context.Context) (*big.Int, error)
- func (b *PtnApiBackend) SyncUTXOByAddr(addr string) string
- func (b *PtnApiBackend) TxPool() txspool.ITxPool
- func (b *PtnApiBackend) TxPoolClear()
- func (b *PtnApiBackend) TxPoolContent() (map[common.Hash]*txspool.TxPoolTransaction, ...)
- func (b *PtnApiBackend) Unlock()
- func (b *PtnApiBackend) UpdateJuryAccount(addr common.Address, pwd string) bool
- type PublicPalletOneAPI
- type StorageRangeResult
- type Tag
- type TraceConfig
- type TransferPtnArgs
- type TxDesc
Constants ¶
const ( // Protocol messages belonging to ptn/1 StatusMsg = 0x00 NewBlockHashesMsg = 0x01 TxMsg = 0x02 GetBlockHeadersMsg = 0x03 BlockHeadersMsg = 0x04 GetBlockBodiesMsg = 0x05 BlockBodiesMsg = 0x06 NewBlockMsg = 0x07 NewBlockHeaderMsg = 0x08 VSSDealMsg = 0x09 VSSResponseMsg = 0x0a GroupSigMsg = 0x0c GetLeafNodesMsg = 0x0d LeafNodesMsg = 0x0e ContractMsg = 0x0f ElectionMsg = 0x10 AdapterMsg = 0x11 GetNodeDataMsg = 0x20 NodeDataMsg = 0x21 )
ptn protocol message codes
const ( ErrMsgTooLarge = iota ErrDecode ErrInvalidMsgCode ErrProtocolVersionMismatch ErrNetworkIdMismatch ErrGenesisBlockMismatch ErrNoStatusMsg ErrExtraStatusMsg ErrSuspendedPeer )
const ProtocolMaxMsgSize = 10 * 1024 * 1024 // Maximum cap on the size of a protocol message
Variables ¶
var ( TestNetKeys []string TestNetValues []string MainNetKeys []string MainNetValues []string )
var ( // Chain index prefixes (use `i` + single byte to avoid mixing data types). BloomBitsIndexPrefix = []byte("iB") // BloomBitsIndexPrefix is the data table of a chain indexer to track its progress )
var DefaultConfig = Config{ SyncMode: downloader.FastSync, NetworkId: 1, LightServ: 10, LightPeers: 25, CorsPeers: 0, DatabaseCache: 768, TrieCache: 256, TrieTimeout: 5 * time.Minute, CryptoLib: []byte{0, 0}, TxPool: txspool.DefaultTxPoolConfig, Dag: dagconfig.DagConfig, MediatorPlugin: mediatorplugin.DefaultConfig, Jury: jury.DefaultConfig, Contract: *contractcfg.NewContractConfig(), }
DefaultConfig contains default settings for use on the PalletOne main net.
var ProtocolLengths = []uint64{100, 8} //{17, 8}
Number of implemented message corresponding to different protocol versions.
var ProtocolName = "ptn"
Official short name of the protocol used during capability negotiation.
var ProtocolVersions = []uint{ptn1}
Supported versions of the ptn protocol (first is primary).
Functions ¶
Types ¶
type BloomIndexer ¶
type BloomIndexer struct {
// contains filtered or unexported fields
}
BloomIndexer implements a core.ChainIndexer, building up a rotated bloom bits index for the Ethereum header bloom filters, permitting blazing fast filtering.
func (*BloomIndexer) Commit ¶
func (b *BloomIndexer) Commit() error
Commit implements core.ChainIndexerBackend, finalizing the bloom section and writing it out into the database.
func (*BloomIndexer) Process ¶
func (b *BloomIndexer) Process(header *modules.Header)
Process implements core.ChainIndexerBackend, adding a new header's bloom into the index.
type Config ¶
type Config struct { // The genesis block, which is inserted if the database is empty. // If nil, the PalletOne main net block is used. Genesis *core.Genesis `toml:",omitempty"` // Protocol options NetworkId uint64 // Network ID to use for selecting peers to connect to SyncMode downloader.SyncMode NoPruning bool // Light client options LightServ int `toml:",omitempty"` // Maximum percentage of time allowed for serving LES requests LightPeers int `toml:",omitempty"` // Maximum number of LES client peers // Cors client options //CorsServ int `toml:",omitempty"` // Maximum percentage of time allowed for serving LES requests CorsPeers int `toml:",omitempty"` // Maximum number of LES client peers // Database options SkipBcVersionCheck bool `toml:"-"` DatabaseHandles int `toml:"-"` DatabaseCache int TrieCache int TrieTimeout time.Duration // Mining-related options //Etherbase common.Address `toml:",omitempty"` MinerThreads int `toml:",omitempty"` ExtraData []byte `toml:",omitempty"` CryptoLib []byte // Transaction pool options TxPool txspool.TxPoolConfig `toml:"-"` // Enables tracking of SHA3 preimages in the VM EnablePreimageRecording bool // DAG options Dag dagconfig.Config `toml:"-"` //jury Account Jury jury.Config `toml:"-"` //Contract config Contract contractcfg.Config `toml:"-"` // Miscellaneous options DocRoot string `toml:"-"` // append by Albert·Gou MediatorPlugin mediatorplugin.Config `toml:"-"` }
type Mockproducer ¶
type Mockproducer struct {
// contains filtered or unexported fields
}
Mockproducer is a mock of producer interface
func NewMockproducer ¶
func NewMockproducer(ctrl *gomock.Controller) *Mockproducer
NewMockproducer creates a new mock instance
func (*Mockproducer) AddToDealBuf ¶ added in v1.0.1
func (m *Mockproducer) AddToDealBuf(deal *mediatorplugin.VSSDealEvent)
AddToDealBuf mocks base method
func (*Mockproducer) AddToResponseBuf ¶
func (m *Mockproducer) AddToResponseBuf(resp *mediatorplugin.VSSResponseEvent)
AddToResponseBuf mocks base method
func (*Mockproducer) AddToTBLSRecoverBuf ¶
func (m *Mockproducer) AddToTBLSRecoverBuf(sigShare *mediatorplugin.SigShareEvent, header *modules.Header)
AddToTBLSRecoverBuf mocks base method
func (*Mockproducer) AddToTBLSSignBufs ¶
func (m *Mockproducer) AddToTBLSSignBufs(newHash common.Hash)
AddToTBLSSignBufs mocks base method
func (*Mockproducer) ClearGroupSignBufs ¶ added in v1.0.6
func (m *Mockproducer) ClearGroupSignBufs(stableUnit *modules.Unit)
ClearGroupSignBufs mocks base method
func (*Mockproducer) EXPECT ¶
func (m *Mockproducer) EXPECT() *MockproducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*Mockproducer) IsLocalMediator ¶ added in v1.0.4
func (m *Mockproducer) IsLocalMediator(add common.Address) bool
IsLocalMediator mocks base method
func (*Mockproducer) LocalHaveActiveMediator ¶
func (m *Mockproducer) LocalHaveActiveMediator() bool
LocalHaveActiveMediator mocks base method
func (*Mockproducer) LocalHavePrecedingMediator ¶
func (m *Mockproducer) LocalHavePrecedingMediator() bool
LocalHavePrecedingMediator mocks base method
func (*Mockproducer) SubscribeGroupSigEvent ¶
func (m *Mockproducer) SubscribeGroupSigEvent(ch chan<- mediatorplugin.GroupSigEvent) event.Subscription
SubscribeGroupSigEvent mocks base method
func (*Mockproducer) SubscribeNewProducedUnitEvent ¶
func (m *Mockproducer) SubscribeNewProducedUnitEvent(ch chan<- mediatorplugin.NewProducedUnitEvent) event.Subscription
SubscribeNewProducedUnitEvent mocks base method
func (*Mockproducer) SubscribeSigShareEvent ¶
func (m *Mockproducer) SubscribeSigShareEvent(ch chan<- mediatorplugin.SigShareEvent) event.Subscription
SubscribeSigShareEvent mocks base method
func (*Mockproducer) SubscribeVSSDealEvent ¶
func (m *Mockproducer) SubscribeVSSDealEvent(ch chan<- mediatorplugin.VSSDealEvent) event.Subscription
SubscribeVSSDealEvent mocks base method
func (*Mockproducer) SubscribeVSSResponseEvent ¶
func (m *Mockproducer) SubscribeVSSResponseEvent(ch chan<- mediatorplugin.VSSResponseEvent) event.Subscription
SubscribeVSSResponseEvent mocks base method
func (*Mockproducer) UpdateMediatorsDKG ¶
func (m *Mockproducer) UpdateMediatorsDKG(isRenew bool)
UpdateMediatorsDKG mocks base method
type MockproducerMockRecorder ¶
type MockproducerMockRecorder struct {
// contains filtered or unexported fields
}
MockproducerMockRecorder is the mock recorder for Mockproducer
func (*MockproducerMockRecorder) AddToDealBuf ¶ added in v1.0.1
func (mr *MockproducerMockRecorder) AddToDealBuf(deal interface{}) *gomock.Call
AddToDealBuf indicates an expected call of AddToDealBuf
func (*MockproducerMockRecorder) AddToResponseBuf ¶
func (mr *MockproducerMockRecorder) AddToResponseBuf(resp interface{}) *gomock.Call
AddToResponseBuf indicates an expected call of AddToResponseBuf
func (*MockproducerMockRecorder) AddToTBLSRecoverBuf ¶
func (mr *MockproducerMockRecorder) AddToTBLSRecoverBuf(sigShare, header interface{}) *gomock.Call
AddToTBLSRecoverBuf indicates an expected call of AddToTBLSRecoverBuf
func (*MockproducerMockRecorder) AddToTBLSSignBufs ¶
func (mr *MockproducerMockRecorder) AddToTBLSSignBufs(newHash interface{}) *gomock.Call
AddToTBLSSignBufs indicates an expected call of AddToTBLSSignBufs
func (*MockproducerMockRecorder) ClearGroupSignBufs ¶ added in v1.0.6
func (mr *MockproducerMockRecorder) ClearGroupSignBufs(stableUnit interface{}) *gomock.Call
ClearGroupSignBufs indicates an expected call of ClearGroupSignBufs
func (*MockproducerMockRecorder) IsLocalMediator ¶ added in v1.0.4
func (mr *MockproducerMockRecorder) IsLocalMediator(add interface{}) *gomock.Call
IsLocalMediator indicates an expected call of IsLocalMediator
func (*MockproducerMockRecorder) LocalHaveActiveMediator ¶
func (mr *MockproducerMockRecorder) LocalHaveActiveMediator() *gomock.Call
LocalHaveActiveMediator indicates an expected call of LocalHaveActiveMediator
func (*MockproducerMockRecorder) LocalHavePrecedingMediator ¶
func (mr *MockproducerMockRecorder) LocalHavePrecedingMediator() *gomock.Call
LocalHavePrecedingMediator indicates an expected call of LocalHavePrecedingMediator
func (*MockproducerMockRecorder) SubscribeGroupSigEvent ¶
func (mr *MockproducerMockRecorder) SubscribeGroupSigEvent(ch interface{}) *gomock.Call
SubscribeGroupSigEvent indicates an expected call of SubscribeGroupSigEvent
func (*MockproducerMockRecorder) SubscribeNewProducedUnitEvent ¶
func (mr *MockproducerMockRecorder) SubscribeNewProducedUnitEvent(ch interface{}) *gomock.Call
SubscribeNewProducedUnitEvent indicates an expected call of SubscribeNewProducedUnitEvent
func (*MockproducerMockRecorder) SubscribeSigShareEvent ¶
func (mr *MockproducerMockRecorder) SubscribeSigShareEvent(ch interface{}) *gomock.Call
SubscribeSigShareEvent indicates an expected call of SubscribeSigShareEvent
func (*MockproducerMockRecorder) SubscribeVSSDealEvent ¶
func (mr *MockproducerMockRecorder) SubscribeVSSDealEvent(ch interface{}) *gomock.Call
SubscribeVSSDealEvent indicates an expected call of SubscribeVSSDealEvent
func (*MockproducerMockRecorder) SubscribeVSSResponseEvent ¶
func (mr *MockproducerMockRecorder) SubscribeVSSResponseEvent(ch interface{}) *gomock.Call
SubscribeVSSResponseEvent indicates an expected call of SubscribeVSSResponseEvent
func (*MockproducerMockRecorder) UpdateMediatorsDKG ¶
func (mr *MockproducerMockRecorder) UpdateMediatorsDKG(isRenew interface{}) *gomock.Call
UpdateMediatorsDKG indicates an expected call of UpdateMediatorsDKG
type NodeInfo ¶
type NodeInfo struct { Network uint64 `json:"network"` // PalletOne network ID (1=Frontier, 2=Morden, Ropsten=3, Rinkeby=4) Index uint64 Genesis common.Hash `json:"genesis"` // SHA3 hash of the host's genesis block Head common.Hash `json:"head"` // SHA3 hash of the host's best owned block }
NodeInfo represents a short summary of the PalletOne sub-protocol metadata known about the host peer.
type PalletOne ¶
type PalletOne struct { ApiBackend *PtnApiBackend // contains filtered or unexported fields }
PalletOne implements the PalletOne full node service.
func New ¶
func New(ctx *node.ServiceContext, config *Config, cache palletcache.ICache, isTestNet bool) (*PalletOne, error)
New creates a new PalletOne object (including the initialisation of the common PalletOne object)
func (*PalletOne) APIs ¶
APIs returns the collection of RPC services the ethereum package offers. NOTE, some of these services probably need to be moved to somewhere else.
func (*PalletOne) AccountManager ¶
func (*PalletOne) AdapterBroadcast ¶
func (s *PalletOne) AdapterBroadcast(event jury.AdapterEvent)
func (*PalletOne) AddCorsServer ¶
func (*PalletOne) AddLesServer ¶
func (*PalletOne) ContractBroadcast ¶
func (s *PalletOne) ContractBroadcast(event jury.ContractEvent, local bool)
func (*PalletOne) ContractProcessor ¶
func (*PalletOne) CorsProtocols ¶
func (*PalletOne) CorsServer ¶
func (*PalletOne) Downloader ¶
func (s *PalletOne) Downloader() *downloader.Downloader
func (*PalletOne) ElectionBroadcast ¶
func (s *PalletOne) ElectionBroadcast(event jury.ElectionEvent, local bool)
func (*PalletOne) Engine ¶
func (s *PalletOne) Engine() core.ConsensusEngine
func (*PalletOne) EthVersion ¶
func (*PalletOne) GenesisHash ¶ added in v1.0.2
func (*PalletOne) GetKeyStore ¶
@author Albert·Gou
func (*PalletOne) GetLocalActiveMediators ¶
func (*PalletOne) GetLocalMediators ¶
func (*PalletOne) IsListening ¶
func (*PalletOne) LocalHaveActiveMediator ¶
func (*PalletOne) MockContractLocalSend ¶
func (s *PalletOne) MockContractLocalSend(event jury.ContractEvent)
func (*PalletOne) NetVersion ¶
func (*PalletOne) ProManager ¶
func (s *PalletOne) ProManager() *ProtocolManager
func (*PalletOne) Protocols ¶
Protocols implements node.Service, returning all the currently configured network protocols to start.
func (*PalletOne) SignAndSendTransaction ¶
@author Albert·Gou
func (*PalletOne) SignGenericTransaction ¶
func (p *PalletOne) SignGenericTransaction(from common.Address, tx *modules.Transaction) (*modules.Transaction, error)
func (*PalletOne) Start ¶
Start implements node.Service, starting all internal goroutines needed by the PalletOne protocol implementation.
type PeerInfo ¶
type PeerInfo struct { Version int `json:"version"` // PalletOne protocol version negotiated //Difficulty uint64 `json:"difficulty"` // Total difficulty of the peer's blockchain Index uint64 `json:"index"` // Total difficulty of the peer's blockchain Head string `json:"head"` // SHA3 hash of the peer's best owned block }
PeerInfo represents a short summary of the PalletOne sub-protocol metadata known about a connected peer.
type PrivateDebugAPI ¶
type PrivateDebugAPI struct { }
// PublicDebugAPI is the collection of PalletOne full node APIs exposed // over the public debugging endpoint.
type PublicDebugAPI struct { ptn *PalletOne }
// NewPublicDebugAPI creates a new API definition for the full node- // related public debug methods of the PalletOne service.
func NewPublicDebugAPI(ptn *PalletOne) *PublicDebugAPI { return &PublicDebugAPI{ptn: ptn} }
PrivateDebugAPI is the collection of PalletOne full node APIs exposed over the private debugging endpoint.
func (*PrivateDebugAPI) Preimage ¶
Preimage is a debug API function that returns the preimage for a sha3 hash, if known.
func (*PrivateDebugAPI) TraceBlock ¶
func (api *PrivateDebugAPI) TraceBlock(ctx context.Context, blob []byte, config *TraceConfig) ([]*txTraceResult, error)
TraceBlock returns the structured logs created during the execution of EVM and returns them as a JSON object.
func (*PrivateDebugAPI) TraceBlockByHash ¶
func (api *PrivateDebugAPI) TraceBlockByHash(ctx context.Context, hash common.Hash, config *TraceConfig) ([]*txTraceResult, error)
TraceBlockByHash returns the structured logs created during the execution of EVM and returns them as a JSON object.
func (*PrivateDebugAPI) TraceBlockByNumber ¶
func (api *PrivateDebugAPI) TraceBlockByNumber(ctx context.Context, number rpc.BlockNumber, config *TraceConfig) ([]*txTraceResult, error)
TraceBlockByNumber returns the structured logs created during the execution of EVM and returns them as a JSON object.
func (*PrivateDebugAPI) TraceBlockFromFile ¶
func (api *PrivateDebugAPI) TraceBlockFromFile(ctx context.Context, file string, config *TraceConfig) ([]*txTraceResult, error)
TraceBlockFromFile returns the structured logs created during the execution of EVM and returns them as a JSON object.
func (*PrivateDebugAPI) TraceChain ¶
func (api *PrivateDebugAPI) TraceChain(ctx context.Context, start, end rpc.BlockNumber, config *TraceConfig) (*rpc.Subscription, error)
TraceChain returns the structured logs created during the execution of EVM between two blocks (excluding start) and returns them as a JSON object.
func (*PrivateDebugAPI) TraceTransaction ¶
func (api *PrivateDebugAPI) TraceTransaction(ctx context.Context, hash common.Hash, config *TraceConfig) (interface{}, error)
TraceTransaction returns the structured logs created during the execution of EVM and returns them as a JSON object.
type ProtocolManager ¶
type ProtocolManager struct { SubProtocols []p2p.Protocol // contains filtered or unexported fields }
func NewProtocolManager ¶
func NewProtocolManager(mode downloader.SyncMode, networkId uint64, gasToken modules.AssetId, txpool txspool.ITxPool, dag dag.IDag, mux *event.TypeMux, producer producer, genesis *modules.Unit, contractProc consensus.ContractInf, engine core.ConsensusEngine, contract *contracts.Contract, pDocker *utils.PalletOneDocker) (*ProtocolManager, error)
NewProtocolManager returns a new PalletOne sub protocol manager. The PalletOne sub protocol manages peers capable with the PalletOne network.
func (*ProtocolManager) AdapterBroadcast ¶
func (pm *ProtocolManager) AdapterBroadcast(event jury.AdapterEvent)
func (*ProtocolManager) AdapterMsg ¶
func (pm *ProtocolManager) AdapterMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) BlockBodiesMsg ¶
func (pm *ProtocolManager) BlockBodiesMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) BlockHeadersMsg ¶
func (pm *ProtocolManager) BlockHeadersMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) BroadcastCe ¶
func (pm *ProtocolManager) BroadcastCe(ce []byte)
test for p2p broadcast
func (*ProtocolManager) BroadcastGroupSig ¶
func (pm *ProtocolManager) BroadcastGroupSig(groupSig *mp.GroupSigEvent)
@author Albert·Gou BroadcastGroupSig will propagate the group signature of unit to p2p network
func (*ProtocolManager) BroadcastSigShare ¶ added in v1.0.4
func (pm *ProtocolManager) BroadcastSigShare(sigShare *mp.SigShareEvent)
func (*ProtocolManager) BroadcastTx ¶
func (pm *ProtocolManager) BroadcastTx(hash common.Hash, tx *modules.Transaction)
BroadcastTx will propagate a transaction to all peers which are not known to already have the given transaction.
func (*ProtocolManager) BroadcastUnit ¶
func (pm *ProtocolManager) BroadcastUnit(unit *modules.Unit, propagate bool)
BroadcastUnit will either propagate a unit to a subset of it's peers, or will only announce it's availability (depending what's requested).
func (*ProtocolManager) BroadcastVSSDeal ¶ added in v1.0.4
func (pm *ProtocolManager) BroadcastVSSDeal(deal *mp.VSSDealEvent)
func (*ProtocolManager) BroadcastVSSResponse ¶ added in v1.0.4
func (pm *ProtocolManager) BroadcastVSSResponse(deal *mp.VSSResponseEvent)
func (*ProtocolManager) ContractBroadcast ¶
func (pm *ProtocolManager) ContractBroadcast(event jury.ContractEvent, local bool)
func (*ProtocolManager) ContractMsg ¶
func (pm *ProtocolManager) ContractMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) ContractReqLocalSend ¶
func (pm *ProtocolManager) ContractReqLocalSend(event jury.ContractEvent)
func (*ProtocolManager) ElectionBroadcast ¶
func (pm *ProtocolManager) ElectionBroadcast(event jury.ElectionEvent, local bool)
func (*ProtocolManager) ElectionMsg ¶
func (pm *ProtocolManager) ElectionMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) GetActiveMediatorPeers ¶
func (pm *ProtocolManager) GetActiveMediatorPeers() map[string]*peer
GetActiveMediatorPeers retrieves a list of peers that active mediator. If the value is nil, it is the node itself @author Albert·Gou
func (*ProtocolManager) GetBlockBodiesMsg ¶
func (pm *ProtocolManager) GetBlockBodiesMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) GetBlockHeadersMsg ¶
func (pm *ProtocolManager) GetBlockHeadersMsg(msg p2p.Msg, p *peer) error
Block header query, collect the requested headers and reply
func (*ProtocolManager) GetLeafNodesMsg ¶
func (pm *ProtocolManager) GetLeafNodesMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) GetNodeDataMsg ¶
func (pm *ProtocolManager) GetNodeDataMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) GetPeer ¶
func (pm *ProtocolManager) GetPeer(node *discover.Node) (p *peer, self bool)
GetPeer, retrieve specified peer. If it is the node itself, p is nil and self is true @author Albert·Gou
func (*ProtocolManager) GroupSigMsg ¶
func (pm *ProtocolManager) GroupSigMsg(msg p2p.Msg, p *peer) error
GroupSigMsg
func (*ProtocolManager) IsExistInCache ¶
func (pm *ProtocolManager) IsExistInCache(id []byte) bool
func (*ProtocolManager) LocalHandle ¶
func (pm *ProtocolManager) LocalHandle(p *peer) error
func (*ProtocolManager) NewBlockHashesMsg ¶
func (pm *ProtocolManager) NewBlockHashesMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) NewBlockMsg ¶
func (pm *ProtocolManager) NewBlockMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) NodeDataMsg ¶
func (pm *ProtocolManager) NodeDataMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) NodeInfo ¶
func (pm *ProtocolManager) NodeInfo(genesisHash common.Hash) *NodeInfo
NodeInfo retrieves some protocol metadata about the running host node.
func (*ProtocolManager) SigShareMsg ¶
func (pm *ProtocolManager) SigShareMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) Start ¶
func (pm *ProtocolManager) Start(srvr *p2p.Server, maxPeers int, syncCh chan bool)
func (*ProtocolManager) StatusMsg ¶
func (pm *ProtocolManager) StatusMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) Stop ¶
func (pm *ProtocolManager) Stop()
func (*ProtocolManager) TxMsg ¶
func (pm *ProtocolManager) TxMsg(msg p2p.Msg, p *peer) error
func includeContractTx(txs []*modules.Transaction) bool { //todo sort
for _, tx := range txs { if tx.IsContractTx() && tx.IsOnlyContractRequest() { return true } } return false }
func (*ProtocolManager) VSSDealMsg ¶
func (pm *ProtocolManager) VSSDealMsg(msg p2p.Msg, p *peer) error
func (*ProtocolManager) VSSResponseMsg ¶
func (pm *ProtocolManager) VSSResponseMsg(msg p2p.Msg, p *peer) error
type PtnApiBackend ¶
type PtnApiBackend struct {
// contains filtered or unexported fields
}
PtnApiBackend implements ethapi.Backend for full nodes
func (*PtnApiBackend) AccountManager ¶
func (b *PtnApiBackend) AccountManager() *accounts.Manager
func (*PtnApiBackend) BloomStatus ¶
func (b *PtnApiBackend) BloomStatus() (uint64, uint64)
func (*PtnApiBackend) ChainDb ¶
func (b *PtnApiBackend) ChainDb() ptndb.Database
func (*PtnApiBackend) ContractDeploy ¶
func (*PtnApiBackend) ContractDeployReqTx ¶
func (*PtnApiBackend) ContractDeployReqTxFee ¶ added in v1.0.3
func (*PtnApiBackend) ContractInstall ¶
func (*PtnApiBackend) ContractInstallReqTx ¶
func (*PtnApiBackend) ContractInstallReqTxFee ¶ added in v1.0.3
func (*PtnApiBackend) ContractInvoke ¶
func (*PtnApiBackend) ContractInvokeReqTokenTx ¶
func (*PtnApiBackend) ContractInvokeReqTx ¶
func (*PtnApiBackend) ContractInvokeReqTxFee ¶ added in v1.0.3
func (*PtnApiBackend) ContractQuery ¶
func (*PtnApiBackend) ContractStop ¶
func (b *PtnApiBackend) ContractStop(deployId []byte, txid string, deleteImage bool) error
func (*PtnApiBackend) ContractStopReqTx ¶
func (*PtnApiBackend) ContractStopReqTxFee ¶ added in v1.0.3
func (*PtnApiBackend) Dag ¶
func (b *PtnApiBackend) Dag() dag.IDag
func (*PtnApiBackend) DecodeJsonTx ¶ added in v1.0.3
func (b *PtnApiBackend) DecodeJsonTx(hexStr string) (string, error)
func (*PtnApiBackend) Downloader ¶
func (b *PtnApiBackend) Downloader() *downloader.Downloader
func (*PtnApiBackend) ElectionVrf ¶
func (b *PtnApiBackend) ElectionVrf(id uint32) ([]byte, error)
func (*PtnApiBackend) EventMux ¶
func (b *PtnApiBackend) EventMux() *event.TypeMux
func (*PtnApiBackend) GetAddrByOutPoint ¶
func (*PtnApiBackend) GetAddrOutpoints ¶
func (b *PtnApiBackend) GetAddrOutpoints(addr string) ([]modules.OutPoint, error)
func (*PtnApiBackend) GetAddrRawUtxos ¶
func (*PtnApiBackend) GetAddrTokenFlow ¶ added in v1.0.3
func (b *PtnApiBackend) GetAddrTokenFlow(addr, token string) ([]*ptnjson.TokenFlowJson, error)
func (*PtnApiBackend) GetAddrTxHistory ¶
func (b *PtnApiBackend) GetAddrTxHistory(addr string) ([]*ptnjson.TxHistoryJson, error)
func (*PtnApiBackend) GetAddrUtxoTxs ¶ added in v1.0.6
func (b *PtnApiBackend) GetAddrUtxoTxs(addr string) ([]*ptnjson.TxWithUnitInfoJson, error)
func (*PtnApiBackend) GetAddrUtxos2 ¶ added in v1.0.3
func (b *PtnApiBackend) GetAddrUtxos2(addr string) ([]*ptnjson.UtxoJson, error)
func (*PtnApiBackend) GetAddressBalanceStatistics ¶ added in v1.0.1
func (b *PtnApiBackend) GetAddressBalanceStatistics(token string, topN int) (*statistics.TokenAddressBalanceJson, error)
func (*PtnApiBackend) GetAddressCount ¶ added in v1.0.6
func (b *PtnApiBackend) GetAddressCount() int
func (*PtnApiBackend) GetAllContractTpl ¶
func (b *PtnApiBackend) GetAllContractTpl() ([]*ptnjson.ContractTemplateJson, error)
func (*PtnApiBackend) GetAllContracts ¶
func (b *PtnApiBackend) GetAllContracts() ([]*ptnjson.ContractJson, error)
func (*PtnApiBackend) GetAllData ¶ added in v1.0.4
func (b *PtnApiBackend) GetAllData() ([][]byte, [][]byte)
func (*PtnApiBackend) GetAllUtxos ¶
func (b *PtnApiBackend) GetAllUtxos() ([]*ptnjson.UtxoJson, error)
func (*PtnApiBackend) GetAssetExistence ¶ added in v1.0.1
func (b *PtnApiBackend) GetAssetExistence(asset string) ([]*ptnjson.ProofOfExistenceJson, error)
func (*PtnApiBackend) GetAssetTxHistory ¶
func (b *PtnApiBackend) GetAssetTxHistory(asset *modules.Asset) ([]*ptnjson.TxHistoryJson, error)
func (*PtnApiBackend) GetChainParameters ¶
func (b *PtnApiBackend) GetChainParameters() *core.ChainParameters
func (*PtnApiBackend) GetCommon ¶
func (b *PtnApiBackend) GetCommon(key []byte, stableDb bool) ([]byte, error)
func (*PtnApiBackend) GetCommonByPrefix ¶
func (b *PtnApiBackend) GetCommonByPrefix(prefix []byte, stableDb bool) map[string][]byte
func (*PtnApiBackend) GetContract ¶
func (b *PtnApiBackend) GetContract(addr common.Address) (*ptnjson.ContractJson, error)
GetContract
func (*PtnApiBackend) GetContractInvokeHistory ¶ added in v1.0.3
func (b *PtnApiBackend) GetContractInvokeHistory(addr string) ([]*ptnjson.ContractInvokeHistoryJson, error)
func (*PtnApiBackend) GetContractState ¶
func (b *PtnApiBackend) GetContractState(contractid []byte, key string) ([]byte, *modules.StateVersion, error)
func (*PtnApiBackend) GetContractStateJsonByPrefix ¶ added in v1.0.3
func (b *PtnApiBackend) GetContractStateJsonByPrefix(contractid []byte, prefix string) ([]ptnjson.ContractStateJson, error)
func (*PtnApiBackend) GetContractStatesByPrefix ¶
func (b *PtnApiBackend) GetContractStatesByPrefix(contractid []byte, prefix string) (map[string]*modules.ContractStateValue, error)
func (*PtnApiBackend) GetContractTpl ¶ added in v1.0.1
func (b *PtnApiBackend) GetContractTpl(tplId []byte) (*modules.ContractTemplate, error)
func (*PtnApiBackend) GetContractsByTpl ¶
func (b *PtnApiBackend) GetContractsByTpl(tplId []byte) ([]*ptnjson.ContractJson, error)
func (*PtnApiBackend) GetContractsWithJuryAddr ¶ added in v1.0.5
func (b *PtnApiBackend) GetContractsWithJuryAddr(addr common.Hash) []*modules.Contract
func (*PtnApiBackend) GetDagAddrUtxos ¶ added in v1.0.7
func (b *PtnApiBackend) GetDagAddrUtxos(addr string) ([]*ptnjson.UtxoJson, error)
func (*PtnApiBackend) GetFileInfo ¶
func (b *PtnApiBackend) GetFileInfo(filehash string) ([]*modules.ProofOfExistencesInfo, error)
func (*PtnApiBackend) GetHeaderByHash ¶
func (*PtnApiBackend) GetHeaderByNumber ¶
func (b *PtnApiBackend) GetHeaderByNumber(number *modules.ChainIndex) (*modules.Header, error)
func (*PtnApiBackend) GetJuryAccount ¶
func (b *PtnApiBackend) GetJuryAccount() []common.Address
func (*PtnApiBackend) GetKeyStore ¶
func (b *PtnApiBackend) GetKeyStore() *keystore.KeyStore
func (*PtnApiBackend) GetPoolAddrUtxos ¶ added in v1.0.7
func (*PtnApiBackend) GetPoolTransaction ¶
func (b *PtnApiBackend) GetPoolTransaction(hash common.Hash) *modules.Transaction
func (*PtnApiBackend) GetPoolTransactions ¶
func (b *PtnApiBackend) GetPoolTransactions() (modules.Transactions, error)
func (*PtnApiBackend) GetPrefix ¶
func (b *PtnApiBackend) GetPrefix(prefix string) map[string][]byte
func (*PtnApiBackend) GetProofOfExistencesByMaindata ¶ added in v1.0.7
func (b *PtnApiBackend) GetProofOfExistencesByMaindata(maindata string) ([]*modules.ProofOfExistencesInfo, error)
func (*PtnApiBackend) GetProofTxInfoByHash ¶
func (s *PtnApiBackend) GetProofTxInfoByHash(strtxhash string) ([][]byte, error)
func (*PtnApiBackend) GetStxoEntry ¶ added in v1.0.1
func (*PtnApiBackend) GetTrieSyncProgress ¶
func (b *PtnApiBackend) GetTrieSyncProgress() (uint64, error)
func (*PtnApiBackend) GetTxByHash ¶
func (b *PtnApiBackend) GetTxByHash(hash common.Hash) (*ptnjson.TxWithUnitInfoJson, error)
func (*PtnApiBackend) GetTxByReqId ¶
func (b *PtnApiBackend) GetTxByReqId(hash common.Hash) (*ptnjson.TxWithUnitInfoJson, error)
func (*PtnApiBackend) GetTxByTxid_back ¶
func (b *PtnApiBackend) GetTxByTxid_back(txid string) (*ptnjson.GetTxIdResult, error)
func (*PtnApiBackend) GetTxHashByReqId ¶
func (*PtnApiBackend) GetTxPackInfo ¶ added in v1.0.6
func (b *PtnApiBackend) GetTxPackInfo(txHash common.Hash) (*ptnjson.TxPackInfoJson, error)
func (*PtnApiBackend) GetTxPoolTxByHash ¶
func (b *PtnApiBackend) GetTxPoolTxByHash(hash common.Hash) (*ptnjson.TxPoolTxJson, error)
GetPoolTxByHash return a json of the tx in pool.
func (*PtnApiBackend) GetTxSearchEntry ¶
func (b *PtnApiBackend) GetTxSearchEntry(hash common.Hash) (*ptnjson.TxSerachEntryJson, error)
func (*PtnApiBackend) GetUnit ¶
func (b *PtnApiBackend) GetUnit(hash common.Hash) *modules.Unit
Get Unit
func (*PtnApiBackend) GetUnitByHash ¶
func (b *PtnApiBackend) GetUnitByHash(hash common.Hash) *modules.Unit
func (*PtnApiBackend) GetUnitByNumber ¶
func (b *PtnApiBackend) GetUnitByNumber(number *modules.ChainIndex) *modules.Unit
func (*PtnApiBackend) GetUnitNumber ¶
func (b *PtnApiBackend) GetUnitNumber(hash common.Hash) uint64
Get UnitNumber
func (*PtnApiBackend) GetUnitTxsHashHex ¶
func (b *PtnApiBackend) GetUnitTxsHashHex(hash common.Hash) ([]string, error)
func (*PtnApiBackend) GetUnitTxsInfo ¶
func (b *PtnApiBackend) GetUnitTxsInfo(hash common.Hash) ([]*ptnjson.TxSummaryJson, error)
func (*PtnApiBackend) GetUnitsByIndex ¶
func (*PtnApiBackend) GetUnpackedTxsByAddr ¶ added in v1.0.6
func (b *PtnApiBackend) GetUnpackedTxsByAddr(addr string) ([]*txspool.TxPoolTransaction, error)
func (*PtnApiBackend) GetUnstableUnits ¶
func (b *PtnApiBackend) GetUnstableUnits() []*ptnjson.UnitSummaryJson
func (*PtnApiBackend) GetUtxoEntry ¶
func (*PtnApiBackend) HeaderByNumber ¶
func (b *PtnApiBackend) HeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*modules.Header, error)
func (*PtnApiBackend) Lock ¶ added in v1.0.6
func (b *PtnApiBackend) Lock()
func (*PtnApiBackend) MemdagInfos ¶ added in v1.0.4
func (b *PtnApiBackend) MemdagInfos() (*modules.MemdagInfos, error)
func (*PtnApiBackend) ProofTransactionByHash ¶
func (s *PtnApiBackend) ProofTransactionByHash(tx string) (string, error)
func (*PtnApiBackend) ProofTransactionByRlptx ¶
func (s *PtnApiBackend) ProofTransactionByRlptx(rlptx [][]byte) (string, error)
func (*PtnApiBackend) ProtocolVersion ¶
func (b *PtnApiBackend) ProtocolVersion() int
func (*PtnApiBackend) QueryDbByKey ¶
func (b *PtnApiBackend) QueryDbByKey(key []byte) *ptnjson.DbRowJson
func (*PtnApiBackend) QueryDbByPrefix ¶
func (b *PtnApiBackend) QueryDbByPrefix(prefix []byte) []*ptnjson.DbRowJson
func (*PtnApiBackend) QueryProofOfExistenceByReference ¶
func (b *PtnApiBackend) QueryProofOfExistenceByReference(ref string) ([]*ptnjson.ProofOfExistenceJson, error)
func (*PtnApiBackend) Queued ¶
func (b *PtnApiBackend) Queued() ([]*txspool.TxPoolTransaction, error)
func (*PtnApiBackend) SaveCommon ¶
func (b *PtnApiBackend) SaveCommon(key, val []byte) error
func (*PtnApiBackend) SendConsensus ¶
func (b *PtnApiBackend) SendConsensus(ctx context.Context) error
func (*PtnApiBackend) SendContractInvokeReqTx ¶ added in v1.0.1
func (b *PtnApiBackend) SendContractInvokeReqTx(requestTx *modules.Transaction) (common.Hash, error)
func (*PtnApiBackend) SendTx ¶
func (b *PtnApiBackend) SendTx(ctx context.Context, tx *modules.Transaction) error
func (*PtnApiBackend) SendTxs ¶ added in v1.0.1
func (b *PtnApiBackend) SendTxs(ctx context.Context, signedTxs []*modules.Transaction) []error
func (*PtnApiBackend) ServiceFilter ¶
func (b *PtnApiBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)
func (*PtnApiBackend) SetHead ¶
func (b *PtnApiBackend) SetHead(number uint64)
func (*PtnApiBackend) SignAndSendRequest ¶
func (b *PtnApiBackend) SignAndSendRequest(addr common.Address, tx *modules.Transaction) error
func (*PtnApiBackend) SignAndSendTransaction ¶
func (b *PtnApiBackend) SignAndSendTransaction(addr common.Address, tx *modules.Transaction) error
func (*PtnApiBackend) StartCorsSync ¶
func (b *PtnApiBackend) StartCorsSync() (string, error)
func (*PtnApiBackend) StateAndHeaderByNumber ¶
func (b *PtnApiBackend) StateAndHeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*state.StateDB, *modules.Header, error)
func (*PtnApiBackend) SubscribeTxPreEvent ¶
func (b *PtnApiBackend) SubscribeTxPreEvent(ch chan<- modules.TxPreEvent) event.Subscription
func (*PtnApiBackend) SuggestPrice ¶
func (*PtnApiBackend) SyncUTXOByAddr ¶
func (b *PtnApiBackend) SyncUTXOByAddr(addr string) string
func (*PtnApiBackend) TxPool ¶
func (b *PtnApiBackend) TxPool() txspool.ITxPool
func (*PtnApiBackend) TxPoolClear ¶ added in v1.0.7
func (b *PtnApiBackend) TxPoolClear()
func (*PtnApiBackend) TxPoolContent ¶
func (b *PtnApiBackend) TxPoolContent() (map[common.Hash]*txspool.TxPoolTransaction, map[common.Hash]*txspool.TxPoolTransaction)
func (*PtnApiBackend) Unlock ¶ added in v1.0.6
func (b *PtnApiBackend) Unlock()
func (*PtnApiBackend) UpdateJuryAccount ¶
func (b *PtnApiBackend) UpdateJuryAccount(addr common.Address, pwd string) bool
type PublicPalletOneAPI ¶
type PublicPalletOneAPI struct {
// contains filtered or unexported fields
}
PublicPalletOneAPI provides an API to access PalletOne full node-related information.
func NewPublicPalletOneAPI ¶
func NewPublicPalletOneAPI(p *PalletOne) *PublicPalletOneAPI
NewPublicPalletOneAPI creates a new PalletOne protocol API for full nodes.
func (*PublicPalletOneAPI) Coinbase ¶
func (api *PublicPalletOneAPI) Coinbase() (common.Address, error)
Coinbase is the address that mining rewards will be send to (alias for Etherbase)
func (*PublicPalletOneAPI) Hashrate ¶
func (api *PublicPalletOneAPI) Hashrate() hexutil.Uint64
Hashrate returns the POW hashrate
type StorageRangeResult ¶
type StorageRangeResult struct { Storage storageMap `json:"storage"` NextKey *common.Hash `json:"nextKey"` // nil if Storage includes the last key in the trie. }
StorageRangeResult is the result of a debug_storageRangeAt API call.
type TraceConfig ¶
TraceConfig holds extra parameters to trace functions.
type TransferPtnArgs ¶
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package downloader contains the manual full chain synchronization.
|
Package downloader contains the manual full chain synchronization. |
Package fetcher contains the block announcement based synchronization.
|
Package fetcher contains the block announcement based synchronization. |
Package filters implements an ethereum filtering system for block, transactions and log events.
|
Package filters implements an ethereum filtering system for block, transactions and log events. |
Package tracers is a collection of JavaScript transaction tracers.
|
Package tracers is a collection of JavaScript transaction tracers. |
internal/tracers
Package tracers contains the actual JavaScript tracer assets.
|
Package tracers contains the actual JavaScript tracer assets. |