ocr3

Documentation

Index

• type Capability
  • func NewOCR3(config Config) *Capability
  • func (o *Capability) NewReportingPluginFactory(ctx context.Context, cfg core.ReportingPluginServiceConfig, ...) (core.OCR3ReportingPluginFactory, error)
  • func (o *Capability) NewValidationService(ctx context.Context) (core.ValidationService, error)
• type Config
• type ContractTransmitter
  • func NewContractTransmitter(lggr logger.Logger, registry core.CapabilitiesRegistry, fromAccount string) *ContractTransmitter
  • func (c *ContractTransmitter) FromAccount() (types.Account, error)
  • func (c *ContractTransmitter) Transmit(ctx context.Context, configDigest types.ConfigDigest, seqNr uint64, ...) error

Types

type Capability

type Capability struct {
	loop.Plugin
	reportingplugins.PluginProviderServer
	// contains filtered or unexported fields
}

func NewOCR3

func NewOCR3(config Config) *Capability

func (*Capability) NewReportingPluginFactory

func (o *Capability) NewReportingPluginFactory(ctx context.Context, cfg core.ReportingPluginServiceConfig,
	provider commontypes.PluginProvider, pipelineRunner core.PipelineRunnerService, telemetry core.TelemetryClient,
	errorLog core.ErrorLog, capabilityRegistry core.CapabilitiesRegistry, keyValueStore core.KeyValueStore,
	relayerSet core.RelayerSet) (core.OCR3ReportingPluginFactory, error)

func (*Capability) NewValidationService

func (o *Capability) NewValidationService(ctx context.Context) (core.ValidationService, error)

type Config

type Config struct {
	RequestTimeout    *time.Duration
	BatchSize         int
	Logger            logger.Logger
	AggregatorFactory types.AggregatorFactory
	EncoderFactory    types.EncoderFactory
	SendBufferSize    int
	// contains filtered or unexported fields
}

type ContractTransmitter

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

ContractTransmitter is a custom transmitter for the OCR3 capability. When called it will forward the report + its signatures back to the OCR3 capability by making a call to Execute with a special "method" parameter.

func NewContractTransmitter

func NewContractTransmitter(lggr logger.Logger, registry core.CapabilitiesRegistry, fromAccount string) *ContractTransmitter

func (*ContractTransmitter) FromAccount

func (c *ContractTransmitter) FromAccount() (types.Account, error)

func (*ContractTransmitter) Transmit

func (c *ContractTransmitter) Transmit(ctx context.Context, configDigest types.ConfigDigest, seqNr uint64, rwi ocr3types.ReportWithInfo[[]byte], signatures []types.AttributedOnchainSignature) error