encoding

package
v2.11.0 Latest Latest
Warning

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

Go to latest
Published: May 1, 2024 License: MIT Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source
const (
	// upkeep failure onchain reasons
	UpkeepFailureReasonNone                    UpkeepFailureReason = 0
	UpkeepFailureReasonUpkeepCancelled         UpkeepFailureReason = 1
	UpkeepFailureReasonUpkeepPaused            UpkeepFailureReason = 2
	UpkeepFailureReasonTargetCheckReverted     UpkeepFailureReason = 3
	UpkeepFailureReasonUpkeepNotNeeded         UpkeepFailureReason = 4
	UpkeepFailureReasonPerformDataExceedsLimit UpkeepFailureReason = 5
	UpkeepFailureReasonInsufficientBalance     UpkeepFailureReason = 6
	UpkeepFailureReasonMercuryCallbackReverted UpkeepFailureReason = 7
	UpkeepFailureReasonRevertDataExceedsLimit  UpkeepFailureReason = 8
	UpkeepFailureReasonRegistryPaused          UpkeepFailureReason = 9
	// leaving a gap here for more onchain failure reasons in the future
	// upkeep failure offchain reasons
	UpkeepFailureReasonMercuryAccessNotAllowed UpkeepFailureReason = 32
	UpkeepFailureReasonTxHashNoLongerExists    UpkeepFailureReason = 33
	UpkeepFailureReasonInvalidRevertDataInput  UpkeepFailureReason = 34
	UpkeepFailureReasonSimulationFailed        UpkeepFailureReason = 35
	UpkeepFailureReasonTxHashReorged           UpkeepFailureReason = 36

	// pipeline execution error
	NoPipelineError               PipelineExecutionState = 0
	CheckBlockTooOld              PipelineExecutionState = 1
	CheckBlockInvalid             PipelineExecutionState = 2
	RpcFlakyFailure               PipelineExecutionState = 3
	MercuryFlakyFailure           PipelineExecutionState = 4
	PackUnpackDecodeFailed        PipelineExecutionState = 5
	PrivilegeConfigUnmarshalError PipelineExecutionState = 6
)

Variables

View Source
var (
	ErrEmptyResults = fmt.Errorf("empty results; cannot encode")
)

Functions

func GetIneligibleCheckResultWithoutPerformData

func GetIneligibleCheckResultWithoutPerformData(p ocr2keepers.UpkeepPayload, reason UpkeepFailureReason, state PipelineExecutionState, retryable bool) ocr2keepers.CheckResult

GetIneligibleCheckResultWithoutPerformData returns an ineligible check result with ineligibility reason and pipeline execution state but without perform data

func NewAbiPacker

func NewAbiPacker() *abiPacker

func NewReportEncoder

func NewReportEncoder(p Packer) ocr2keepers.Encoder

Types

type ErrCode added in v2.10.0

type ErrCode uint32

ErrCode is used for invoking an error handler with a specific error code.

const (
	ErrCodeNil                         ErrCode = 0
	ErrCodeStreamsPartialContent       ErrCode = 808206
	ErrCodeStreamsBadRequest           ErrCode = 808400
	ErrCodeStreamsUnauthorized         ErrCode = 808401
	ErrCodeStreamsNotFound             ErrCode = 808404
	ErrCodeStreamsInternalError        ErrCode = 808500
	ErrCodeStreamsBadGateway           ErrCode = 808502
	ErrCodeStreamsServiceUnavailable   ErrCode = 808503
	ErrCodeStreamsStatusGatewayTimeout ErrCode = 808504
	ErrCodeStreamsBadResponse          ErrCode = 808600
	ErrCodeStreamsTimeout              ErrCode = 808601
	ErrCodeStreamsUnknownError         ErrCode = 808700
)

func HttpToStreamsErrCode added in v2.10.0

func HttpToStreamsErrCode(statusCode int) ErrCode

type Packer

type Packer interface {
	UnpackCheckResult(payload ocr2keepers.UpkeepPayload, raw string) (ocr2keepers.CheckResult, error)
	UnpackPerformResult(raw string) (PipelineExecutionState, bool, error)
	UnpackLogTriggerConfig(raw []byte) (ac.IAutomationV21PlusCommonLogTriggerConfig, error)
	PackReport(report ac.IAutomationV21PlusCommonReport) ([]byte, error)
	UnpackReport(raw []byte) (ac.IAutomationV21PlusCommonReport, error)
}

type PipelineExecutionState added in v2.9.0

type PipelineExecutionState uint8

type UpkeepFailureReason added in v2.9.0

type UpkeepFailureReason uint8

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL