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

geth

package

Go to main page

Versions in this module

v0

v0.2.2

Apr 12, 2017

v0.2.1

Apr 3, 2017

Changes in this version

type GethRPC

+ func (g *GethRPC) Broadcast(data []byte) (common.Hash, error)

type TxWatcher

+ func (tw *TxWatcher) WaitAndRetry() (*big.Int, *big.Int, error)

v0.2.0

Mar 29, 2017

Changes in this version

type GethRPC

+ func (g *GethRPC) SetEtherbase(etherbase common.Address) error

+ func (g *GethRPC) SetExtradata(extradata string) error

+ func (g *GethRPC) Syncing() bool

v0.1.0

Mar 25, 2017

Changes in this version

+ const PoolMonitorClientABI

+ const TestPoolABI

+ var BlockTime = 6 * time.Second

+ var ErrorMap = map[uint64][]string

+ var PoolMonitorAddress = common.HexToAddress("0x7727D4535f1A9c9ECC59FB17B6bF8145C7d5D58c")

+ var RegisterEventTopic = common.HexToHash("0x1d759fb22634fe2d322d688a4b46aaf185dd0a3db78ccf01a9218f00ac3df03f").Big()

+ var SetEpochDataEventTopic = common.HexToHash("0x5cd723400be8430351b9cbaa5ea421b3fb2528c6a7650c493f895e7d97750da1").Big()

+ var SubmitClaimEventTopic = common.HexToHash("0x53ab9d877ae22286591454f9a8d58501caa34a07c99eac2c09bc0066c065400d").Big()

+ var TimestampFile = getTimestampFile()

+ var VerifyClaimEventTopic = common.HexToHash("0x096caf97202169a068288f02e51ff9fcc85f98e1477f6ad9acbf6ebf25dbcd00").Big()

+ func ErrorMsg(errCode, errInfo *big.Int) string

+ func GetAddress(keystorePath string, address common.Address) (common.Address, bool, []common.Address)

+ type GethContractClient struct

+ func NewGethContractClient(contractAddr common.Address, node ethereum.RPCClient, miner common.Address, ...) (*GethContractClient, error)

+ func (cc *GethContractClient) CanRegister() bool

+ func (cc *GethContractClient) GetClaimSeed() *big.Int

+ func (cc *GethContractClient) IsRegistered() bool

+ func (cc *GethContractClient) Register(paymentAddress common.Address) error

+ func (cc *GethContractClient) SetEpochData(merkleRoot []*big.Int, fullSizeIn128Resolution []uint64, branchDepth []uint64, ...) error

+ func (cc *GethContractClient) SubmitClaim(numShares *big.Int, difficulty *big.Int, min *big.Int, max *big.Int, ...) error

+ func (cc *GethContractClient) VerifyClaim(rlpHeader []byte, nonce *big.Int, shareIndex *big.Int, ...) error

+ func (cc *GethContractClient) Version() string

+ type GethRPC struct

+ ContractAddr common.Address

+ ExtraData []byte

+ ShareDifficulty *big.Int

+ func NewGethRPC(endpoint, contractAddr, extraData string, diff *big.Int) (*GethRPC, error)

+ func (g *GethRPC) BlockNumber() (*big.Int, error)

+ func (g *GethRPC) ClientVersion() (string, error)

+ func (g *GethRPC) GetBlockHeader(number int) *types.Header

+ func (g *GethRPC) GetLog(from *big.Int, event *big.Int, sender *big.Int) (*big.Int, *big.Int)

+ func (g *GethRPC) GetPendingBlockHeader() *types.Header

+ func (g *GethRPC) GetWork() *ethereum.Work

+ func (g *GethRPC) IsVerified(h common.Hash) bool

+ func (g *GethRPC) SubmitHashrate(hashrate hexutil.Uint64, id common.Hash) bool

+ func (g *GethRPC) SubmitWork(nonce types.BlockNonce, hash, mixDigest common.Hash) bool

+ type KovanRPC struct

+ func NewKovanRPC(endpoint, contractAddr, extraData string, diff *big.Int) (*KovanRPC, error)

+ func (k *KovanRPC) GetWork() *ethereum.Work

+ func (k *KovanRPC) SubmitWork(nonce types.BlockNonce, hash, mixDigest common.Hash) bool

+ type MinerAccount struct

+ func GetAccount(keystorePath string, address common.Address, passphrase string) *MinerAccount

+ func (ma MinerAccount) Address() common.Address

+ func (ma MinerAccount) KeyFile() string

+ func (ma MinerAccount) PassPhrase() string

+ type PoolMonitor struct

+ func NewPoolMonitor(contractAddr common.Address, version string, ipc string) (*PoolMonitor, error)

+ func (pm *PoolMonitor) ContractAddress() common.Address

