flop_kick

Documentation

Index

• func GetFlopKickConfig() shared_t.EventTransformerConfig
• type Entity
• type FlopKickConverter
  • func (FlopKickConverter) ToEntities(contractAbi string, ethLogs []types.Log) ([]interface{}, error)
  • func (FlopKickConverter) ToModels(entities []interface{}) ([]interface{}, error)
• type FlopKickRepository
  • func (repository FlopKickRepository) Create(headerID int64, models []interface{}) error
  • func (repository FlopKickRepository) MarkHeaderChecked(headerId int64) error
  • func (repository FlopKickRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository FlopKickRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository *FlopKickRepository) SetDB(db *postgres.DB)
• type Model

Functions

func GetFlopKickConfig

func GetFlopKickConfig() shared_t.EventTransformerConfig

Types

type Entity

type Entity struct {
	Id               *big.Int
	Lot              *big.Int
	Bid              *big.Int
	Gal              common.Address
	End              *big.Int
	TransactionIndex uint
	LogIndex         uint
	Raw              types.Log
}

type FlopKickConverter

type FlopKickConverter struct{}

func (FlopKickConverter) ToEntities

func (FlopKickConverter) ToEntities(contractAbi string, ethLogs []types.Log) ([]interface{}, error)

func (FlopKickConverter) ToModels

func (FlopKickConverter) ToModels(entities []interface{}) ([]interface{}, error)

type FlopKickRepository

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

func (FlopKickRepository) Create

func (repository FlopKickRepository) Create(headerID int64, models []interface{}) error

func (FlopKickRepository) MarkHeaderChecked

func (repository FlopKickRepository) MarkHeaderChecked(headerId int64) error

func (FlopKickRepository) MissingHeaders

func (repository FlopKickRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)

func (FlopKickRepository) RecheckHeaders

func (repository FlopKickRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)

func (*FlopKickRepository) SetDB

func (repository *FlopKickRepository) SetDB(db *postgres.DB)

type Model

type Model struct {
	BidId            string `db:"bid_id"`
	Lot              string
	Bid              string
	Gal              string
	End              time.Time
	TransactionIndex uint   `db:"tx_idx"`
	LogIndex         uint   `db:"log_idx"`
	Raw              []byte `db:"raw_log"`
}