database

Documentation

Index

• func NewMemStore() *memStore
• func NewPostgresStore(dsn string) *postgresStore
• type EthSendRawTxEntry
• type RequestEntry
• type Store
  • func NewMockStore() Store

Functions

func NewMemStore

func NewMemStore() *memStore

func NewPostgresStore

func NewPostgresStore(dsn string) *postgresStore

Types

type EthSendRawTxEntry

type EthSendRawTxEntry struct {
	Id                          uuid.UUID `db:"id"`
	RequestId                   uuid.UUID `db:"request_id"` // id from RequestEntry table
	InsertedAt                  time.Time `db:"inserted_at"`
	IsOnOafcList                bool      `db:"is_on_oafc_list"`
	IsWhiteHatBundleCollection  bool      `db:"is_white_hat_bundle_collection"`
	WhiteHatBundleId            string    `db:"white_hat_bundle_id"`
	IsCancelTx                  bool      `db:"is_cancel_tx"`
	NeedsFrontRunningProtection bool      `db:"needs_front_running_protection"`
	WasSentToRelay              bool      `db:"was_sent_to_relay"`
	WasSentToMempool            bool      `db:"was_sent_to_mempool"`
	IsBlocked                   bool      `db:"is_blocked"`
	Error                       string    `db:"error"`
	ErrorCode                   int       `db:"error_code"`
	TxRaw                       string    `db:"tx_raw"`
	TxHash                      string    `db:"tx_hash"`
	TxFrom                      string    `db:"tx_from"`
	TxTo                        string    `db:"tx_to"`
	TxNonce                     int       `db:"tx_nonce"`
	TxData                      string    `db:"tx_data"`
	TxSmartContractMethod       string    `db:"tx_smart_contract_method"`
	Fast                        bool      `db:"fast"` // If set, fast preference gets called
}

EthSendRawTxEntry to store each eth_sendRawTransaction calls

type RequestEntry

type RequestEntry struct {
	Id                 uuid.UUID `db:"id"`
	ReceivedAt         time.Time `db:"received_at"`
	InsertedAt         time.Time `db:"inserted_at"`
	RequestDurationMs  int64     `db:"request_duration_ms"`
	IsBatchRequest     bool      `db:"is_batch_request"`
	NumRequestInBatch  int       `db:"num_request_in_batch"`
	HttpMethod         string    `db:"http_method"`
	HttpUrl            string    `db:"http_url"`
	HttpQueryParam     string    `db:"http_query_param"`
	HttpResponseStatus int       `db:"http_response_status"`
	Origin             string    `db:"origin"`
	Host               string    `db:"host"`
	Error              string    `db:"error"`
}

RequestEntry to store each request

type Store

type Store interface {
	SaveRequestEntry(entry RequestEntry) error
	SaveRawTxEntries(entries []*EthSendRawTxEntry) error
}

func NewMockStore

func NewMockStore() Store