+ func (pm *PoolMonitor) RequireClientUpdate() bool

+ func (pm *PoolMonitor) RequireContractUpdate() bool

+ type PoolMonitorClient struct

+ func NewPoolMonitorClient(address common.Address, backend bind.ContractBackend) (*PoolMonitorClient, error)

+ type PoolMonitorClientCaller struct

+ func NewPoolMonitorClientCaller(address common.Address, caller bind.ContractCaller) (*PoolMonitorClientCaller, error)

+ func (_PoolMonitorClient *PoolMonitorClientCaller) ClientVersion(opts *bind.CallOpts) ([32]byte, error)

+ func (_PoolMonitorClient *PoolMonitorClientCaller) PoolContract(opts *bind.CallOpts) (common.Address, error)

+ type PoolMonitorClientCallerRaw struct

+ Contract *PoolMonitorClientCaller

+ func (_PoolMonitorClient *PoolMonitorClientCallerRaw) Call(opts *bind.CallOpts, result interface{}, method string, params ...interface{}) error

+ type PoolMonitorClientCallerSession struct

+ CallOpts bind.CallOpts

+ Contract *PoolMonitorClientCaller

+ func (_PoolMonitorClient *PoolMonitorClientCallerSession) ClientVersion() ([32]byte, error)

+ func (_PoolMonitorClient *PoolMonitorClientCallerSession) PoolContract() (common.Address, error)

+ type PoolMonitorClientRaw struct

+ Contract *PoolMonitorClient

+ func (_PoolMonitorClient *PoolMonitorClientRaw) Call(opts *bind.CallOpts, result interface{}, method string, params ...interface{}) error

+ func (_PoolMonitorClient *PoolMonitorClientRaw) Transact(opts *bind.TransactOpts, method string, params ...interface{}) (*types.Transaction, error)

+ func (_PoolMonitorClient *PoolMonitorClientRaw) Transfer(opts *bind.TransactOpts) (*types.Transaction, error)

+ type PoolMonitorClientSession struct

+ CallOpts bind.CallOpts

+ Contract *PoolMonitorClient

+ TransactOpts bind.TransactOpts

+ func (_PoolMonitorClient *PoolMonitorClientSession) ClientVersion() ([32]byte, error)

+ func (_PoolMonitorClient *PoolMonitorClientSession) PoolContract() (common.Address, error)

+ func (_PoolMonitorClient *PoolMonitorClientSession) UpdateClientVersion(version [32]byte) (*types.Transaction, error)

+ func (_PoolMonitorClient *PoolMonitorClientSession) UpdatePoolContract(newAddress common.Address) (*types.Transaction, error)

+ type PoolMonitorClientTransactor struct

+ func NewPoolMonitorClientTransactor(address common.Address, transactor bind.ContractTransactor) (*PoolMonitorClientTransactor, error)

+ func (_PoolMonitorClient *PoolMonitorClientTransactor) UpdateClientVersion(opts *bind.TransactOpts, version [32]byte) (*types.Transaction, error)

+ func (_PoolMonitorClient *PoolMonitorClientTransactor) UpdatePoolContract(opts *bind.TransactOpts, newAddress common.Address) (*types.Transaction, error)

+ type PoolMonitorClientTransactorRaw struct

+ Contract *PoolMonitorClientTransactor

+ func (_PoolMonitorClient *PoolMonitorClientTransactorRaw) Transact(opts *bind.TransactOpts, method string, params ...interface{}) (*types.Transaction, error)

+ func (_PoolMonitorClient *PoolMonitorClientTransactorRaw) Transfer(opts *bind.TransactOpts) (*types.Transaction, error)

+ type PoolMonitorClientTransactorSession struct

+ Contract *PoolMonitorClientTransactor

+ TransactOpts bind.TransactOpts

+ func (_PoolMonitorClient *PoolMonitorClientTransactorSession) UpdateClientVersion(version [32]byte) (*types.Transaction, error)

+ func (_PoolMonitorClient *PoolMonitorClientTransactorSession) UpdatePoolContract(newAddress common.Address) (*types.Transaction, error)

+ type TestPool struct

+ func NewTestPool(address common.Address, backend bind.ContractBackend) (*TestPool, error)

+ type TestPoolCaller struct

+ func NewTestPoolCaller(address common.Address, caller bind.ContractCaller) (*TestPoolCaller, error)

+ func (_TestPool *TestPoolCaller) BudgetPerShareUnit(opts *bind.CallOpts) (*big.Int, error)

+ func (_TestPool *TestPoolCaller) CalcPayment(opts *bind.CallOpts, numShares *big.Int, difficulty *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolCaller) CalcPaymentShareUnits(opts *bind.CallOpts, numShares *big.Int, difficulty *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolCaller) CanRegister(opts *bind.CallOpts, sender common.Address) (bool, error)

