Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

work

package

Go to main page

Versions in this module

v1

v1.0.3

Sep 26, 2024

v1.0.3-rc.3

Sep 26, 2024

v1.0.3-rc.2

Sep 24, 2024

v1.0.3-rc.1

Sep 20, 2024

v1.0.2

Aug 19, 2024

v1.0.2-rc.2

Aug 19, 2024

v1.0.2-rc.1

Aug 9, 2024

v1.0.1

Jul 18, 2024

Changes in this version

+ var ResultChGauge = metrics.NewRegisteredGauge("miner/resultch", nil)

+ type Agent interface

+ GetHashRate func() int64

+ SetReturnCh func(chan<- *Result)

+ Start func()

+ Stop func()

+ Work func() chan<- *Task

+ type Backend interface

+ AccountManager func() accounts.AccountManager

+ BlockChain func() BlockChain

+ ChainDB func() database.DBManager

+ ReBroadcastTxs func(transactions types.Transactions)

+ TxPool func() TxPool

+ type BlockChain interface

+ ApplyTransaction func(config *params.ChainConfig, author *common.Address, statedb *state.StateDB, ...) (*types.Receipt, *vm.InternalTxTrace, error)

+ BadBlocks func() ([]blockchain.BadBlockArgs, error)

+ BlockSubscriptionLoop func(pool *blockchain.TxPool)

+ CloseBlockSubscriptionLoop func()

+ Config func() *params.ChainConfig

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

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

+ CurrentBlock func() *types.Block

+ CurrentBlockUpdateLoop func(pool *blockchain.TxPool)

+ CurrentFastBlock func() *types.Block

+ CurrentHeader func() *types.Header

+ Engine func() consensus.Engine

+ Export func(w io.Writer) error

+ ExportN func(w io.Writer, first, last uint64) error

+ 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

+ GetBlockByNumber func(number uint64) *types.Block

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

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

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

+ GetContractStorageRoot func(block *types.Block, db state.Database, contractAddr common.Address) (common.ExtHash, error)

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

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

+ GetHeaderByNumber func(number uint64) *types.Header

+ GetLogsByHash func(hash common.Hash) [][]*types.Log

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

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

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

+ GetTxAndLookupInfo func(txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64)

+ GetTxAndLookupInfoInCache func(hash common.Hash) (*types.Transaction, common.Hash, uint64, uint64)

+ GetTxLookupInfoAndReceipt func(txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, *types.Receipt)

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

+ HasBadBlock func(hash common.Hash) bool

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

+ IsParallelDBWrite func() bool

+ IsSenderTxHashIndexingEnabled func() bool

+ PostChainEvents func(events []interface{}, logs []*types.Log)

+ PrepareStateMigration func() error

+ Processor func() blockchain.Processor

+ PrunableStateAt func(root common.Hash, num uint64) (*state.StateDB, error)

+ ResetWithGenesisBlock func(gb *types.Block) error

+ Rollback func(chain []common.Hash)

+ SaveTrieNodeCacheToDisk func() error

+ SetHead func(head uint64) error

+ Snapshots func() *snapshot.Tree

+ StartCollectingTrieStats func(contractAddr common.Address) error

+ StartContractWarmUp func(contractAddr common.Address, minLoad uint) error

+ StartStateMigration func(uint64, common.Hash) error

+ StartWarmUp func(minLoad uint) error

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

+ StateAt func(root common.Hash) (*state.StateDB, error)

+ StateAtWithGCLock func(root common.Hash) (*state.StateDB, error)

+ StateAtWithPersistent func(root common.Hash) (*state.StateDB, error)

+ StateCache func() state.Database

+ StateMigrationStatus func() (bool, uint64, int, int, int, float64, error)

+ Stop func()

+ StopStateMigration func() error

+ StopWarmUp func() error

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

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

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

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

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

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

+ Validator func() blockchain.Validator

+ WriteBlockWithState func(block *types.Block, receipts []*types.Receipt, stateDB *state.StateDB) (blockchain.WriteResult, error)

+ type CpuAgent struct

+ func NewCpuAgent(chain consensus.ChainReader, engine consensus.Engine, nodetype common.ConnType) *CpuAgent

+ func (self *CpuAgent) GetHashRate() int64

+ func (self *CpuAgent) SetReturnCh(ch chan<- *Result)

+ func (self *CpuAgent) Start()

+ func (self *CpuAgent) Stop()

+ func (self *CpuAgent) Work() chan<- *Task

+ type FakeWorker struct

+ func NewFakeWorker() *FakeWorker

+ func (*FakeWorker) HashRate() (tot int64)

+ func (*FakeWorker) Mining() bool

+ func (*FakeWorker) Pending() (*types.Block, *state.StateDB)

+ func (*FakeWorker) PendingBlock() *types.Block

+ func (*FakeWorker) Register(Agent)

+ func (*FakeWorker) SetExtra([]byte) error

+ func (*FakeWorker) Start()

+ func (*FakeWorker) Stop()

+ type Miner struct

+ func New(backend Backend, config *params.ChainConfig, mux *event.TypeMux, ...) *Miner

+ func (self *Miner) HashRate() (tot int64)

+ func (self *Miner) Mining() bool

+ func (self *Miner) Pending() (*types.Block, *state.StateDB)

+ func (self *Miner) PendingBlock() *types.Block

+ func (self *Miner) Register(agent Agent)

+ func (self *Miner) SetExtra(extra []byte) error

+ func (self *Miner) Start()

+ func (self *Miner) Stop()

+ func (self *Miner) Unregister(agent Agent)

+ type RemoteAgent struct

+ func NewRemoteAgent(chain consensus.ChainReader, engine consensus.Engine) *RemoteAgent

+ func (a *RemoteAgent) GetHashRate() (tot int64)

+ func (a *RemoteAgent) GetWork() ([3]string, error)

+ func (a *RemoteAgent) SetReturnCh(returnCh chan<- *Result)

+ func (a *RemoteAgent) Start()

+ func (a *RemoteAgent) Stop()

+ func (a *RemoteAgent) SubmitHashrate(id common.Hash, rate uint64)

+ func (a *RemoteAgent) SubmitWork(hash common.Hash) bool

+ func (a *RemoteAgent) Work() chan<- *Task

+ type Result struct

+ Block *types.Block

+ Task *Task

+ type Task struct

+ Block *types.Block

+ func NewTask(config *params.ChainConfig, signer types.Signer, statedb *state.StateDB, ...) *Task

+ func (env *Task) ApplyTransactions(txs *types.TransactionsByPriceAndNonce, bc BlockChain, ...) []*types.Log

+ func (env *Task) Receipts() []*types.Receipt

+ func (env *Task) Transactions() []*types.Transaction

+ type TxPool interface

+ AddLocal func(tx *types.Transaction) error

+ CachedPendingTxsByCount func(count int) types.Transactions

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

+ GasPrice func() *big.Int

+ Get func(hash common.Hash) *types.Transaction

+ GetPendingNonce func(addr common.Address) uint64

+ HandleTxMsg func(types.Transactions)

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

+ SetGasPrice func(price *big.Int)

+ StartSpamThrottler func(conf *blockchain.ThrottlerConfig) error

+ Stats func() (int, int)

+ Stop func()

+ StopSpamThrottler func()

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

v1.0.1-rc.3

Jul 17, 2024

v1.0.1-rc.2

Jul 11, 2024

v1.0.1-rc.1

Jul 3, 2024