cn

package

Go to main page

Versions in this module

v1

v1.2.0

Oct 21, 2019

Changes in this version

+ const MsgCodeEnd

+ type BlockChain interface

+ Config func() *params.ChainConfig

+ CurrentBlock func() *types.Block

+ CurrentFastBlock func() *types.Block

+ CurrentHeader func() *types.Header

+ FastSyncCommitHead func(hash common.Hash) error

+ Genesis func() *types.Block

+ GetBlock func(hash common.Hash, number uint64) *types.Block

+ GetBlockByHash func(hash common.Hash) *types.Block

+ GetBlockHashesFromHash func(hash common.Hash, max uint64) []common.Hash

+ GetBodyRLP func(hash common.Hash) rlp.RawValue

+ GetHeader func(hash common.Hash, number uint64) *types.Header

+ GetHeaderByHash func(hash common.Hash) *types.Header

+ GetHeaderByNumber func(number uint64) *types.Header

+ GetReceiptsByBlockHash func(blockHash common.Hash) types.Receipts

+ GetTd func(hash common.Hash, number uint64) *big.Int

+ GetTdByHash func(hash common.Hash) *big.Int

+ HasBlock func(hash common.Hash, number uint64) bool

+ HasHeader func(hash common.Hash, number uint64) bool

+ InsertChain func(chain types.Blocks) (int, error)

+ InsertHeaderChain func(chain []*types.Header, checkFreq int) (int, error)

+ InsertReceiptChain func(blockChain types.Blocks, receiptChain []types.Receipts) (int, error)

+ Rollback func(chain []common.Hash)

+ State func() (*state.StateDB, error)

+ TrieNode func(hash common.Hash) ([]byte, error)

+ type MockPeer struct

+ func NewMockPeer(ctrl *gomock.Controller) *MockPeer

+ func (m *MockPeer) AddToKnownBlocks(arg0 common.Hash)

+ func (m *MockPeer) AddToKnownTxs(arg0 common.Hash)

+ func (m *MockPeer) AsyncSendNewBlock(arg0 *types.Block, arg1 *big.Int)

+ func (m *MockPeer) AsyncSendNewBlockHash(arg0 *types.Block)

+ func (m *MockPeer) AsyncSendTransactions(arg0 types.Transactions)

+ func (m *MockPeer) Broadcast()

+ func (m *MockPeer) Close()

+ func (m *MockPeer) ConnType() p2p.ConnType

+ func (m *MockPeer) DisconnectP2PPeer(arg0 p2p.DiscReason)

+ func (m *MockPeer) EXPECT() *MockPeerMockRecorder

+ func (m *MockPeer) FetchBlockBodies(arg0 []common.Hash) error

+ func (m *MockPeer) FetchBlockHeader(arg0 common.Hash) error

+ func (m *MockPeer) GetAddr() common.Address

+ func (m *MockPeer) GetChainID() *big.Int

+ func (m *MockPeer) GetID() string

+ func (m *MockPeer) GetP2PPeer() *p2p.Peer

+ func (m *MockPeer) GetP2PPeerID() discover.NodeID

+ func (m *MockPeer) GetRW() p2p.MsgReadWriter

+ func (m *MockPeer) GetVersion() int

+ func (m *MockPeer) Handle(arg0 *ProtocolManager) error

+ func (m *MockPeer) Handshake(arg0 uint64, arg1, arg2 *big.Int, arg3, arg4 common.Hash) error

+ func (m *MockPeer) Head() (common.Hash, *big.Int)

+ func (m *MockPeer) Info() *PeerInfo

+ func (m *MockPeer) KnowsBlock(arg0 common.Hash) bool

+ func (m *MockPeer) KnowsTx(arg0 common.Hash) bool

+ func (m *MockPeer) ReSendTransactions(arg0 types.Transactions) error

+ func (m *MockPeer) RegisterConsensusMsgCode(arg0 uint64)

+ func (m *MockPeer) RequestBodies(arg0 []common.Hash) error

+ func (m *MockPeer) RequestHeadersByHash(arg0 common.Hash, arg1, arg2 int, arg3 bool) error

+ func (m *MockPeer) RequestHeadersByNumber(arg0 uint64, arg1, arg2 int, arg3 bool) error

+ func (m *MockPeer) RequestNodeData(arg0 []common.Hash) error

+ func (m *MockPeer) RequestReceipts(arg0 []common.Hash) error

+ func (m *MockPeer) Send(arg0 uint64, arg1 interface{}) error

+ func (m *MockPeer) SendBlockBodies(arg0 []*blockBody) error

+ func (m *MockPeer) SendBlockBodiesRLP(arg0 []rlp.RawValue) error

+ func (m *MockPeer) SendBlockHeaders(arg0 []*types.Header) error

+ func (m *MockPeer) SendFetchedBlockBodiesRLP(arg0 []rlp.RawValue) error

+ func (m *MockPeer) SendFetchedBlockHeader(arg0 *types.Header) error

+ func (m *MockPeer) SendNewBlock(arg0 *types.Block, arg1 *big.Int) error

