internal

package

v0.0.0-...-b6889b5 Latest Latest Go to latest Published: Jan 24, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func ProcessBlocks(cfg Configuration, metrics MetricDefinitions)

func ServeMetrics(registry *prom.Registry)

type Configuration struct {
	BlocksSince  time.Time
	FromAccounts []string
	ToAccounts   []string
}

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

func NewDateFilter(start time.Time, end time.Time) (*DateFilter, error)

func (f DateFilter) QualifyTransaction(blk EthBlock, txn EthTransaction) (bool, error)

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

func NewDestinationFilter(ver int, id big.Int, addr string) (*DestinationFilter, error)

func (f DestinationFilter) QualifyTransaction(blk EthBlock, txn EthTransaction) (bool, error)

type EthBlock interface {
	Time() uint64
}

type EthMessage interface {
	To() *common.Address
	From() common.Address
}

type EthTransaction interface {
	ChainId() *big.Int
	Hash() common.Hash
	AsMessage(s types.Signer) (types.Message, error)
}

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

func (fc FilterChain) QualifyTransaction(blk EthBlock, txn EthTransaction) (bool, error)

type Lot struct {
	LotId   ulid.ULID
	Date    time.Time
	Rate    decimal.Decimal
	TxnList []LotTxn
}

func NewLot(date time.Time) Lot

func (l *Lot) AddTxn(from common.Address, nonce uint64, amt decimal.Decimal) error

type LotTxn struct {
	TxnFrom   common.Address
	TxnNonce  uint64
	EthAmount decimal.Decimal
}

func NewLotTxn(from common.Address, nonce uint64, amt decimal.Decimal) LotTxn

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

func GetMetricDefinitions() MetricDefinitions

func InitializeMetrics() MetricDefinitions

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

func NewSourceFilter(ver int, id big.Int, addr string) (*SourceFilter, error)

func (f SourceFilter) QualifyTransaction(blk EthBlock, txn EthTransaction) (bool, error)

type TransactionFilter interface {
	QualifyTransaction(EthBlock, EthTransaction) (bool, error)
}