ethereum

type AddressGenerator ¶

type AddressGenerator struct {
	// contains filtered or unexported fields
}

func NewAddressGenerator(masterPublicKeyString string) (*AddressGenerator, error)

func (g *AddressGenerator) Generate(index uint64) (common.Address, error)

type Client ¶

type Client interface {
	NetworkID(ctx context.Context) (*big.Int, error)
	BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
}

type Listener ¶

type Listener struct {
	Enabled              bool
	Client               Client          `inject:""`
	Storage              storage.Storage `inject:""`
	NetworkID            string
	ConfirmedBlockNumber uint64
	TransactionHandler   TransactionHandler
}

Listener listens for transactions using geth RPC. It calls TransactionHandler for each new transactions. It will reprocess the block if TransactionHandler returns error. It will start from the block number returned from Storage.GetBlockToProcess("ethereum") or the latest block if it returned 0. Transactions can be processed more than once, it's TransactionHandler responsibility to ignore duplicates. You can run multiple Listeners if Storage is implemented correctly. Listener ignores contract creation transactions. Listener requires geth 1.7.0.

func (l *Listener) Start() error

func (l *Listener) Stop() error

type Transaction ¶

type Transaction struct {
	Hash string
	// Value in Wei
	ValueWei *big.Int
	To       string
}

func (t *Transaction) ValueToTomo() string

func (t *Transaction) ValueToWei() string

type TransactionHandler ¶

type TransactionHandler func(transaction Transaction) error