Version: v0.0.0-...-b1bd2f5 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: May 7, 2019 License: Apache-2.0 Imports: 11 Imported by: 0




This section is empty.


This section is empty.


func EthToWei

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


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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL