Documentation
¶
Index ¶
- func NewCapability(s *requests.Store, clock clockwork.Clock, requestTimeout time.Duration, ...) *capability
- func NewReportingPlugin(s *requests.Store, r CapabilityIface, batchSize int, ...) (*reportingPlugin, error)
- type Capability
- type CapabilityIface
- type Config
- type ContractTransmitter
- type ValueMapEncoder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCapability ¶ added in v0.5.0
func NewReportingPlugin ¶ added in v0.5.0
func NewReportingPlugin(s *requests.Store, r CapabilityIface, batchSize int, config ocr3types.ReportingPluginConfig, outcomePruningThreshold uint64, lggr logger.Logger) (*reportingPlugin, 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) Close ¶ added in v0.4.0
func (o *Capability) Close() error
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 CapabilityIface ¶ added in v0.5.0
type CapabilityIface interface {
GetAggregator(workflowID string) (pbtypes.Aggregator, error)
GetEncoderByWorkflowID(workflowID string) (pbtypes.Encoder, error)
GetEncoderByName(encoderName string, config *values.Map) (pbtypes.Encoder, error)
GetRegisteredWorkflowsIDs() []string
UnregisterWorkflowID(workflowID string)
}
type Config ¶
type Config struct {
RequestTimeout *time.Duration
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 (*ContractTransmitter) SetCapability ¶ added in v0.5.0
func (c *ContractTransmitter) SetCapability(capability capabilities.ExecutableCapability)
func (*ContractTransmitter) Transmit ¶
func (c *ContractTransmitter) Transmit(ctx context.Context, configDigest types.ConfigDigest, seqNr uint64, rwi ocr3types.ReportWithInfo[[]byte], signatures []types.AttributedOnchainSignature) error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.