ethereum

Documentation

Index

• func EthToWei(eth string) (*big.Int, error)
• type AddressGenerator
  • func NewAddressGenerator(masterPublicKeyString string) (*AddressGenerator, error)
  • func (g *AddressGenerator) Generate(index uint32) (string, error)
• type Client
• type Listener
  • func (l *Listener) Start(rpcServer string) error
• type Storage
• type Transaction
  • func (t Transaction) ValueToStellar() string
• type TransactionHandler

Functions

func EthToWei

func EthToWei(eth string) (*big.Int, error)

Types

type AddressGenerator

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

func NewAddressGenerator

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

func (*AddressGenerator) Generate

func (g *AddressGenerator) Generate(index uint32) (string, 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 `inject:""`
	NetworkID          string
	TransactionHandler TransactionHandler
	// contains filtered or unexported fields
}

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.GetEthereumBlockToProcess 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 (*Listener) Start

func (l *Listener) Start(rpcServer string) error

type Storage

type Storage interface {
	// GetEthereumBlockToProcess gets the number of Ethereum block to process. `0` means the
	// processing should start from the current block.
	GetEthereumBlockToProcess() (uint64, error)
	// SaveLastProcessedEthereumBlock should update the number of the last processed Ethereum
	// block. It should only update the block if block > current block in atomic transaction.
	SaveLastProcessedEthereumBlock(block uint64) error
}

Storage is an interface that must be implemented by an object using persistent storage.

type Transaction

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

func (Transaction) ValueToStellar

func (t Transaction) ValueToStellar() string

type TransactionHandler

type TransactionHandler func(transaction Transaction) error