Documentation
¶
Index ¶
- func NewIndexerEVM() (types.Indexer, error)
- func NewIndexerTron() types.Indexer
- type IndexerEVM
- func (s *IndexerEVM) IndexGateway(ctx context.Context, network *ent.Network, address string, fromBlock int64, ...) (*types.EventCounts, error)
- func (s *IndexerEVM) IndexProviderAddress(ctx context.Context, network *ent.Network, address string, fromBlock int64, ...) (*types.EventCounts, error)
- func (s *IndexerEVM) IndexReceiveAddress(ctx context.Context, token *ent.Token, address string, fromBlock int64, ...) (*types.EventCounts, error)
- func (s *IndexerEVM) IndexReceiveAddressWithBypass(ctx context.Context, token *ent.Token, address string, fromBlock int64, ...) (*types.EventCounts, error)
- type IndexerTron
- func (s *IndexerTron) IndexGateway(ctx context.Context, network *ent.Network, address string, fromBlock int64, ...) (*types.EventCounts, error)
- func (s *IndexerTron) IndexProviderAddress(ctx context.Context, network *ent.Network, address string, fromBlock int64, ...) (*types.EventCounts, error)
- func (s *IndexerTron) IndexReceiveAddress(ctx context.Context, token *ent.Token, address string, fromBlock int64, ...) (*types.EventCounts, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewIndexerEVM ¶
NewIndexerEVM creates a new instance of IndexerEVM.
func NewIndexerTron ¶
NewIndexerTron creates a new instance of IndexerTron.
Types ¶
type IndexerEVM ¶
type IndexerEVM struct {
// contains filtered or unexported fields
}
IndexerEVM performs blockchain to database extract, transform, load (ETL) operations.
func (*IndexerEVM) IndexGateway ¶
func (s *IndexerEVM) IndexGateway(ctx context.Context, network *ent.Network, address string, fromBlock int64, toBlock int64, txHash string) (*types.EventCounts, error)
IndexGateway indexes all gateway events (OrderCreated, OrderSettled, OrderRefunded) in one efficient call
func (*IndexerEVM) IndexProviderAddress ¶ added in v0.0.2
func (s *IndexerEVM) IndexProviderAddress(ctx context.Context, network *ent.Network, address string, fromBlock int64, toBlock int64, txHash string) (*types.EventCounts, error)
IndexProviderAddress indexes OrderSettled events for a provider address
func (*IndexerEVM) IndexReceiveAddress ¶
func (s *IndexerEVM) IndexReceiveAddress(ctx context.Context, token *ent.Token, address string, fromBlock int64, toBlock int64, txHash string) (*types.EventCounts, error)
IndexReceiveAddress indexes all transfer events for a specific receive address
func (*IndexerEVM) IndexReceiveAddressWithBypass ¶ added in v0.1.0
func (s *IndexerEVM) IndexReceiveAddressWithBypass(ctx context.Context, token *ent.Token, address string, fromBlock int64, toBlock int64, txHash string, bypassQueue bool) (*types.EventCounts, error)
IndexReceiveAddressWithBypass indexes all transfer events for a specific receive address with option to bypass queue
type IndexerTron ¶
type IndexerTron struct {
// contains filtered or unexported fields
}
IndexerTron performs blockchain to database extract, transform, load (ETL) operations.
func (*IndexerTron) IndexGateway ¶
func (s *IndexerTron) IndexGateway(ctx context.Context, network *ent.Network, address string, fromBlock int64, toBlock int64, txHash string) (*types.EventCounts, error)
IndexGateway indexes all Gateway contract events (OrderCreated, OrderSettled, OrderRefunded) in a single call
func (*IndexerTron) IndexProviderAddress ¶ added in v0.0.2
func (s *IndexerTron) IndexProviderAddress(ctx context.Context, network *ent.Network, address string, fromBlock int64, toBlock int64, txHash string) (*types.EventCounts, error)
IndexProviderAddress indexes OrderSettled events for a provider address
func (*IndexerTron) IndexReceiveAddress ¶
func (s *IndexerTron) IndexReceiveAddress(ctx context.Context, token *ent.Token, address string, fromBlock int64, toBlock int64, txHash string) (*types.EventCounts, error)
IndexReceiveAddress indexes transfers to receive/linked addresses from user transaction history
Source Files