events

Documentation

Index

• type Config
• type Service
  • func NewEventsService(log *zap.Logger, walletsDB wallets.DB, config Config) *Service
  • func (events *Service) GetForAddress(ctx context.Context, endpoints []common.EthEndpoint, address []common.Address, ...) (map[int64]blockchain.Header, []TransferEvent, error)
  • func (events *Service) GetForSatellite(ctx context.Context, endpoints []common.EthEndpoint, satelliteID string, ...) (map[int64]blockchain.Header, []TransferEvent, error)
• type TransferEvent

Types

type Config

type Config struct {
	AddressBatchSize int `help:"number of Addresses to fetch new events for in a single request" default:"100"`
	BlockBatchSize   int `help:"number of blocks to fetch new events for in a single request" default:"5000"`
	ChainReorgBuffer int `help:"minimum number of blocks to re-query for when looking for new transfer events" default:"15"`
	MaximumQuerySize int `help:"maximum number of blocks prior to the latest block that storjscan can query for" default:"10000"`
}

Config is a configuration struct for the transfer events service.

type Service

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

Service for blockchain transfer events.

func NewEventsService

func NewEventsService(log *zap.Logger, walletsDB wallets.DB, config Config) *Service

NewEventsService creates a new transfer events service.

func (*Service) GetForAddress

func (events *Service) GetForAddress(ctx context.Context, endpoints []common.EthEndpoint, address []common.Address, from map[int64]int64) (map[int64]blockchain.Header, []TransferEvent, error)

GetForAddress returns with the latest transfer events from the blockchain for a given address.

func (*Service) GetForSatellite

func (events *Service) GetForSatellite(ctx context.Context, endpoints []common.EthEndpoint, satelliteID string, from map[int64]int64) (map[int64]blockchain.Header, []TransferEvent, error)

GetForSatellite returns with the latest transfer events from the blockchain for a given satellite.

type TransferEvent

type TransferEvent struct {
	ChainID     int64
	From        common.Address
	To          common.Address
	BlockHash   common.Hash
	BlockNumber int64
	TxHash      common.Hash
	LogIndex    int
	TokenValue  currency.Amount
}

TransferEvent holds a transfer event raised by an ERC20 contract.