validate

Documentation

Index

• func ToLocalConfig(ocr2Config OCR2Config, insConf InsecureConfig, spec job.OCR2OracleSpec) (types.LocalConfig, error)
• func ValidatedOracleSpecToml(ctx context.Context, config OCR2Config, insConf InsecureConfig, ...) (job.Job, error)
• type Config
• type InsecureConfig
• type OCR2Config
• type OCR2GenericPluginConfig
  • func (o *OCR2GenericPluginConfig) UnmarshalJSON(data []byte) error
• type OCR2OnchainSigningStrategy
  • func (o *OCR2OnchainSigningStrategy) ConfigCopy() job.JSONConfig
  • func (o *OCR2OnchainSigningStrategy) IsMultiChain() bool
  • func (o *OCR2OnchainSigningStrategy) KeyBundleID(name string) (string, error)
  • func (o *OCR2OnchainSigningStrategy) PublicKey() (string, error)
  • func (o *OCR2OnchainSigningStrategy) UnmarshalJSON(data []byte) error
• type PipelineSpec

Functions

func ToLocalConfig

func ToLocalConfig(ocr2Config OCR2Config, insConf InsecureConfig, spec job.OCR2OracleSpec) (types.LocalConfig, error)

ToLocalConfig creates a OCR2 LocalConfig from the global config and the OCR2 spec.

func ValidatedOracleSpecToml

func ValidatedOracleSpecToml(ctx context.Context, config OCR2Config, insConf InsecureConfig, tomlString string, rc plugins.RegistrarConfig) (job.Job, error)

ValidatedOracleSpecToml validates an oracle spec that came from TOML

Types

type Config

type Config struct {
	Pipelines    []PipelineSpec `json:"pipelines"`
	PluginConfig map[string]any `json:"pluginConfig"`
}

type InsecureConfig

type InsecureConfig interface {
	OCRDevelopmentMode() bool
}

type OCR2Config

type OCR2Config interface {
	BlockchainTimeout() time.Duration
	ContractConfirmations() uint16
	ContractPollInterval() time.Duration
	ContractTransmitterTransmitTimeout() time.Duration
	DatabaseTimeout() time.Duration
	DefaultTransactionQueueDepth() uint32
	SimulateTransactions() bool
	TraceLogging() bool
}

OCR2Config contains OCR2 configurations for a job.

type OCR2GenericPluginConfig

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

func (*OCR2GenericPluginConfig) UnmarshalJSON

func (o *OCR2GenericPluginConfig) UnmarshalJSON(data []byte) error

type OCR2OnchainSigningStrategy

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

func (*OCR2OnchainSigningStrategy) ConfigCopy

func (o *OCR2OnchainSigningStrategy) ConfigCopy() job.JSONConfig

func (*OCR2OnchainSigningStrategy) IsMultiChain

func (o *OCR2OnchainSigningStrategy) IsMultiChain() bool

func (*OCR2OnchainSigningStrategy) KeyBundleID

func (o *OCR2OnchainSigningStrategy) KeyBundleID(name string) (string, error)

func (*OCR2OnchainSigningStrategy) PublicKey

func (o *OCR2OnchainSigningStrategy) PublicKey() (string, error)

func (*OCR2OnchainSigningStrategy) UnmarshalJSON

func (o *OCR2OnchainSigningStrategy) UnmarshalJSON(data []byte) error

type PipelineSpec

type PipelineSpec struct {
	Name string `json:"name"`
	Spec string `json:"spec"`
}