dent

Documentation

Index

• func GetDentConfig() shared_t.TransformerConfig
• type DentConverter
  • func NewDentConverter() DentConverter
  • func (c DentConverter) ToModels(ethLogs []types.Log) (result []interface{}, err error)
• type DentModel
• type DentRepository
  • func (repository DentRepository) Create(headerID int64, models []interface{}) error
  • func (repository DentRepository) MarkHeaderChecked(headerId int64) error
  • func (repository DentRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository DentRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository *DentRepository) SetDB(db *postgres.DB)

Functions

func GetDentConfig

func GetDentConfig() shared_t.TransformerConfig

Types

type DentConverter

type DentConverter struct{}

func NewDentConverter

func NewDentConverter() DentConverter

func (DentConverter) ToModels

func (c DentConverter) ToModels(ethLogs []types.Log) (result []interface{}, err error)

type DentModel

type DentModel struct {
	BidId            string `db:"bid_id"`
	Lot              string
	Bid              string
	Guy              string
	LogIndex         uint   `db:"log_idx"`
	TransactionIndex uint   `db:"tx_idx"`
	Raw              []byte `db:"raw_log"`
}

type DentRepository

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

func (DentRepository) Create

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

func (DentRepository) MarkHeaderChecked

func (repository DentRepository) MarkHeaderChecked(headerId int64) error

func (DentRepository) MissingHeaders

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

func (DentRepository) RecheckHeaders

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

func (*DentRepository) SetDB

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