jobs

Documentation

Index

• type AlreadyExists
  • func NewAlreadyExists(instance uint64) (*AlreadyExists, error)
  • func (a *AlreadyExists) Name() string
  • func (a *AlreadyExists) Run(client *ethclient.Client, log hclog.Logger) error
  • func (a *AlreadyExists) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, ...)
  • func (a *AlreadyExists) Stop() <-chan struct{}
• type AlreadyExistsConfig
• type GoodSender
  • func NewGoodSender(instance uint64) (*GoodSender, error)
  • func (g *GoodSender) Name() string
  • func (g *GoodSender) Run(client *ethclient.Client, log hclog.Logger) error
  • func (g *GoodSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, ...)
  • func (g *GoodSender) Stop() <-chan struct{}
• type GoodSenderConfig
• type Job
• type JobConfig
• type Monitor
  • func NewMonitor() (*Monitor, error)
  • func (j *Monitor) Name() string
  • func (j *Monitor) Run(client *ethclient.Client, log hclog.Logger) error
  • func (j *Monitor) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, ...)
  • func (j *Monitor) Stop() <-chan struct{}
• type MultiSender
  • func NewMultiSender(instance uint64) (*MultiSender, error)
  • func (m *MultiSender) Name() string
  • func (m *MultiSender) Run(client *ethclient.Client, log hclog.Logger) error
  • func (m *MultiSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, ...)
  • func (m *MultiSender) Stop() <-chan struct{}
• type MultiSenderConfig
• type NoWaitSender
  • func NewNoWaitSender(instance uint64) (*NoWaitSender, error)
  • func (n *NoWaitSender) Name() string
  • func (n *NoWaitSender) Run(client *ethclient.Client, log hclog.Logger) error
  • func (n *NoWaitSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, ...)
  • func (n *NoWaitSender) Stop() <-chan struct{}
• type NoWaitSenderConfig
• type NonceGapSender
  • func NewNonceGapSender(instance uint64) (*NonceGapSender, error)
  • func (n *NonceGapSender) Name() string
  • func (n *NonceGapSender) Run(client *ethclient.Client, log hclog.Logger) error
  • func (n *NonceGapSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, ...)
  • func (n *NonceGapSender) Stop() <-chan struct{}
• type NonceGapSenderConfig
• type NonceTooHighSender
  • func NewNonceTooHighSender(instance uint64) (*NonceTooHighSender, error)
  • func (n *NonceTooHighSender) Name() string
  • func (n *NonceTooHighSender) Run(client *ethclient.Client, log hclog.Logger) error
  • func (n *NonceTooHighSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int)
  • func (n *NonceTooHighSender) Stop() <-chan struct{}
• type NonceTooHighSenderConfig
• type PoolStatus
• type StateFiller
  • func NewStateFiller(instance uint64) (*StateFiller, error)
  • func (g *StateFiller) Name() string
  • func (g *StateFiller) Run(client *ethclient.Client, log hclog.Logger) error
  • func (g *StateFiller) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, ...)
  • func (g *StateFiller) Stop() <-chan struct{}
• type StateFillerConfig

Types

type AlreadyExists

type AlreadyExists struct {
	Config AlreadyExistsConfig
	// contains filtered or unexported fields
}

func NewAlreadyExists

func NewAlreadyExists(instance uint64) (*AlreadyExists, error)

func (*AlreadyExists) Name

func (a *AlreadyExists) Name() string

func (*AlreadyExists) Run

func (a *AlreadyExists) Run(client *ethclient.Client, log hclog.Logger) error

func (*AlreadyExists) SetWallet

func (a *AlreadyExists) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)

func (*AlreadyExists) Stop

func (a *AlreadyExists) Stop() <-chan struct{}

type AlreadyExistsConfig

type AlreadyExistsConfig struct {
	JobConfig
}

type GoodSender

type GoodSender struct {
	Config GoodSenderConfig
	// contains filtered or unexported fields
}

func NewGoodSender

func NewGoodSender(instance uint64) (*GoodSender, error)

func (*GoodSender) Name

func (g *GoodSender) Name() string

func (*GoodSender) Run

func (g *GoodSender) Run(client *ethclient.Client, log hclog.Logger) error

func (*GoodSender) SetWallet

func (g *GoodSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)

func (*GoodSender) Stop

func (g *GoodSender) Stop() <-chan struct{}

type GoodSenderConfig

type GoodSenderConfig struct {
	JobConfig
}

type Job

