Documentation
¶
Overview ¶
Package parser provides the logic to parse and store events.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BoolToUint8 ¶
BoolToUint8 is a helper function to handle bool to uint8 conversion for clickhouse.
func GetAmountUSD ¶
GetAmountUSD computes the USD value of a token amount.
func ToNullString ¶
func ToNullString(str *string) sql.NullString
ToNullString is a helper function to convert values to null string.
Types ¶
type BridgeParser ¶
type BridgeParser struct {
// Filterer is the bridge Filterer we use to parse events.
Filterer *bridge.SynapseBridgeFilterer
// Filterer is the bridge Filterer we use to parse events.
FiltererV1 *bridgev1.SynapseBridgeFilterer
// contains filtered or unexported fields
}
BridgeParser parses events from the bridge contract.
func NewBridgeParser ¶
func NewBridgeParser(consumerDB db.ConsumerDB, bridgeAddress common.Address, bridgeConfigFetcher fetcher.BridgeConfigFetcher, consumerFetcher *fetcher.ScribeFetcher) (*BridgeParser, error)
NewBridgeParser creates a new parser for a given bridge.
func (*BridgeParser) EventType ¶
func (p *BridgeParser) EventType(log ethTypes.Log) (_ bridgeTypes.EventType, ok bool)
EventType returns the event type of a bridge log.
func (*BridgeParser) ParseAndStore ¶
ParseAndStore parses the bridge logs and stores them in the database.
nolint:gocognit,cyclop,dupl,maintidx
type MessageBusParser ¶ added in v0.0.19
type MessageBusParser struct {
// Filterer is the message Filterer we use to parse events
Filterer *messagebus.MessageBusUpgradeableFilterer
// contains filtered or unexported fields
}
MessageBusParser parses messagebus logs.
func NewMessageBusParser ¶ added in v0.0.19
func NewMessageBusParser(consumerDB db.ConsumerDB, messageBusAddress common.Address, consumerFetcher *fetcher.ScribeFetcher) (*MessageBusParser, error)
NewMessageBusParser creates a new parser for a given message.
func (*MessageBusParser) EventType ¶ added in v0.0.19
func (m *MessageBusParser) EventType(log ethTypes.Log) (_ messageBusTypes.EventType, ok bool)
EventType returns the event type of a message log.
func (*MessageBusParser) ParseAndStore ¶ added in v0.0.19
func (m *MessageBusParser) ParseAndStore(ctx context.Context, log ethTypes.Log, chainID uint32) error
ParseAndStore parses the message logs and stores them in the database.
nolint:gocognit,cyclop,dupl
type Parser ¶
type Parser interface {
// ParseAndStore parses the logs and stores them in the database.
ParseAndStore(ctx context.Context, log ethTypes.Log, chainID uint32) error
}
Parser parses events and stores them.
type SwapParser ¶
type SwapParser struct {
// Filterer is the swap Filterer we use to parse events.
Filterer *swap.SwapFlashLoanFilterer
// contains filtered or unexported fields
}
SwapParser parses events from the swap contract.
func NewSwapParser ¶
func NewSwapParser(consumerDB db.ConsumerDB, swapAddress common.Address, swapFetcher fetcher.SwapFetcher, consumerFetcher *fetcher.ScribeFetcher) (*SwapParser, error)
NewSwapParser creates a new parser for a given bridge.
func (*SwapParser) ParseAndStore ¶
ParseAndStore parses and stores the swap logs.
Source Files