+ func (_TestPool *TestPoolCaller) EpochData(opts *bind.CallOpts, arg0 *big.Int) (struct{ ... }, error)

+ func (_TestPool *TestPoolCaller) ExistingIds(opts *bind.CallOpts, arg0 [32]byte) (bool, error)

+ func (_TestPool *TestPoolCaller) GetClaimSeed(opts *bind.CallOpts, sender common.Address) (*big.Int, error)

+ func (_TestPool *TestPoolCaller) GetEpochData(opts *bind.CallOpts, epoch *big.Int) ([3]*big.Int, error)

+ func (_TestPool *TestPoolCaller) GetMinerId(opts *bind.CallOpts, sender common.Address) ([32]byte, error)

+ func (_TestPool *TestPoolCaller) GetShareIndex(opts *bind.CallOpts, sender common.Address) (*big.Int, error)

+ func (_TestPool *TestPoolCaller) Hashimoto(opts *bind.CallOpts, header [32]byte, nonceLe [8]byte, ...) (*big.Int, error)

+ func (_TestPool *TestPoolCaller) IsRegistered(opts *bind.CallOpts, sender common.Address) (bool, error)

+ func (_TestPool *TestPoolCaller) NewVersionReleased(opts *bind.CallOpts) (bool, error)

+ func (_TestPool *TestPoolCaller) Owners(opts *bind.CallOpts, arg0 common.Address) (bool, error)

+ func (_TestPool *TestPoolCaller) PaymentUnitsPer1000Blocks(opts *bind.CallOpts, arg0 *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolCaller) To62Encoding(opts *bind.CallOpts, id *big.Int, numChars *big.Int) ([32]byte, error)

+ func (_TestPool *TestPoolCaller) Version(opts *bind.CallOpts) (string, error)

+ type TestPoolCallerRaw struct

+ Contract *TestPoolCaller

+ func (_TestPool *TestPoolCallerRaw) Call(opts *bind.CallOpts, result interface{}, method string, params ...interface{}) error

+ type TestPoolCallerSession struct

+ CallOpts bind.CallOpts

+ Contract *TestPoolCaller

+ func (_TestPool *TestPoolCallerSession) BudgetPerShareUnit() (*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) CalcPayment(numShares *big.Int, difficulty *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) CalcPaymentShareUnits(numShares *big.Int, difficulty *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) CanRegister(sender common.Address) (bool, error)

+ func (_TestPool *TestPoolCallerSession) EpochData(arg0 *big.Int) (struct{ ... }, error)

+ func (_TestPool *TestPoolCallerSession) ExistingIds(arg0 [32]byte) (bool, error)

+ func (_TestPool *TestPoolCallerSession) GetClaimSeed(sender common.Address) (*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) GetEpochData(epoch *big.Int) ([3]*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) GetMinerId(sender common.Address) ([32]byte, error)

+ func (_TestPool *TestPoolCallerSession) GetShareIndex(sender common.Address) (*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) Hashimoto(header [32]byte, nonceLe [8]byte, fullSizeIn128Resultion *big.Int, ...) (*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) IsRegistered(sender common.Address) (bool, error)

+ func (_TestPool *TestPoolCallerSession) NewVersionReleased() (bool, error)

+ func (_TestPool *TestPoolCallerSession) Owners(arg0 common.Address) (bool, error)

+ func (_TestPool *TestPoolCallerSession) PaymentUnitsPer1000Blocks(arg0 *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolCallerSession) To62Encoding(id *big.Int, numChars *big.Int) ([32]byte, error)

+ func (_TestPool *TestPoolCallerSession) Version() (string, error)

+ type TestPoolRaw struct

+ Contract *TestPool

+ func (_TestPool *TestPoolRaw) Call(opts *bind.CallOpts, result interface{}, method string, params ...interface{}) error

+ func (_TestPool *TestPoolRaw) Transact(opts *bind.TransactOpts, method string, params ...interface{}) (*types.Transaction, error)

+ func (_TestPool *TestPoolRaw) Transfer(opts *bind.TransactOpts) (*types.Transaction, error)

+ type TestPoolSession struct

+ CallOpts bind.CallOpts

+ Contract *TestPool

+ TransactOpts bind.TransactOpts

+ func (_TestPool *TestPoolSession) BudgetPerShareUnit() (*big.Int, error)

+ func (_TestPool *TestPoolSession) CalcPayment(numShares *big.Int, difficulty *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolSession) CalcPaymentShareUnits(numShares *big.Int, difficulty *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolSession) CanRegister(sender common.Address) (bool, error)

+ func (_TestPool *TestPoolSession) DeclareNewerVersion() (*types.Transaction, error)

