pip_log_value

Documentation

Index

• Variables
• func GetPipLogValueConfig() shared_t.EventTransformerConfig
• type PipLogValueConverter
  • func (converter PipLogValueConverter) ToModels(ethLogs []types.Log) ([]interface{}, error)
• type PipLogValueModel
• type PipLogValueRepository
  • func (repository PipLogValueRepository) Create(headerID int64, models []interface{}) error
  • func (repository PipLogValueRepository) MarkHeaderChecked(headerID int64) error
  • func (repository PipLogValueRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository PipLogValueRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error)
  • func (repository *PipLogValueRepository) SetDB(db *postgres.DB)

Variables

var (
	ErrNoMatchingLog = errors.New("no matching log")
	Ether            = big.NewFloat(1e18)
	Ray              = big.NewFloat(1e27)
)

Functions

func GetPipLogValueConfig

func GetPipLogValueConfig() shared_t.EventTransformerConfig

Types

type PipLogValueConverter

type PipLogValueConverter struct{}

func (PipLogValueConverter) ToModels

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

type PipLogValueModel

type PipLogValueModel struct {
	BlockNumber      uint64 `db:"block_number"`
	ContractAddress  string `db:"contract_address"`
	Value            string `db:"val"`
	LogIndex         uint   `db:"log_idx"`
	TransactionIndex uint   `db:"tx_idx"`
	Raw              []byte `db:"raw_log"`
}

type PipLogValueRepository

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

func (PipLogValueRepository) Create

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

func (PipLogValueRepository) MarkHeaderChecked

func (repository PipLogValueRepository) MarkHeaderChecked(headerID int64) error

func (PipLogValueRepository) MissingHeaders

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

func (PipLogValueRepository) RecheckHeaders

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

func (*PipLogValueRepository) SetDB

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