flap_kick

Documentation

Index

• func GetFlapKickConfig() shared_t.TransformerConfig
• type FlapKickConverter
  • func (FlapKickConverter) ToEntities(contractAbi string, ethLogs []types.Log) ([]interface{}, error)
  • func (FlapKickConverter) ToModels(entities []interface{}) ([]interface{}, error)
• type FlapKickEntity
• type FlapKickModel
• type FlapKickRepository
  • func (repository *FlapKickRepository) Create(headerID int64, models []interface{}) error
  • func (repository *FlapKickRepository) MarkHeaderChecked(headerID int64) error
  • func (repository FlapKickRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository FlapKickRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository *FlapKickRepository) SetDB(db *postgres.DB)

Functions

func GetFlapKickConfig

func GetFlapKickConfig() shared_t.TransformerConfig

Types

type FlapKickConverter

type FlapKickConverter struct {
}

func (FlapKickConverter) ToEntities

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

func (FlapKickConverter) ToModels

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

type FlapKickEntity

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

type FlapKickModel

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

type FlapKickRepository

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

func (*FlapKickRepository) Create

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

func (*FlapKickRepository) MarkHeaderChecked

func (repository *FlapKickRepository) MarkHeaderChecked(headerID int64) error

func (FlapKickRepository) MissingHeaders

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

func (FlapKickRepository) RecheckHeaders

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

func (*FlapKickRepository) SetDB

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