frob

Documentation

Index

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

Functions

func GetFrobConfig

func GetFrobConfig() shared_t.TransformerConfig

Types

type FrobConverter

type FrobConverter struct{}

func (FrobConverter) ToEntities

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

func (FrobConverter) ToModels

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

type FrobEntity

type FrobEntity struct {
	Ilk              [32]byte
	Urn              [32]byte
	Ink              *big.Int
	Art              *big.Int
	Dink             *big.Int
	Dart             *big.Int
	IArt             *big.Int
	LogIndex         uint
	TransactionIndex uint
	Raw              types.Log
}

type FrobModel

type FrobModel struct {
	Ilk              string
	Urn              string
	Ink              string
	Art              string
	Dink             string
	Dart             string
	IArt             string
	LogIndex         uint   `db:"log_idx"`
	TransactionIndex uint   `db:"tx_idx"`
	Raw              []byte `db:"raw_log"`
}

type FrobRepository

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

func (FrobRepository) Create

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

func (FrobRepository) MarkHeaderChecked

func (repository FrobRepository) MarkHeaderChecked(headerID int64) error

func (FrobRepository) MissingHeaders

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

func (FrobRepository) RecheckHeaders

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

func (*FrobRepository) SetDB

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