ethgas

Documentation

Index

• Constants
• Variables
• func DefaultGasPriceBidReader(block *ethmonitor.Block) []*big.Int
• func DefaultGasPricePaidReader(block *ethmonitor.Block) []*big.Int
• type EMA
  • func NewEMA(decay float64) *EMA
  • func (ema *EMA) Tick(price *big.Int) *big.Int
  • func (ema *EMA) Value() *big.Int
• type GasGauge
  • func NewGasGauge(log logger.Logger, monitor *ethmonitor.Monitor, minGasPriceInGwei uint64, ...) (*GasGauge, error)
  • func NewGasGaugeWei(log logger.Logger, monitor *ethmonitor.Monitor, minGasPriceInWei uint64, ...) (*GasGauge, error)
  • func (g *GasGauge) IsRunning() bool
  • func (g *GasGauge) Run(ctx context.Context) error
  • func (g *GasGauge) Stop()
  • func (g *GasGauge) Subscribe() ethmonitor.Subscription
  • func (g *GasGauge) SuggestedGasPrice() SuggestedGasPrice
  • func (g *GasGauge) SuggestedGasPriceBid() SuggestedGasPrice
  • func (g *GasGauge) SuggestedPaidGasPrice() SuggestedGasPrice
• type GasPriceReader
• type SuggestedGasPrice

Constants

const (
	ONE_GWEI = uint64(1e9)
)

Variables

var BUCKET_RANGE = big.NewInt(int64(5 * ONE_GWEI))

var CustomGasPriceBidReaders = map[uint64]GasPriceReader{}

var CustomGasPricePaidReaders = map[uint64]GasPriceReader{
	42161:  arbitrumGasPricePaidReader,
	42170:  arbitrumGasPricePaidReader,
	421611: arbitrumGasPricePaidReader,
}

var ONE_GWEI_BIG = big.NewInt(int64(ONE_GWEI))

Functions

func DefaultGasPriceBidReader

func DefaultGasPriceBidReader(block *ethmonitor.Block) []*big.Int

func DefaultGasPricePaidReader

func DefaultGasPricePaidReader(block *ethmonitor.Block) []*big.Int

Types

type EMA

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

EMA is a moving average with exponential decay. It doesn't have any concept of weight so it will only work on homogenous (evenly spaced) time series. ema := NewEMA(0.1818) avg1 = ema.Tick(price1) avg2 = ema.Tick(price2) spike := checkPriceMovingAvg(price, avg, 20%)

func NewEMA

func NewEMA(decay float64) *EMA

NewEMA(decay) returns a new exponential moving average. It weighs new values more than existing values according to the decay. For example: NewEMA(0.05) would give 5% weight to the present and 95% weight to the past. Common to use 2/(selected time period+1).

func (*EMA) Tick

func (ema *EMA) Tick(price *big.Int) *big.Int

func (*EMA) Value

func (ema *EMA) Value() *big.Int

type GasGauge

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

func NewGasGauge

func NewGasGauge(log logger.Logger, monitor *ethmonitor.Monitor, minGasPriceInGwei uint64, useEIP1559 bool) (*GasGauge, error)

func NewGasGaugeWei

func NewGasGaugeWei(log logger.Logger, monitor *ethmonitor.Monitor, minGasPriceInWei uint64, useEIP1559 bool) (*GasGauge, error)

func (*GasGauge) IsRunning

func (g *GasGauge) IsRunning() bool

func (*GasGauge) Run

func (g *GasGauge) Run(ctx context.Context) error

func (*GasGauge) Stop

func (g *GasGauge) Stop()

func (*GasGauge) Subscribe

func (g *GasGauge) Subscribe() ethmonitor.Subscription

func (*GasGauge) SuggestedGasPrice

func (g *GasGauge) SuggestedGasPrice() SuggestedGasPrice

func (*GasGauge) SuggestedGasPriceBid

func (g *GasGauge) SuggestedGasPriceBid() SuggestedGasPrice

func (*GasGauge) SuggestedPaidGasPrice

func (g *GasGauge) SuggestedPaidGasPrice() SuggestedGasPrice

type GasPriceReader

type GasPriceReader func(block *ethmonitor.Block) []*big.Int

type SuggestedGasPrice

type SuggestedGasPrice struct {
	Instant  uint64 `json:"instant"` // in gwei
	Fast     uint64 `json:"fast"`
	Standard uint64 `json:"standard"`
	Slow     uint64 `json:"slow"`

	InstantWei  *big.Int `json:"instantWei"`
	FastWei     *big.Int `json:"fastWei"`
	StandardWei *big.Int `json:"standardWei"`
	SlowWei     *big.Int `json:"slowWei"`

	BlockNum  *big.Int `json:"blockNum"`
	BlockTime uint64   `json:"blockTime"`
}