Versions in this module Expand all Collapse all v1 v1.1.0 Aug 7, 2026 Changes in this version + const DefaultBlobThreshold + const MaxMaxQueryBytesUnused + type Config struct + VerboseLogging bool + type DSOpts = datasource.DSOpts + type DataSource = datasource.DataSource + type Observation struct + AttestedPredecessorRetirement []byte + RemoveChannelIDs map[llotypes.ChannelID]struct{} + ShouldRetire bool + StreamValues protocol.StreamValues + UnixTimestampNanoseconds uint64 + UpdateChannelDefinitions llotypes.ChannelDefinitions + type Plugin struct + BlobThreshold int + ChannelDefinitionCache llotypes.ChannelDefinitionCache + Config Config + ConfigDigest ocrtypes.ConfigDigest + DataSource DataSource + DefaultMinReportIntervalNanoseconds uint64 + DonID uint32 + F int + Logger logger.Logger + MaxDurationObservation time.Duration + N int + OptsCache *protocol.OptsCache + OutcomeTelemetryCh chan<- *protocol.LLOOutcomeTelemetry + PredecessorConfigDigest *ocrtypes.ConfigDigest + PredecessorRetirementReportCache protocol.PredecessorRetirementReportCache + ProtocolVersion uint32 + ReportCodecs map[llotypes.ReportFormat]protocol.ReportCodec + ReportTelemetryCh chan<- *protocol.LLOReportTelemetry + RetirementReportCodec protocol.RetirementReportCodec + ShouldRetireCache ShouldRetireCache + func (p *Plugin) Close() error + func (p *Plugin) Committed(ctx context.Context, seqNr uint64, _ ocr3_1types.KeyValueStateReader) error + func (p *Plugin) Observation(ctx context.Context, seqNr uint64, _ ocrtypes.AttributedQuery, ...) (ocrtypes.Observation, error) + func (p *Plugin) ObservationQuorum(ctx context.Context, seqNr uint64, _ ocrtypes.AttributedQuery, ...) (bool, error) + func (p *Plugin) Query(ctx context.Context, seqNr uint64, _ ocr3_1types.KeyValueStateReader, ...) (ocrtypes.Query, error) + func (p *Plugin) Reports(ctx context.Context, seqNr uint64, ...) ([]ocr3types.ReportPlus[llotypes.ReportInfo], error) + func (p *Plugin) ShouldAcceptAttestedReport(context.Context, uint64, ocr3types.ReportWithInfo[llotypes.ReportInfo]) (bool, error) + func (p *Plugin) ShouldTransmitAcceptedReport(context.Context, uint64, ocr3types.ReportWithInfo[llotypes.ReportInfo]) (bool, error) + func (p *Plugin) StateTransition(ctx context.Context, seqNr uint64, _ ocrtypes.AttributedQuery, ...) (ocr3_1types.ReportsPlusPrecursor, error) + func (p *Plugin) ValidateObservation(ctx context.Context, seqNr uint64, _ ocrtypes.AttributedQuery, ...) error + type PluginFactory struct + func NewPluginFactory(p PluginFactoryParams) *PluginFactory + func (f *PluginFactory) NewReportingPlugin(ctx context.Context, cfg ocr3types.ReportingPluginConfig, ...) (ocr3_1types.ReportingPlugin[llotypes.ReportInfo], ...) + type PluginFactoryParams struct + BlobThreshold int + DonID uint32 + OutcomeTelemetryCh chan<- *protocol.LLOOutcomeTelemetry + ReportCodecs map[llotypes.ReportFormat]protocol.ReportCodec + ReportTelemetryCh chan<- *protocol.LLOReportTelemetry + type ShouldRetireCache interface + ShouldRetire func(digest ocrtypes.ConfigDigest) (bool, error)
Go to main page