type Job interface {
	Run(client *ethclient.Client, log hclog.Logger) error
	Name() string
	SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)
	Stop() <-chan struct{}
}

type JobConfig

type JobConfig struct {
	Address  *common.Address
	Key      *ecdsa.PrivateKey
	ChainID  *big.Int
	GasPrice *big.Int
}

type Monitor

type Monitor struct {
	Job
	// contains filtered or unexported fields
}

func NewMonitor

func NewMonitor() (*Monitor, error)

func (*Monitor) Name

func (j *Monitor) Name() string

func (*Monitor) Run

func (j *Monitor) Run(client *ethclient.Client, log hclog.Logger) error

func (*Monitor) SetWallet

func (j *Monitor) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)

func (*Monitor) Stop

func (j *Monitor) Stop() <-chan struct{}

type MultiSender

type MultiSender struct {
	Config MultiSenderConfig
	// contains filtered or unexported fields
}

func NewMultiSender

func NewMultiSender(instance uint64) (*MultiSender, error)

func (*MultiSender) Name

func (m *MultiSender) Name() string

func (*MultiSender) Run

func (m *MultiSender) Run(client *ethclient.Client, log hclog.Logger) error

func (*MultiSender) SetWallet

func (m *MultiSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)

func (*MultiSender) Stop

func (m *MultiSender) Stop() <-chan struct{}

type MultiSenderConfig

type MultiSenderConfig struct {
	JobConfig
}

type NoWaitSender

type NoWaitSender struct {
	Config NoWaitSenderConfig
	// contains filtered or unexported fields
}

func NewNoWaitSender

func NewNoWaitSender(instance uint64) (*NoWaitSender, error)

func (*NoWaitSender) Name

func (n *NoWaitSender) Name() string

func (*NoWaitSender) Run

func (n *NoWaitSender) Run(client *ethclient.Client, log hclog.Logger) error

func (*NoWaitSender) SetWallet

func (n *NoWaitSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)

func (*NoWaitSender) Stop

func (n *NoWaitSender) Stop() <-chan struct{}

type NoWaitSenderConfig

type NoWaitSenderConfig struct {
	JobConfig
}

type NonceGapSender

type NonceGapSender struct {
	Config NonceGapSenderConfig
	// contains filtered or unexported fields
}

func NewNonceGapSender

func NewNonceGapSender(instance uint64) (*NonceGapSender, error)

func (*NonceGapSender) Name

func (n *NonceGapSender) Name() string

func (*NonceGapSender) Run

func (n *NonceGapSender) Run(client *ethclient.Client, log hclog.Logger) error

func (*NonceGapSender) SetWallet

func (n *NonceGapSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)

func (*NonceGapSender) Stop

func (n *NonceGapSender) Stop() <-chan struct{}

type NonceGapSenderConfig

type NonceGapSenderConfig struct {
	JobConfig
}

type NonceTooHighSender

type NonceTooHighSender struct {
	Config NonceTooHighSenderConfig
	// contains filtered or unexported fields
}

func NewNonceTooHighSender

func NewNonceTooHighSender(instance uint64) (*NonceTooHighSender, error)

func (*NonceTooHighSender) Name

func (n *NonceTooHighSender) Name() string

func (*NonceTooHighSender) Run

func (n *NonceTooHighSender) Run(client *ethclient.Client, log hclog.Logger) error

func (*NonceTooHighSender) SetWallet

func (n *NonceTooHighSender) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int)

func (*NonceTooHighSender) Stop

func (n *NonceTooHighSender) Stop() <-chan struct{}

type NonceTooHighSenderConfig

type NonceTooHighSenderConfig struct {
	JobConfig
}

type PoolStatus

type PoolStatus struct {
	BaseFee string `json:"baseFee"`
	Pending string `json:"pending"`
	Queued  string `json:"queued"`
}

type StateFiller

type StateFiller struct {
	Config StateFillerConfig
	// contains filtered or unexported fields
}

func NewStateFiller

func NewStateFiller(instance uint64) (*StateFiller, error)

func (*StateFiller) Name

func (g *StateFiller) Name() string

func (*StateFiller) Run

func (g *StateFiller) Run(client *ethclient.Client, log hclog.Logger) error

func (*StateFiller) SetWallet

func (g *StateFiller) SetWallet(address *common.Address, privateKey *ecdsa.PrivateKey, chainID *big.Int, gasPrice *big.Int)

func (*StateFiller) Stop

func (g *StateFiller) Stop() <-chan struct{}

type StateFillerConfig

type StateFillerConfig struct {
	JobConfig
}