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) GetSmallestStoredBlock(table string) (int64, error)
  • func (pg *Postgres) SaveLogs(tradeLogs []common.Tradelog, transferLogs []common.Transferlog, ...) error

Constants

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

Types

type DB

type DB interface {
	GetLastStoredBlock(table string) (int64, error)
	GetSmallestStoredBlock(table string) (int64, error)
	SaveLogs(tradeLogs []common.Tradelog, transferLogs []common.Transferlog, tradeTable, transferTable 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) GetSmallestStoredBlock

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

func (*Postgres) SaveLogs

func (pg *Postgres) SaveLogs(tradeLogs []common.Tradelog, transferLogs []common.Transferlog, tradeTable, transferTable string) error