Versions in this module Expand all Collapse all v1 v1.1.3 Nov 3, 2026 v1.1.2 Nov 2, 2026 Changes in this version type Plugin + ExpressionPins *calculated.ExpressionPins v1.1.1 Aug 26, 2026 v1.1.0 Aug 7, 2026 v1.0.0 Jul 14, 2026 Changes in this version + const MaxObservationLength + const MaxOutcomeLength + const MaxReportLength + func IsSecondsResolution(cd llocommon.ChannelDefinitionWithID, optsCache *llocommon.OptsCache) bool + func MakeChannelHash(cd llocommon.ChannelDefinitionWithID) llocommon.ChannelHash + func StreamAggregatesToProtoOutcome(in llocommon.StreamAggregates) (out []*llocommon.LLOStreamAggregate, err error) + type Config struct + VerboseLogging bool + type DSOpts interface + ConfigDigest func() ocr2types.ConfigDigest + ObservationTimestamp func() time.Time + OutCtx func() ocr3types.OutcomeContext + OutcomeCodec func() OutcomeCodec + SeqNr func() uint64 + VerboseLogging func() bool + type DataSource interface + Observe func(ctx context.Context, streamValues llocommon.StreamValues, opts DSOpts) error + type GoldenOutcomeCase struct + Name string + Outcome Outcome + OutputFile string + func GoldenOutcomeCases() []GoldenOutcomeCase + type Observation struct + AttestedPredecessorRetirement []byte + RemoveChannelIDs map[llotypes.ChannelID]struct{} + ShouldRetire bool + StreamValues llocommon.StreamValues + UnixTimestampNanoseconds uint64 + UpdateChannelDefinitions llotypes.ChannelDefinitions + type ObservationCodec interface + Decode func(encoded types.Observation) (obs Observation, err error) + Encode func(obs Observation) (types.Observation, error) + func NewProtoObservationCodec(lggr logger.Logger, enableCompression bool) (ObservationCodec, error) + type Outcome struct + ChannelDefinitions llotypes.ChannelDefinitions + LifeCycleStage llotypes.LifeCycleStage + ObservationTimestampNanoseconds uint64 + StreamAggregates llocommon.StreamAggregates + ValidAfterNanoseconds map[llotypes.ChannelID]uint64 + func (out *Outcome) GenRetirementReport(protocolVersion uint32) llocommon.RetirementReport + func (out *Outcome) IsReportable(channelID llotypes.ChannelID, protocolVersion uint32, minReportInterval uint64, ...) *UnreportableChannelError + func (out *Outcome) ReportableChannels(protocolVersion uint32, defaultMinReportInterval uint64, ...) (reportable []llotypes.ChannelID, unreportable []*UnreportableChannelError) + type OutcomeCodec interface + Decode func(encoded ocr3types.Outcome) (outcome Outcome, err error) + Encode func(outcome Outcome) (ocr3types.Outcome, error) + func GetOutcomeCodec(c llocommon.OffchainConfig) OutcomeCodec + type Plugin struct + ChannelDefinitionCache llotypes.ChannelDefinitionCache + Config Config + ConfigDigest types.ConfigDigest + DataSource DataSource + DefaultMinReportIntervalNanoseconds uint64 + DonID uint32 + F int + Logger logger.Logger + MaxDurationObservation time.Duration + N int + ObservationCodec ObservationCodec + OptsCache *llocommon.OptsCache + OutcomeCodec OutcomeCodec + OutcomeTelemetryCh chan<- *llocommon.LLOOutcomeTelemetry + PredecessorConfigDigest *types.ConfigDigest + PredecessorRetirementReportCache llocommon.PredecessorRetirementReportCache + ProtocolVersion uint32 + ReportCodecs map[llotypes.ReportFormat]llocommon.ReportCodec + ReportTelemetryCh chan<- *llocommon.LLOReportTelemetry + RetirementReportCodec llocommon.RetirementReportCodec + ShouldRetireCache ShouldRetireCache + func (p *Plugin) Close() error + func (p *Plugin) Observation(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query) (types.Observation, error) + func (p *Plugin) ObservationQuorum(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query, ...) (bool, error) + func (p *Plugin) Outcome(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query, ...) (ocr3types.Outcome, error) + func (p *Plugin) ProcessCalculatedStreams(outcome *Outcome) + func (p *Plugin) ProcessCalculatedStreamsDryRun(expression string) error + func (p *Plugin) Query(ctx context.Context, outctx ocr3types.OutcomeContext) (types.Query, error) + func (p *Plugin) Reports(ctx context.Context, seqNr uint64, rawOutcome ocr3types.Outcome) ([]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) ValidateObservation(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query, ...) error + type PluginFactory struct + func NewPluginFactory(p PluginFactoryParams) *PluginFactory + func (f *PluginFactory) NewReportingPlugin(ctx context.Context, cfg ocr3types.ReportingPluginConfig) (ocr3types.ReportingPlugin[llotypes.ReportInfo], ocr3types.ReportingPluginInfo, ...) + type PluginFactoryParams struct + DonID uint32 + OutcomeTelemetryCh chan<- *llocommon.LLOOutcomeTelemetry + ReportCodecs map[llotypes.ReportFormat]llocommon.ReportCodec + ReportTelemetryCh chan<- *llocommon.LLOReportTelemetry + type ShouldRetireCache interface + ShouldRetire func(digest ocr2types.ConfigDigest) (bool, error) + type UnreportableChannelError struct + ChannelID llotypes.ChannelID + Inner error + Reason string + func SelectBackfillCandidate(out *Outcome, backfillCID llotypes.ChannelID) (tsNanos uint64, rawTS uint64, opts llocommon.HistoryBackfillOpts, ...) + func (e *UnreportableChannelError) Error() string + func (e *UnreportableChannelError) String() string + func (e *UnreportableChannelError) Unwrap() error
Go to main page