db

Documentation

Index

• Constants
• type DB
• type Postgres
  • func NewPostgres(db *sqlx.DB) *Postgres
  • func (pg *Postgres) GetLastStoredBlock(table string) (int64, error)
  • func (pg *Postgres) GetUniqueTokenAddressByRangeForTrade(table string, from, to int64) ([]string, error)
  • func (pg *Postgres) GetUniqueTokenAddressByRangeForTransfer(table string, from, to int64) ([]string, error)

Constants

const (
	BaseTradeLogs    = "base_trade_logs"
	BaseTransferLogs = "base_transfer_logs"
)

Types

type DB

type DB interface {
	GetLastStoredBlock(table string) (int64, error)
	GetUniqueTokenAddressByRangeForTrade(table string, from, to int64) ([]string, error)
	GetUniqueTokenAddressByRangeForTransfer(table string, from, to int64) ([]string, error)
}

type Postgres

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

func NewPostgres

func NewPostgres(db *sqlx.DB) *Postgres

func (*Postgres) GetLastStoredBlock

func (pg *Postgres) GetLastStoredBlock(table string) (int64, error)

func (*Postgres) GetUniqueTokenAddressByRangeForTrade

func (pg *Postgres) GetUniqueTokenAddressByRangeForTrade(table string, from, to int64) ([]string, error)

func (*Postgres) GetUniqueTokenAddressByRangeForTransfer

func (pg *Postgres) GetUniqueTokenAddressByRangeForTransfer(table string, from, to int64) ([]string, error)