handler

package
v1.11.0-clf-20230127 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 27, 2023 License: MIT Imports: 64 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBaseHandler 

func NewBaseHandler(cfg *config.Config) *baseHandler

NewBaseHandler is the constructor of baseHandler

func OCR2AutomationReports added in v1.12.0 

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

func OCR2GetConfig added in v1.12.0 

func OCR2GetConfig(hdlr *baseHandler, registry_addr string) error

Types

type BaseOCR2Tx added in v1.12.0 

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

func NewBaseOCR2Tx added in v1.12.0 

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

func (*BaseOCR2Tx) DataMap added in v1.12.0 

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

func (*BaseOCR2Tx) Method added in v1.12.0 

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 added in v1.10.0 

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 added in v1.12.0 

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 added in v1.6.0 

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 added in v1.10.0 

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 added in v1.10.0 

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 added in v1.10.0 

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

UpdateRegistry attaches to an existing registry and possibly updates registry config

func (*Keeper) UpkeepCounterEvents added in v1.3.0 

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 added in v1.3.0 

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 added in v1.3.0 

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

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

type OCR2ReportDataElem added in v1.12.0 

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

type OCR2SetConfigTx added in v1.12.0 

type OCR2SetConfigTx struct {
	BaseOCR2Tx
}

func NewOCR2SetConfigTx added in v1.12.0 

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

func (*OCR2SetConfigTx) Config added in v1.12.0 

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

type OCR2Transaction added in v1.12.0 

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

func NewOCR2Transaction added in v1.12.0 

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

func (*OCR2Transaction) BlockNumber added in v1.12.0 

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

func (*OCR2Transaction) ChainId added in v1.12.0 

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

func (*OCR2Transaction) DecodeError added in v1.12.0 

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

func (*OCR2Transaction) From added in v1.12.0 

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

func (*OCR2Transaction) Method added in v1.12.0 

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

func (*OCR2Transaction) To added in v1.12.0 

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

func (*OCR2Transaction) TransactionHash added in v1.12.0 

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

type OCR2TransmitTx added in v1.12.0 

type OCR2TransmitTx struct {
	OCR2Transaction
}

func NewOCR2TransmitTx added in v1.12.0 

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

func (*OCR2TransmitTx) BatchElem added in v1.12.0 

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

func (*OCR2TransmitTx) SetStaticValues added in v1.12.0 

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

func (*OCR2TransmitTx) UpkeepsInTransmit added in v1.12.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.