handler

Documentation

Index

• func NewBaseHandler(cfg *config.Config) *baseHandler
• func OCR2AutomationReports(hdlr *baseHandler, txs []string) error
• func OCR2GetConfig(hdlr *baseHandler, registry_addr string) error
• type BaseOCR2Tx
  • func NewBaseOCR2Tx(tx *types.Transaction) (*BaseOCR2Tx, error)
  • func (tx *BaseOCR2Tx) DataMap() (map[string]interface{}, error)
  • func (tx *BaseOCR2Tx) Method() (*abi.Method, error)
• type Feed
  • func NewFeed(cfg *config.Config) *Feed
  • func (h *Feed) DeployDerivedPriceFeed(ctx context.Context)
  • func (h Feed) RevertReason(hash string)
  • func (h Feed) StartBootstrapNode(ctx context.Context, addr string, uiPort, p2pv2Port int)
• type JsonError
• type Keeper
  • func NewKeeper(cfg *config.Config) *Keeper
  • func (k *Keeper) CreateJob(ctx context.Context)
  • func (k *Keeper) DeployKeepers(ctx context.Context)
  • func (k *Keeper) DeployRegistry(ctx context.Context)
  • func (k *Keeper) LaunchAndTest(ctx context.Context, withdraw bool, printLogs bool)
  • func (h Keeper) RevertReason(hash string)
  • func (h Keeper) StartBootstrapNode(ctx context.Context, addr string, uiPort, p2pv2Port int)
  • func (k *Keeper) UpdateRegistry(ctx context.Context)
  • func (k *Keeper) UpkeepCounterEvents(ctx context.Context, hexAddr string, fromBlock, toBlock uint64)
  • func (k *Keeper) UpkeepHistory(ctx context.Context, upkeepId *big.Int, from, to, gasPrice uint64)
  • func (k *Keeper) Withdraw(ctx context.Context, hexAddr string)
• type OCR2ReportDataElem
• type OCR2SetConfigTx
  • func NewOCR2SetConfigTx(tx *types.Transaction) (*OCR2SetConfigTx, error)
  • func (tx *OCR2SetConfigTx) Config() (ocrtypes.ContractConfig, error)
• type OCR2Transaction
  • func NewOCR2Transaction(raw map[string]interface{}) (*OCR2Transaction, error)
  • func (t *OCR2Transaction) BlockNumber() (uint64, error)
  • func (t *OCR2Transaction) ChainId() *big.Int
  • func (t *OCR2Transaction) DecodeError(b []byte) string
  • func (t *OCR2Transaction) From() (common.Address, error)
  • func (t *OCR2Transaction) Method() (*abi.Method, error)
  • func (t *OCR2Transaction) To() *common.Address
  • func (t *OCR2Transaction) TransactionHash() common.Hash
• type OCR2TransmitTx
  • func NewOCR2TransmitTx(raw map[string]interface{}) (*OCR2TransmitTx, error)
  • func (t *OCR2TransmitTx) BatchElem() (rpc.BatchElem, error)
  • func (t *OCR2TransmitTx) SetStaticValues(elem *OCR2ReportDataElem)
  • func (t *OCR2TransmitTx) UpkeepsInTransmit() ([]plugintypes.UpkeepResult, error)

Functions

func NewBaseHandler

func NewBaseHandler(cfg *config.Config) *baseHandler

NewBaseHandler is the constructor of baseHandler

func OCR2AutomationReports

func OCR2AutomationReports(hdlr *baseHandler, txs []string) error

func OCR2GetConfig

func OCR2GetConfig(hdlr *baseHandler, registry_addr string) error

Types

type BaseOCR2Tx

type BaseOCR2Tx struct {
	types.Transaction
	// contains filtered or unexported fields
}

func NewBaseOCR2Tx

func NewBaseOCR2Tx(tx *types.Transaction) (*BaseOCR2Tx, error)

func (*BaseOCR2Tx) DataMap

func (tx *BaseOCR2Tx) DataMap() (map[string]interface{}, error)

func (*BaseOCR2Tx) Method

func (tx *BaseOCR2Tx) Method() (*abi.Method, error)

type Feed

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

Feed is the price feeds commands handler

func NewFeed

func NewFeed(cfg *config.Config) *Feed

NewFeed is the constructor of Feed

func (*Feed) DeployDerivedPriceFeed

func (h *Feed) DeployDerivedPriceFeed(ctx context.Context)

DeployDerivedPriceFeed deploys and approves the derived price feed.

func (Feed) RevertReason

func (h Feed) RevertReason(hash string)

RevertReason attempts to fetch more info on failed TX

func (Feed) StartBootstrapNode

func (h Feed) StartBootstrapNode(ctx context.Context, addr string, uiPort, p2pv2Port int)