+ func (m *MockPeer) SendNewBlockHashes(arg0 []common.Hash, arg1 []uint64) error

+ func (m *MockPeer) SendNodeData(arg0 [][]byte) error

+ func (m *MockPeer) SendReceiptsRLP(arg0 []rlp.RawValue) error

+ func (m *MockPeer) SendTransactions(arg0 types.Transactions) error

+ func (m *MockPeer) SetAddr(arg0 common.Address)

+ func (m *MockPeer) SetHead(arg0 common.Hash, arg1 *big.Int)

+ func (m *MockPeer) UpdateRWImplementationVersion()

+ type MockPeerMockRecorder struct

+ func (mr *MockPeerMockRecorder) AddToKnownBlocks(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) AddToKnownTxs(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) AsyncSendNewBlock(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) AsyncSendNewBlockHash(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) AsyncSendTransactions(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) Broadcast() *gomock.Call

+ func (mr *MockPeerMockRecorder) Close() *gomock.Call

+ func (mr *MockPeerMockRecorder) ConnType() *gomock.Call

+ func (mr *MockPeerMockRecorder) DisconnectP2PPeer(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) FetchBlockBodies(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) FetchBlockHeader(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) GetAddr() *gomock.Call

+ func (mr *MockPeerMockRecorder) GetChainID() *gomock.Call

+ func (mr *MockPeerMockRecorder) GetID() *gomock.Call

+ func (mr *MockPeerMockRecorder) GetP2PPeer() *gomock.Call

+ func (mr *MockPeerMockRecorder) GetP2PPeerID() *gomock.Call

+ func (mr *MockPeerMockRecorder) GetRW() *gomock.Call

+ func (mr *MockPeerMockRecorder) GetVersion() *gomock.Call

+ func (mr *MockPeerMockRecorder) Handle(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) Handshake(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) Head() *gomock.Call

+ func (mr *MockPeerMockRecorder) Info() *gomock.Call