+ func (_TestPool *TestPoolSession) EpochData(arg0 *big.Int) (struct{ ... }, error)

+ func (_TestPool *TestPoolSession) ExistingIds(arg0 [32]byte) (bool, error)

+ func (_TestPool *TestPoolSession) GetClaimSeed(sender common.Address) (*big.Int, error)

+ func (_TestPool *TestPoolSession) GetEpochData(epoch *big.Int) ([3]*big.Int, error)

+ func (_TestPool *TestPoolSession) GetMinerId(sender common.Address) ([32]byte, error)

+ func (_TestPool *TestPoolSession) GetShareIndex(sender common.Address) (*big.Int, error)

+ func (_TestPool *TestPoolSession) Hashimoto(header [32]byte, nonceLe [8]byte, fullSizeIn128Resultion *big.Int, ...) (*big.Int, error)

+ func (_TestPool *TestPoolSession) IsRegistered(sender common.Address) (bool, error)

+ func (_TestPool *TestPoolSession) NewVersionReleased() (bool, error)

+ func (_TestPool *TestPoolSession) Owners(arg0 common.Address) (bool, error)

+ func (_TestPool *TestPoolSession) PaymentUnitsPer1000Blocks(arg0 *big.Int) (*big.Int, error)

+ func (_TestPool *TestPoolSession) Register(paymentAddress common.Address) (*types.Transaction, error)

+ func (_TestPool *TestPoolSession) SetBudgetPerShareUnit(budget *big.Int) (*types.Transaction, error)

+ func (_TestPool *TestPoolSession) SetEpochData(merkleRoot []*big.Int, fullSizeIn128Resultion []uint64, branchDepth []uint64, ...) (*types.Transaction, error)

+ func (_TestPool *TestPoolSession) SubmitClaim(numShares *big.Int, difficulty *big.Int, min *big.Int, max *big.Int, ...) (*types.Transaction, error)

+ func (_TestPool *TestPoolSession) SubmitClientError(error string) (*types.Transaction, error)

+ func (_TestPool *TestPoolSession) To62Encoding(id *big.Int, numChars *big.Int) ([32]byte, error)

+ func (_TestPool *TestPoolSession) VerifyClaim(rlpHeader []byte, nonce *big.Int, shareIndex *big.Int, ...) (*types.Transaction, error)

+ func (_TestPool *TestPoolSession) Version() (string, error)

+ type TestPoolTransactor struct

+ func NewTestPoolTransactor(address common.Address, transactor bind.ContractTransactor) (*TestPoolTransactor, error)

+ func (_TestPool *TestPoolTransactor) DeclareNewerVersion(opts *bind.TransactOpts) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactor) Register(opts *bind.TransactOpts, paymentAddress common.Address) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactor) SetBudgetPerShareUnit(opts *bind.TransactOpts, budget *big.Int) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactor) SetEpochData(opts *bind.TransactOpts, merkleRoot []*big.Int, ...) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactor) SubmitClaim(opts *bind.TransactOpts, numShares *big.Int, difficulty *big.Int, min *big.Int, ...) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactor) SubmitClientError(opts *bind.TransactOpts, error string) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactor) VerifyClaim(opts *bind.TransactOpts, rlpHeader []byte, nonce *big.Int, shareIndex *big.Int, ...) (*types.Transaction, error)

+ type TestPoolTransactorRaw struct

+ Contract *TestPoolTransactor

+ func (_TestPool *TestPoolTransactorRaw) Transact(opts *bind.TransactOpts, method string, params ...interface{}) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactorRaw) Transfer(opts *bind.TransactOpts) (*types.Transaction, error)

+ type TestPoolTransactorSession struct

+ Contract *TestPoolTransactor

+ TransactOpts bind.TransactOpts

+ func (_TestPool *TestPoolTransactorSession) DeclareNewerVersion() (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactorSession) Register(paymentAddress common.Address) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactorSession) SetBudgetPerShareUnit(budget *big.Int) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactorSession) SetEpochData(merkleRoot []*big.Int, fullSizeIn128Resultion []uint64, branchDepth []uint64, ...) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactorSession) SubmitClaim(numShares *big.Int, difficulty *big.Int, min *big.Int, max *big.Int, ...) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactorSession) SubmitClientError(error string) (*types.Transaction, error)

+ func (_TestPool *TestPoolTransactorSession) VerifyClaim(rlpHeader []byte, nonce *big.Int, shareIndex *big.Int, ...) (*types.Transaction, error)

+ type TxWatcher struct

+ func NewTxWatcher(tx *types.Transaction, node ethereum.RPCClient, blockNo *big.Int, ...) *TxWatcher

+ func (tw *TxWatcher) Wait() (*big.Int, *big.Int)