StartBootstrapNode starts the ocr2 bootstrap node with the given contract address

type JsonError

type JsonError interface {
	Error() string
	// ErrorCode() int
	ErrorData() interface{}
}

JsonError is a rpc.jsonError interface

type Keeper

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

Keeper is the keepers commands handler

func NewKeeper

func NewKeeper(cfg *config.Config) *Keeper

NewKeeper creates new instance of Keeper

func (*Keeper) CreateJob

func (k *Keeper) CreateJob(ctx context.Context)

func (*Keeper) DeployKeepers

func (k *Keeper) DeployKeepers(ctx context.Context)

DeployKeepers contains a logic to deploy keepers.

func (*Keeper) DeployRegistry

func (k *Keeper) DeployRegistry(ctx context.Context)

DeployRegistry deploys a new keeper registry.

func (*Keeper) LaunchAndTest

func (k *Keeper) LaunchAndTest(ctx context.Context, withdraw bool, printLogs bool)

LaunchAndTest launches keeper registry, chainlink nodes, upkeeps and start performing. 1. launch chainlink node using docker image 2. get keeper registry instance, deploy if needed 3. deploy upkeeps 4. create keeper jobs 5. fund nodes if needed 6. set keepers in the registry 7. withdraw funds after tests are done -> TODO: wait until tests are done instead of cancel manually

func (Keeper) RevertReason

func (h Keeper) RevertReason(hash string)

RevertReason attempts to fetch more info on failed TX

func (Keeper) StartBootstrapNode

func (h Keeper) StartBootstrapNode(ctx context.Context, addr string, uiPort, p2pv2Port int)

StartBootstrapNode starts the ocr2 bootstrap node with the given contract address

func (*Keeper) UpdateRegistry

func (k *Keeper) UpdateRegistry(ctx context.Context)

UpdateRegistry attaches to an existing registry and possibly updates registry config

func (*Keeper) UpkeepCounterEvents

func (k *Keeper) UpkeepCounterEvents(ctx context.Context, hexAddr string, fromBlock, toBlock uint64)

UpkeepCounterEvents print out emitted events and write to csv file

func (*Keeper) UpkeepHistory

func (k *Keeper) UpkeepHistory(ctx context.Context, upkeepId *big.Int, from, to, gasPrice uint64)

UpkeepHistory prints the checkUpkeep status and keeper responsibility for a given upkeep in a set block range

func (*Keeper) Withdraw

func (k *Keeper) Withdraw(ctx context.Context, hexAddr string)

Withdraw takes a keeper registry address, cancels all upkeeps and withdraws the funds

type OCR2ReportDataElem

type OCR2ReportDataElem struct {
	Err                string
	From               string
	To                 string
	ChainID            string
	BlockNumber        string
	PerformKeys        string
	PerformBlockChecks string
}

type OCR2SetConfigTx

type OCR2SetConfigTx struct {
	BaseOCR2Tx
}

func NewOCR2SetConfigTx

func NewOCR2SetConfigTx(tx *types.Transaction) (*OCR2SetConfigTx, error)

func (*OCR2SetConfigTx) Config

func (tx *OCR2SetConfigTx) Config() (ocrtypes.ContractConfig, error)

type OCR2Transaction

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

func NewOCR2Transaction

func NewOCR2Transaction(raw map[string]interface{}) (*OCR2Transaction, error)

func (*OCR2Transaction) BlockNumber

func (t *OCR2Transaction) BlockNumber() (uint64, error)

func (*OCR2Transaction) ChainId

func (t *OCR2Transaction) ChainId() *big.Int

func (*OCR2Transaction) DecodeError

func (t *OCR2Transaction) DecodeError(b []byte) string

func (*OCR2Transaction) From

func (t *OCR2Transaction) From() (common.Address, error)

func (*OCR2Transaction) Method

func (t *OCR2Transaction) Method() (*abi.Method, error)

func (*OCR2Transaction) To

func (t *OCR2Transaction) To() *common.Address

func (*OCR2Transaction) TransactionHash

func (t *OCR2Transaction) TransactionHash() common.Hash

type OCR2TransmitTx

type OCR2TransmitTx struct {
	OCR2Transaction
}

func NewOCR2TransmitTx

func NewOCR2TransmitTx(raw map[string]interface{}) (*OCR2TransmitTx, error)

func (*OCR2TransmitTx) BatchElem

func (t *OCR2TransmitTx) BatchElem() (rpc.BatchElem, error)

func (*OCR2TransmitTx) SetStaticValues

func (t *OCR2TransmitTx) SetStaticValues(elem *OCR2ReportDataElem)

func (*OCR2TransmitTx) UpkeepsInTransmit

func (t *OCR2TransmitTx) UpkeepsInTransmit() ([]plugintypes.UpkeepResult, error)