vat_frob

Documentation

Index

• Constants
• func GetVatFrobConfig() shared_t.EventTransformerConfig
• type VatFrobConverter
  • func (VatFrobConverter) ToModels(ethLogs []types.Log) ([]interface{}, error)
• type VatFrobModel
• type VatFrobRepository
  • func (repository VatFrobRepository) Create(headerID int64, models []interface{}) error
  • func (repository VatFrobRepository) MarkHeaderChecked(headerID int64) error
  • func (repository VatFrobRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository VatFrobRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository *VatFrobRepository) SetDB(db *postgres.DB)

Constants

const (
	InsertVatFrobQuery = `` /* 286-byte string literal not displayed */

)

Functions

func GetVatFrobConfig

func GetVatFrobConfig() shared_t.EventTransformerConfig

Types

type VatFrobConverter

type VatFrobConverter struct{}

func (VatFrobConverter) ToModels

func (VatFrobConverter) ToModels(ethLogs []types.Log) ([]interface{}, error)

type VatFrobModel

type VatFrobModel struct {
	Ilk              string
	Urn              string `db:"urn_id"`
	V                string
	W                string
	Dink             string
	Dart             string
	LogIndex         uint   `db:"log_idx"`
	TransactionIndex uint   `db:"tx_idx"`
	Raw              []byte `db:"raw_log"`
}

type VatFrobRepository

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

func (VatFrobRepository) Create

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

func (VatFrobRepository) MarkHeaderChecked

func (repository VatFrobRepository) MarkHeaderChecked(headerID int64) error

func (VatFrobRepository) MissingHeaders

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

func (VatFrobRepository) RecheckHeaders

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

func (*VatFrobRepository) SetDB

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