+ func (mr *MockPeerMockRecorder) KnowsBlock(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) KnowsTx(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) ReSendTransactions(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) RegisterConsensusMsgCode(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) RequestBodies(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) RequestHeadersByHash(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) RequestHeadersByNumber(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) RequestNodeData(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) RequestReceipts(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendBlockBodies(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendBlockBodiesRLP(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendBlockHeaders(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendFetchedBlockBodiesRLP(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendFetchedBlockHeader(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendNewBlock(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendNewBlockHashes(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendNodeData(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendReceiptsRLP(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SendTransactions(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SetAddr(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) SetHead(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerMockRecorder) UpdateRWImplementationVersion() *gomock.Call

+ type MockPeerSet struct

+ func NewMockPeerSet(ctrl *gomock.Controller) *MockPeerSet

+ func (m *MockPeerSet) BestPeer() Peer

+ func (m *MockPeerSet) CNPeers() map[common.Address]Peer

+ func (m *MockPeerSet) CNWithoutTx(arg0 common.Hash) []Peer

+ func (m *MockPeerSet) Close()

+ func (m *MockPeerSet) ENPeers() map[common.Address]Peer

+ func (m *MockPeerSet) EXPECT() *MockPeerSetMockRecorder

+ func (m *MockPeerSet) Len() int

+ func (m *MockPeerSet) PNPeers() map[common.Address]Peer

+ func (m *MockPeerSet) Peer(arg0 string) Peer

+ func (m *MockPeerSet) Peers() map[string]Peer

+ func (m *MockPeerSet) PeersWithoutBlock(arg0 common.Hash) []Peer

+ func (m *MockPeerSet) PeersWithoutTx(arg0 common.Hash) []Peer

+ func (m *MockPeerSet) Register(arg0 Peer) error

+ func (m *MockPeerSet) RegisterValidator(arg0 p2p.ConnType, arg1 p2p.PeerTypeValidator)

+ func (m *MockPeerSet) SamplePeersToSendBlock(arg0 *types.Block, arg1 p2p.ConnType) []Peer

+ func (m *MockPeerSet) SampleResendPeersByType(arg0 p2p.ConnType) []Peer

+ func (m *MockPeerSet) TypePeersWithoutTx(arg0 common.Hash, arg1 p2p.ConnType) []Peer

+ func (m *MockPeerSet) Unregister(arg0 string) error

+ func (m *MockPeerSet) UpdateTypePeersWithoutTxs(arg0 *types.Transaction, arg1 p2p.ConnType, arg2 map[Peer]types.Transactions)

+ type MockPeerSetMockRecorder struct

+ func (mr *MockPeerSetMockRecorder) BestPeer() *gomock.Call

+ func (mr *MockPeerSetMockRecorder) CNPeers() *gomock.Call

+ func (mr *MockPeerSetMockRecorder) CNWithoutTx(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) Close() *gomock.Call

+ func (mr *MockPeerSetMockRecorder) ENPeers() *gomock.Call

+ func (mr *MockPeerSetMockRecorder) Len() *gomock.Call

+ func (mr *MockPeerSetMockRecorder) PNPeers() *gomock.Call

+ func (mr *MockPeerSetMockRecorder) Peer(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) Peers() *gomock.Call

+ func (mr *MockPeerSetMockRecorder) PeersWithoutBlock(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) PeersWithoutTx(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) Register(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) RegisterValidator(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) SamplePeersToSendBlock(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) SampleResendPeersByType(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) TypePeersWithoutTx(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) Unregister(arg0 interface{}) *gomock.Call

+ func (mr *MockPeerSetMockRecorder) UpdateTypePeersWithoutTxs(arg0, arg1, arg2 interface{}) *gomock.Call

type Peer

+ DisconnectP2PPeer func(discReason p2p.DiscReason)

+ type PeerSet interface

+ BestPeer func() Peer

+ CNPeers func() map[common.Address]Peer

+ CNWithoutTx func(hash common.Hash) []Peer

+ Close func()

+ ENPeers func() map[common.Address]Peer

+ Len func() int

+ PNPeers func() map[common.Address]Peer

+ Peer func(id string) Peer

+ Peers func() map[string]Peer

+ PeersWithoutBlock func(hash common.Hash) []Peer

+ PeersWithoutTx func(hash common.Hash) []Peer

+ Register func(p Peer) error

+ RegisterValidator func(connType p2p.ConnType, validator p2p.PeerTypeValidator)

+ SamplePeersToSendBlock func(block *types.Block, nodeType p2p.ConnType) []Peer

+ SampleResendPeersByType func(nodeType p2p.ConnType) []Peer

+ TypePeersWithoutTx func(hash common.Hash, nodetype p2p.ConnType) []Peer

+ Unregister func(id string) error

+ UpdateTypePeersWithoutTxs func(tx *types.Transaction, nodeType p2p.ConnType, ...)

+ type ProtocolManagerFetcher interface

+ Enqueue func(peer string, block *types.Block) error

+ FilterBodies func(peer string, transactions [][]*types.Transaction, time time.Time) [][]*types.Transaction

+ FilterHeaders func(peer string, headers []*types.Header, time time.Time) []*types.Header

+ Notify func(peer string, hash common.Hash, number uint64, time time.Time, ...) error

+ Start func()

+ Stop func()

+ type TxPool interface

+ CachedPendingTxsByCount func(count int) types.Transactions

+ HandleTxMsg func(types.Transactions)

+ Pending func() (map[common.Address]types.Transactions, error)

+ SubscribeNewTxsEvent func(chan<- blockchain.NewTxsEvent) event.Subscription

v1.2.0-rc.1

Sep 17, 2019

v1.1.1

Aug 21, 2019

Changes in this version

type Config

+ ParentOperatorAddr *common.Address

v1.1.0

Aug 14, 2019

Changes in this version

type CN

+ func (s *CN) Progress() klaytn.SyncProgress

type CNAPIBackend

+ func (b *CNAPIBackend) Progress() klaytn.SyncProgress

type ServiceChain

+ func (s *ServiceChain) Progress() klaytn.SyncProgress

type ServiceChainAPIBackend

+ func (b *ServiceChainAPIBackend) Progress() klaytn.SyncProgress

+ type StakingHandler interface

+ GetStakingManager func() *reward.StakingManager

+ SetStakingManager func(manager *reward.StakingManager)

v1.0.0

Jun 25, 2019

Changes in this version

+ const BlockBodiesFetchRequestMsg

+ const BlockBodiesFetchResponseMsg

+ const BlockBodiesMsg

+ const BlockBodiesRequestMsg

+ const BlockChannel

+ const BlockHeaderFetchRequestMsg

+ const BlockHeaderFetchResponseMsg

+ const BlockHeadersMsg

+ const BlockHeadersRequestMsg

+ const ConsensusChannel

+ const DefaultMaxResendTxCount

+ const DefaultTxResendInterval

+ const ErrChainIDMismatch

+ const ErrDecode

+ const ErrExtraStatusMsg

+ const ErrFailedToGetStateDB

+ const ErrGenesisBlockMismatch

+ const ErrInvalidMsgCode

+ const ErrMsgTooLarge

+ const ErrNetworkIdMismatch

+ const ErrNoStatusMsg

+ const ErrProtocolVersionMismatch

+ const ErrSuspendedPeer

+ const ErrUnexpectedTxType

+ const MaxChannel

+ const MiscChannel

+ const NewBlockHashesMsg

+ const NewBlockMsg

+ const NodeDataMsg

+ const NodeDataRequestMsg

+ const ProtocolMaxMsgSize

+ const ReceiptsMsg

+ const ReceiptsRequestMsg

+ const StatusMsg

+ const TxChannel

+ const TxMsg

+ var ChannelOfMessage = map[uint64]int

+ var ConcurrentOfChannel = []int

+ var DefaultConfig = Config

+ var ProtocolLengths = []uint64

+ var ProtocolName = "klay"

+ var ProtocolVersions = []uint

+ func CreateCliqueEngine(ctx *node.ServiceContext, config *Config, chainConfig *params.ChainConfig, ...) consensus.Engine

+ func CreateConsensusEngine(ctx *node.ServiceContext, config *Config, chainConfig *params.ChainConfig, ...) consensus.Engine

+ func CreateDB(ctx *node.ServiceContext, config *Config, name string) database.DBManager

+ func NewBloomIndexer(db database.DBManager, size uint64) *blockchain.ChainIndexer

+ type BloomIndexer struct

+ func (b *BloomIndexer) Commit() error

+ func (b *BloomIndexer) Process(header *types.Header)

+ func (b *BloomIndexer) Reset(section uint64, lastSectionHead common.Hash) error

+ type ByPassValidator struct

+ func (v ByPassValidator) ValidatePeerType(addr common.Address) error

+ type CN struct

+ APIBackend *CNAPIBackend

+ func New(ctx *node.ServiceContext, config *Config) (*CN, error)

+ func (s *CN) APIs() []rpc.API

+ func (s *CN) AccountManager() *accounts.Manager

+ func (s *CN) AddLesServer(ls LesServer)

+ func (s *CN) BlockChain() *blockchain.BlockChain

+ func (s *CN) ChainDB() database.DBManager

+ func (s *CN) Components() []interface{}

+ func (s *CN) Downloader() *downloader.Downloader

+ func (s *CN) Engine() consensus.Engine

+ func (s *CN) EventMux() *event.TypeMux

+ func (s *CN) IsListening() bool

+ func (s *CN) IsMining() bool

+ func (s *CN) Miner() *work.Miner

+ func (s *CN) NetVersion() uint64

+ func (s *CN) ProtocolVersion() int

+ func (s *CN) Protocols() []p2p.Protocol

+ func (s *CN) ReBroadcastTxs(transactions types.Transactions)

+ func (s *CN) ResetWithGenesisBlock(gb *types.Block)

+ func (s *CN) Rewardbase() (eb common.Address, err error)

+ func (s *CN) RewardbaseWallet() (accounts.Wallet, error)

+ func (s *CN) SetComponents(component []interface{})

+ func (s *CN) SetRewardbase(rewardbase common.Address)

+ func (s *CN) Start(srvr p2p.Server) error

+ func (s *CN) StartMining(local bool) error

+ func (s *CN) Stop() error

+ func (s *CN) StopMining()

+ func (s *CN) TxPool() *blockchain.TxPool

+ type CNAPIBackend struct

+ func (b *CNAPIBackend) AccountManager() *accounts.Manager

+ func (b *CNAPIBackend) BlockByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*types.Block, error)

+ func (b *CNAPIBackend) BloomStatus() (uint64, uint64)

+ func (b *CNAPIBackend) ChainConfig() *params.ChainConfig

+ func (b *CNAPIBackend) ChainDB() database.DBManager

+ func (b *CNAPIBackend) CurrentBlock() *types.Block

+ func (b *CNAPIBackend) Downloader() *downloader.Downloader

+ func (b *CNAPIBackend) EventMux() *event.TypeMux

+ func (b *CNAPIBackend) GetBlock(ctx context.Context, hash common.Hash) (*types.Block, error)

+ func (b *CNAPIBackend) GetBlockReceipts(ctx context.Context, hash common.Hash) types.Receipts

+ func (b *CNAPIBackend) GetBlockReceiptsInCache(blockHash common.Hash) types.Receipts

+ func (b *CNAPIBackend) GetEVM(ctx context.Context, msg blockchain.Message, state *state.StateDB, ...) (*vm.EVM, func() error, error)

+ func (b *CNAPIBackend) GetLogs(ctx context.Context, hash common.Hash) ([][]*types.Log, error)

+ func (b *CNAPIBackend) GetNonceInCache(addr common.Address) (uint64, bool)

+ func (b *CNAPIBackend) GetPoolNonce(ctx context.Context, addr common.Address) uint64

+ func (b *CNAPIBackend) GetPoolTransaction(hash common.Hash) *types.Transaction

+ func (b *CNAPIBackend) GetPoolTransactions() (types.Transactions, error)

+ func (b *CNAPIBackend) GetTd(blockHash common.Hash) *big.Int

+ func (b *CNAPIBackend) GetTxAndLookupInfo(hash common.Hash) (*types.Transaction, common.Hash, uint64, uint64)

+ func (b *CNAPIBackend) GetTxAndLookupInfoInCache(txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64)

+ func (b *CNAPIBackend) GetTxLookupInfoAndReceipt(ctx context.Context, txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, *types.Receipt)

+ func (b *CNAPIBackend) GetTxLookupInfoAndReceiptInCache(txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, *types.Receipt)

+ func (b *CNAPIBackend) HeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*types.Header, error)

+ func (b *CNAPIBackend) IsParallelDBWrite() bool

+ func (b *CNAPIBackend) IsSenderTxHashIndexingEnabled() bool

+ func (b *CNAPIBackend) ProtocolVersion() int

+ func (b *CNAPIBackend) SendTx(ctx context.Context, signedTx *types.Transaction) error

+ func (b *CNAPIBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)

+ func (b *CNAPIBackend) SetHead(number uint64)

+ func (b *CNAPIBackend) StateAndHeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*state.StateDB, *types.Header, error)

+ func (b *CNAPIBackend) Stats() (pending int, queued int)

+ func (b *CNAPIBackend) SubscribeChainEvent(ch chan<- blockchain.ChainEvent) event.Subscription

+ func (b *CNAPIBackend) SubscribeChainHeadEvent(ch chan<- blockchain.ChainHeadEvent) event.Subscription

+ func (b *CNAPIBackend) SubscribeChainSideEvent(ch chan<- blockchain.ChainSideEvent) event.Subscription

+ func (b *CNAPIBackend) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

+ func (b *CNAPIBackend) SubscribeNewTxsEvent(ch chan<- blockchain.NewTxsEvent) event.Subscription

+ func (b *CNAPIBackend) SubscribeRemovedLogsEvent(ch chan<- blockchain.RemovedLogsEvent) event.Subscription

+ func (b *CNAPIBackend) SuggestPrice(ctx context.Context) (*big.Int, error)

+ func (b *CNAPIBackend) TxPoolContent() (map[common.Address]types.Transactions, map[common.Address]types.Transactions)

+ type ChannelManager struct

+ func NewChannelManager(channelSize int) *ChannelManager

+ func (cm *ChannelManager) GetChannelWithMsgCode(idx int, msgCode uint64) (chan p2p.Msg, error)

+ func (cm *ChannelManager) RegisterChannelWithIndex(idx int, channelId uint, channel chan p2p.Msg)

+ func (cm *ChannelManager) RegisterMsgCode(channelId uint, msgCode uint64)

+ type Config struct

+ AnchoringPeriod uint64

+ DocRoot string

+ EnablePreimageRecording bool

+ ExtraData []byte

+ GPO gasprice.Config

+ GasPrice *big.Int

+ Genesis *blockchain.Genesis

+ IsPrivate bool

+ Istanbul istanbul.Config

+ LevelDBBufferPool bool

+ LevelDBCacheSize int

+ LevelDBCompression database.LevelDBCompressionType

+ MainChainAccountAddr *common.Address

+ NetworkId uint64

+ NoAccountCreation bool

+ NoPruning bool

+ NumStateTriePartitions uint

+ ParallelDBWrite bool

+ PartitionedDB bool

+ Rewardbase common.Address

+ SenderTxHashIndexing bool

+ SentChainTxsLimit uint64

+ ServiceChainSigner common.Address

+ SkipBcVersionCheck bool

+ StateDBCaching bool

+ SyncMode downloader.SyncMode

+ TrieBlockInterval uint

+ TrieCacheLimit int

+ TrieCacheSize int

+ TrieTimeout time.Duration

+ TxPool blockchain.TxPoolConfig

+ TxPoolStateCache bool

+ TxResendCount int

+ TxResendInterval uint64

+ TxResendUseLegacy bool

+ WsEndpoint string

+ func (c *Config) UnmarshalTOML(unmarshal func(interface{}) error) error

+ func (c Config) MarshalTOML() (interface{}, error)

+ type EmptyTxPool struct

+ func (re *EmptyTxPool) AddRemotes([]*types.Transaction) []error

+ func (re *EmptyTxPool) Pending() (map[common.Address]types.Transactions, error)

+ func (re *EmptyTxPool) SubscribeNewTxsEvent(newtxch chan<- blockchain.NewTxsEvent) event.Subscription

+ type LesServer interface

+ Protocols func() []p2p.Protocol

+ SetBloomBitsIndexer func(bbIndexer *blockchain.ChainIndexer)

+ Start func(srvr p2p.Server)

+ Stop func()

+ type NodeInfo struct

+ BlockScore *big.Int

+ Config *params.ChainConfig

+ Genesis common.Hash

+ Head common.Hash

+ Network uint64

+ type Peer interface

+ AddToKnownBlocks func(hash common.Hash)

+ AddToKnownTxs func(hash common.Hash)

+ AsyncSendNewBlock func(block *types.Block, td *big.Int)

+ AsyncSendNewBlockHash func(block *types.Block)

+ AsyncSendTransactions func(txs []*types.Transaction)

+ Broadcast func()

+ Close func()

+ ConnType func() p2p.ConnType

+ FetchBlockBodies func(hashes []common.Hash) error

+ FetchBlockHeader func(hash common.Hash) error

+ GetAddr func() common.Address

+ GetChainID func() *big.Int

+ GetID func() string

+ GetP2PPeer func() *p2p.Peer

+ GetP2PPeerID func() discover.NodeID

+ GetRW func() p2p.MsgReadWriter

+ GetVersion func() int

+ Handle func(pm *ProtocolManager) error

+ Handshake func(network uint64, chainID, td *big.Int, head common.Hash, genesis common.Hash) error

+ Info func() *PeerInfo

+ KnowsBlock func(hash common.Hash) bool

+ KnowsTx func(hash common.Hash) bool

+ ReSendTransactions func(txs types.Transactions) error

+ RegisterConsensusMsgCode func(msgCode uint64)

+ Send func(msgcode uint64, data interface{}) error

+ SendBlockBodies func(bodies []*blockBody) error

+ SendBlockBodiesRLP func(bodies []rlp.RawValue) error

+ SendBlockHeaders func(headers []*types.Header) error

+ SendFetchedBlockBodiesRLP func(bodies []rlp.RawValue) error

+ SendFetchedBlockHeader func(header *types.Header) error

+ SendNewBlock func(block *types.Block, td *big.Int) error

+ SendNewBlockHashes func(hashes []common.Hash, numbers []uint64) error

+ SendNodeData func(data [][]byte) error

+ SendReceiptsRLP func(receipts []rlp.RawValue) error

+ SendTransactions func(txs types.Transactions) error

+ SetAddr func(addr common.Address)

+ SetHead func(hash common.Hash, td *big.Int)

+ UpdateRWImplementationVersion func()

+ type PeerInfo struct

+ BlockScore *big.Int

+ Head string

+ Version int

+ type PrivateAdminAPI struct

+ func NewPrivateAdminAPI(cn *CN) *PrivateAdminAPI

+ func (api *PrivateAdminAPI) ExportChain(file string) (bool, error)

+ func (api *PrivateAdminAPI) ImportChain(file string) (bool, error)

+ type PrivateDebugAPI struct

+ func NewPrivateDebugAPI(config *params.ChainConfig, cn *CN) *PrivateDebugAPI

+ func (api *PrivateDebugAPI) GetBadBlocks(ctx context.Context) ([]blockchain.BadBlockArgs, error)

+ func (api *PrivateDebugAPI) GetModifiedAccountsByHash(startHash common.Hash, endHash *common.Hash) ([]common.Address, error)

+ func (api *PrivateDebugAPI) GetModifiedAccountsByNumber(startNum uint64, endNum *uint64) ([]common.Address, error)

+ func (api *PrivateDebugAPI) Preimage(ctx context.Context, hash common.Hash) (hexutil.Bytes, error)

+ func (api *PrivateDebugAPI) StandardTraceBadBlockToFile(ctx context.Context, hash common.Hash, config *StdTraceConfig) ([]string, error)

+ func (api *PrivateDebugAPI) StandardTraceBlockToFile(ctx context.Context, hash common.Hash, config *StdTraceConfig) ([]string, error)

+ func (api *PrivateDebugAPI) TraceBadBlock(ctx context.Context, hash common.Hash, config *TraceConfig) ([]*txTraceResult, error)

+ func (api *PrivateDebugAPI) TraceBlock(ctx context.Context, blob hexutil.Bytes, 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 PrivateMinerAPI struct

+ func NewPrivateMinerAPI(e *CN) *PrivateMinerAPI

+ func (api *PrivateMinerAPI) GetHashrate() uint64

+ func (api *PrivateMinerAPI) SetExtra(extra string) (bool, error)

+ func (api *PrivateMinerAPI) SetGasPrice(gasPrice hexutil.Big) bool

+ func (api *PrivateMinerAPI) SetRewardbase(rewardbase common.Address) bool

+ func (api *PrivateMinerAPI) Start(threads *int) error

+ func (api *PrivateMinerAPI) Stop() bool

+ type PrivateServiceChainAdminAPI struct

+ func NewPrivateServiceChainAdminAPI(sc *ServiceChain) *PrivateServiceChainAdminAPI

+ func (api *PrivateServiceChainAdminAPI) ExportChain(file string) (bool, error)

+ func (api *PrivateServiceChainAdminAPI) ImportChain(file string) (bool, error)

+ type PrivateServiceChainDebugAPI struct

+ func NewPrivateServiceChainDebugAPI(config *params.ChainConfig, sc *ServiceChain) *PrivateServiceChainDebugAPI

+ func (api *PrivateServiceChainDebugAPI) GetBadBlocks(ctx context.Context) ([]blockchain.BadBlockArgs, error)

+ func (api *PrivateServiceChainDebugAPI) GetModifiedAccountsByHash(startHash common.Hash, endHash *common.Hash) ([]common.Address, error)

+ func (api *PrivateServiceChainDebugAPI) GetModifiedAccountsByNumber(startNum uint64, endNum *uint64) ([]common.Address, error)

+ func (api *PrivateServiceChainDebugAPI) Preimage(ctx context.Context, hash common.Hash) (hexutil.Bytes, error)

+ type PrivateServiceChainMinerAPI struct

+ func NewPrivateServiceChainMinerAPI(e *ServiceChain) *PrivateServiceChainMinerAPI

+ func (api *PrivateServiceChainMinerAPI) GetHashrate() uint64

+ func (api *PrivateServiceChainMinerAPI) SetExtra(extra string) (bool, error)

+ func (api *PrivateServiceChainMinerAPI) SetGasPrice(gasPrice hexutil.Big) bool

+ func (api *PrivateServiceChainMinerAPI) Start(threads *int) error

+ func (api *PrivateServiceChainMinerAPI) Stop() bool

+ type ProtocolManager struct

+ SubProtocols []p2p.Protocol

+ func NewProtocolManager(config *params.ChainConfig, mode downloader.SyncMode, networkId uint64, ...) (*ProtocolManager, error)

+ func (pm *ProtocolManager) BroadcastBlock(block *types.Block)

+ func (pm *ProtocolManager) BroadcastBlockHash(block *types.Block)

+ func (pm *ProtocolManager) BroadcastTxs(txs types.Transactions)

+ func (pm *ProtocolManager) Enqueue(id string, block *types.Block)

+ func (pm *ProtocolManager) FindCNPeers(targets map[common.Address]bool) map[common.Address]consensus.Peer

+ func (pm *ProtocolManager) FindPeers(targets map[common.Address]bool) map[common.Address]consensus.Peer

+ func (pm *ProtocolManager) GetCNPeers() map[common.Address]consensus.Peer

+ func (pm *ProtocolManager) GetENPeers() map[common.Address]consensus.Peer

+ func (pm *ProtocolManager) GetPeers() []common.Address

+ func (pm *ProtocolManager) NodeInfo() *NodeInfo

+ func (pm *ProtocolManager) ReBroadcastTxs(txs types.Transactions)

+ func (pm *ProtocolManager) RegisterValidator(conType p2p.ConnType, validator p2p.PeerTypeValidator)

+ func (pm *ProtocolManager) SetRewardbase(addr common.Address)

+ func (pm *ProtocolManager) SetRewardbaseWallet(wallet accounts.Wallet)

+ func (pm *ProtocolManager) Start(maxPeers int)

+ func (pm *ProtocolManager) Stop()

+ type PublicDebugAPI struct

+ func NewPublicDebugAPI(cn *CN) *PublicDebugAPI

+ func (api *PublicDebugAPI) DumpBlock(blockNr rpc.BlockNumber) (state.Dump, error)

+ type PublicKlayAPI struct

+ func NewPublicKlayAPI(e *CN) *PublicKlayAPI

+ func (api *PublicKlayAPI) Hashrate() hexutil.Uint64

+ func (api *PublicKlayAPI) Rewardbase() (common.Address, error)

+ type PublicKlayServiceChainAPI struct

+ func NewPublicKlayServiceChainAPI(sc *ServiceChain) *PublicKlayServiceChainAPI

+ func (api *PublicKlayServiceChainAPI) Hashrate() hexutil.Uint64

+ func (api *PublicKlayServiceChainAPI) Signer() (common.Address, error)

+ type PublicMinerAPI struct

+ func NewPublicMinerAPI(e *CN) *PublicMinerAPI

+ func (api *PublicMinerAPI) GetWork() ([3]string, error)

+ func (api *PublicMinerAPI) Mining() bool

+ func (api *PublicMinerAPI) SubmitHashrate(hashrate hexutil.Uint64, id common.Hash) bool

+ func (api *PublicMinerAPI) SubmitWork(solution common.Hash) bool

+ type PublicServiceChainDebugAPI struct

+ func NewPublicServiceChainDebugAPI(sc *ServiceChain) *PublicServiceChainDebugAPI

+ func (api *PublicServiceChainDebugAPI) DumpBlock(blockNr rpc.BlockNumber) (state.Dump, error)

+ type PublicServiceChainMinerAPI struct

+ func NewPublicServiceChainMinerAPI(e *ServiceChain) *PublicServiceChainMinerAPI

+ func (api *PublicServiceChainMinerAPI) GetWork() ([3]string, error)

+ func (api *PublicServiceChainMinerAPI) Mining() bool

+ func (api *PublicServiceChainMinerAPI) SubmitWork(solution common.Hash) bool

+ type ServiceChain struct

+ APIBackend *ServiceChainAPIBackend

+ func NewServiceChain(ctx *node.ServiceContext, config *Config) (*ServiceChain, error)

+ func (s *ServiceChain) APIs() []rpc.API

+ func (s *ServiceChain) AccountManager() *accounts.Manager

+ func (s *ServiceChain) BlockChain() *blockchain.BlockChain

+ func (s *ServiceChain) ChainDB() database.DBManager

+ func (s *ServiceChain) Components() []interface{}

+ func (s *ServiceChain) Downloader() *downloader.Downloader

+ func (s *ServiceChain) Engine() consensus.Engine

+ func (s *ServiceChain) EventMux() *event.TypeMux

+ func (s *ServiceChain) IsListening() bool

+ func (s *ServiceChain) IsMining() bool

+ func (s *ServiceChain) Miner() *work.Miner

+ func (s *ServiceChain) NetVersion() uint64

+ func (s *ServiceChain) ProtocolVersion() int

+ func (s *ServiceChain) Protocols() []p2p.Protocol

+ func (s *ServiceChain) ReBroadcastTxs(transactions types.Transactions)

+ func (s *ServiceChain) ResetWithGenesisBlock(gb *types.Block)

+ func (s *ServiceChain) SetComponents(component []interface{})

+ func (s *ServiceChain) Signer() (eb common.Address, err error)

+ func (s *ServiceChain) Start(srvr p2p.Server) error

+ func (s *ServiceChain) StartMining(local bool) error

+ func (s *ServiceChain) Stop() error

+ func (s *ServiceChain) StopMining()

+ func (s *ServiceChain) TxPool() *blockchain.TxPool

+ type ServiceChainAPIBackend struct

+ func (b *ServiceChainAPIBackend) AccountManager() *accounts.Manager

+ func (b *ServiceChainAPIBackend) BlockByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*types.Block, error)

+ func (b *ServiceChainAPIBackend) BloomStatus() (uint64, uint64)

+ func (b *ServiceChainAPIBackend) ChainConfig() *params.ChainConfig

+ func (b *ServiceChainAPIBackend) ChainDB() database.DBManager

+ func (b *ServiceChainAPIBackend) CurrentBlock() *types.Block

+ func (b *ServiceChainAPIBackend) Downloader() *downloader.Downloader

+ func (b *ServiceChainAPIBackend) EventMux() *event.TypeMux

+ func (b *ServiceChainAPIBackend) GetBlock(ctx context.Context, hash common.Hash) (*types.Block, error)

+ func (b *ServiceChainAPIBackend) GetBlockReceipts(ctx context.Context, hash common.Hash) types.Receipts

+ func (b *ServiceChainAPIBackend) GetBlockReceiptsInCache(blockHash common.Hash) types.Receipts

+ func (b *ServiceChainAPIBackend) GetEVM(ctx context.Context, msg blockchain.Message, state *state.StateDB, ...) (*vm.EVM, func() error, error)

+ func (b *ServiceChainAPIBackend) GetLogs(ctx context.Context, hash common.Hash) ([][]*types.Log, error)

+ func (b *ServiceChainAPIBackend) GetNonceInCache(addr common.Address) (uint64, bool)

+ func (b *ServiceChainAPIBackend) GetPoolNonce(ctx context.Context, addr common.Address) uint64

+ func (b *ServiceChainAPIBackend) GetPoolTransaction(hash common.Hash) *types.Transaction

+ func (b *ServiceChainAPIBackend) GetPoolTransactions() (types.Transactions, error)

+ func (b *ServiceChainAPIBackend) GetTd(blockHash common.Hash) *big.Int

+ func (b *ServiceChainAPIBackend) GetTxAndLookupInfo(hash common.Hash) (*types.Transaction, common.Hash, uint64, uint64)

+ func (b *ServiceChainAPIBackend) GetTxAndLookupInfoInCache(txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64)

+ func (b *ServiceChainAPIBackend) GetTxLookupInfoAndReceipt(ctx context.Context, txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, *types.Receipt)

+ func (b *ServiceChainAPIBackend) GetTxLookupInfoAndReceiptInCache(txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, *types.Receipt)

+ func (b *ServiceChainAPIBackend) HeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*types.Header, error)

+ func (b *ServiceChainAPIBackend) IsParallelDBWrite() bool

+ func (b *ServiceChainAPIBackend) IsSenderTxHashIndexingEnabled() bool

+ func (b *ServiceChainAPIBackend) ProtocolVersion() int

+ func (b *ServiceChainAPIBackend) SendTx(ctx context.Context, signedTx *types.Transaction) error

+ func (b *ServiceChainAPIBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)

+ func (b *ServiceChainAPIBackend) SetHead(number uint64)

+ func (b *ServiceChainAPIBackend) StateAndHeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*state.StateDB, *types.Header, error)

+ func (b *ServiceChainAPIBackend) Stats() (pending int, queued int)

+ func (b *ServiceChainAPIBackend) SubscribeChainEvent(ch chan<- blockchain.ChainEvent) event.Subscription

+ func (b *ServiceChainAPIBackend) SubscribeChainHeadEvent(ch chan<- blockchain.ChainHeadEvent) event.Subscription

+ func (b *ServiceChainAPIBackend) SubscribeChainSideEvent(ch chan<- blockchain.ChainSideEvent) event.Subscription

+ func (b *ServiceChainAPIBackend) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

+ func (b *ServiceChainAPIBackend) SubscribeNewTxsEvent(ch chan<- blockchain.NewTxsEvent) event.Subscription

+ func (b *ServiceChainAPIBackend) SubscribeRemovedLogsEvent(ch chan<- blockchain.RemovedLogsEvent) event.Subscription

+ func (b *ServiceChainAPIBackend) SuggestPrice(ctx context.Context) (*big.Int, error)

+ func (b *ServiceChainAPIBackend) TxPoolContent() (map[common.Address]types.Transactions, map[common.Address]types.Transactions)

+ type StdTraceConfig struct

+ Reexec *uint64

+ TxHash common.Hash

+ type StorageRangeResult struct

+ NextKey *common.Hash

+ Storage storageMap

+ type TraceConfig struct

+ Reexec *uint64

+ Timeout *string

+ Tracer *string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL