llo

package

Go to main page

Versions in this module

v0

v0.1.10

Jan 5, 2026

v0.1.9

Dec 19, 2025

v0.1.8

Dec 17, 2025

v0.1.7

Dec 11, 2025

Changes in this version

+ type CalculatedStreamABI struct

+ Expression string

+ ExpressionStreamID llotypes.StreamID

+ Type string

+ type CalculatedStreamABIProvider interface

+ CalculatedStreamABI func(parsedOpts any) ([]CalculatedStreamABI, error)

+ type ChannelDefinitionOptsCache interface

+ Delete func(channelID llotypes.ChannelID)

+ Get func(channelID llotypes.ChannelID) (any, bool)

+ Set func(channelID llotypes.ChannelID, channelOpts llotypes.ChannelOpts, ...) error

+ func NewChannelDefinitionOptsCache() ChannelDefinitionOptsCache

type LLOChannelDefinitionProto

+ Source uint32

+ Tombstone bool

+ func (x *LLOChannelDefinitionProto) GetSource() uint32

+ func (x *LLOChannelDefinitionProto) GetTombstone() bool

+ type OptsParser interface

+ ParseOpts func(opts []byte) (any, error)

type Plugin

+ ChannelDefinitionOptsCache ChannelDefinitionOptsCache

+ type TimeResolution uint8

+ const ResolutionMicroseconds

+ const ResolutionMilliseconds

+ const ResolutionNanoseconds

+ const ResolutionSeconds

+ func (tp *TimeResolution) UnmarshalJSON(data []byte) error

+ func (tp TimeResolution) MarshalJSON() ([]byte, error)

+ type TimeResolutionProvider interface

+ TimeResolution func(parsedOpts any) (TimeResolution, error)

v0.1.6

Oct 16, 2025

v0.1.5

Oct 1, 2025

v0.1.4

Aug 20, 2025

Changes in this version

+ func Ln(x any) (decimal.Decimal, error)

+ func Log(x, y any) (decimal.Decimal, error)

+ func Pow(x, y any) (decimal.Decimal, error)

+ func Sqrt(x any) (decimal.Decimal, error)

+ func Truncate(x any, precision int) (decimal.Decimal, error)

v0.1.3

Jul 23, 2025

v0.1.2

Jul 23, 2025

v0.1.1

Jul 22, 2025

Changes in this version

+ const MaxObservationLength

+ const MaxOutcomeLength

+ const MaxReportCount

+ const MaxReportLength

+ const MaxStreamsPerChannel

+ var File_llo_plugin_telemetry_proto protoreflect.FileDescriptor

+ func Abs(x any) (decimal.Decimal, error)

+ func Add(x, y any) (decimal.Decimal, error)

+ func Avg(x ...any) (decimal.Decimal, error)

+ func Ceil(x any) (decimal.Decimal, error)

+ func Div(x, y any) (decimal.Decimal, error)

+ func Duration(x string) (time.Duration, error)

+ func Equal(x, y any) (bool, error)

+ func Floor(x any) (decimal.Decimal, error)

+ func GreaterThan(x, y any) (bool, error)

+ func GreaterThanOrEqual(x, y any) (bool, error)

+ func IsNegative(x any) (bool, error)

+ func IsPositive(x any) (bool, error)

+ func IsSecondsResolution(reportFormat llotypes.ReportFormat) bool

+ func IsZero(x any) (bool, error)

+ func LessThan(x, y any) (bool, error)

+ func LessThanOrEqual(x, y any) (bool, error)

+ func Max(x ...any) (decimal.Decimal, error)

+ func Min(x ...any) (decimal.Decimal, error)

+ func Mul(x, y any) (decimal.Decimal, error)

+ func NewEnv(outcome *Outcome) environment

+ func Round(x any, precision int) (decimal.Decimal, error)

+ func Sub(x, y any) (decimal.Decimal, error)

type DSOpts

+ ObservationTimestamp func() time.Time

+ OutcomeCodec func() OutcomeCodec

+ type EVMOnchainConfigCodec struct

+ func (EVMOnchainConfigCodec) Decode(b []byte) (OnchainConfig, error)

+ func (EVMOnchainConfigCodec) Encode(c OnchainConfig) ([]byte, error)

type JSONReportCodec

+ func (cdc JSONReportCodec) Pack(digest types.ConfigDigest, seqNr uint64, report ocr2types.Report, ...) ([]byte, error)

+ func (cdc JSONReportCodec) Unpack(b []byte) (digest types.ConfigDigest, seqNr uint64, report ocr2types.Report, ...)

+ func (cdc JSONReportCodec) UnpackDecode(b []byte) (digest types.ConfigDigest, seqNr uint64, report Report, ...)

+ func (cdc JSONReportCodec) Verify(cd llotypes.ChannelDefinition) error

+ type LLOAggregatorStreamValue struct

+ AggregatorValues map[uint32]*LLOStreamValue

+ func (*LLOAggregatorStreamValue) Descriptor() ([]byte, []int)

+ func (*LLOAggregatorStreamValue) ProtoMessage()

+ func (x *LLOAggregatorStreamValue) GetAggregatorValues() map[uint32]*LLOStreamValue

+ func (x *LLOAggregatorStreamValue) ProtoReflect() protoreflect.Message

+ func (x *LLOAggregatorStreamValue) Reset()

+ func (x *LLOAggregatorStreamValue) String() string

+ type LLOChannelIDAndValidAfterNanosecondsProto struct

+ ChannelID uint32

+ ValidAfterNanoseconds uint64

+ func (*LLOChannelIDAndValidAfterNanosecondsProto) Descriptor() ([]byte, []int)

+ func (*LLOChannelIDAndValidAfterNanosecondsProto) ProtoMessage()

+ func (x *LLOChannelIDAndValidAfterNanosecondsProto) GetChannelID() uint32

+ func (x *LLOChannelIDAndValidAfterNanosecondsProto) GetValidAfterNanoseconds() uint64

+ func (x *LLOChannelIDAndValidAfterNanosecondsProto) ProtoReflect() protoreflect.Message

+ func (x *LLOChannelIDAndValidAfterNanosecondsProto) Reset()

+ func (x *LLOChannelIDAndValidAfterNanosecondsProto) String() string

type LLOObservationProto

+ UnixTimestampNanosecondsLegacy int64

+ func (x *LLOObservationProto) GetUnixTimestampNanosecondsLegacy() int64

type LLOOffchainConfigProto

+ DefaultMinReportIntervalNanoseconds uint64

+ EnableObservationCompression bool

+ ProtocolVersion uint32

+ func (x *LLOOffchainConfigProto) GetDefaultMinReportIntervalNanoseconds() uint64

+ func (x *LLOOffchainConfigProto) GetEnableObservationCompression() bool

+ func (x *LLOOffchainConfigProto) GetProtocolVersion() uint32

+ type LLOOutcomeProtoV0 struct

+ ChannelDefinitions []*LLOChannelIDAndDefinitionProto

+ LifeCycleStage string

+ ObservationTimestampNanoseconds int64

+ StreamAggregates []*LLOStreamAggregate

+ ValidAfterSeconds []*LLOChannelIDAndValidAfterSecondsProto

+ func (*LLOOutcomeProtoV0) Descriptor() ([]byte, []int)

+ func (*LLOOutcomeProtoV0) ProtoMessage()

+ func (x *LLOOutcomeProtoV0) GetChannelDefinitions() []*LLOChannelIDAndDefinitionProto

+ func (x *LLOOutcomeProtoV0) GetLifeCycleStage() string

+ func (x *LLOOutcomeProtoV0) GetObservationTimestampNanoseconds() int64

+ func (x *LLOOutcomeProtoV0) GetStreamAggregates() []*LLOStreamAggregate

+ func (x *LLOOutcomeProtoV0) GetValidAfterSeconds() []*LLOChannelIDAndValidAfterSecondsProto

+ func (x *LLOOutcomeProtoV0) ProtoReflect() protoreflect.Message

+ func (x *LLOOutcomeProtoV0) Reset()

+ func (x *LLOOutcomeProtoV0) String() string

+ type LLOOutcomeProtoV1 struct

+ ChannelDefinitions []*LLOChannelIDAndDefinitionProto

+ LifeCycleStage string

+ ObservationTimestampNanoseconds uint64

+ StreamAggregates []*LLOStreamAggregate

+ ValidAfterNanoseconds []*LLOChannelIDAndValidAfterNanosecondsProto

+ func (*LLOOutcomeProtoV1) Descriptor() ([]byte, []int)

+ func (*LLOOutcomeProtoV1) ProtoMessage()

+ func (x *LLOOutcomeProtoV1) GetChannelDefinitions() []*LLOChannelIDAndDefinitionProto

+ func (x *LLOOutcomeProtoV1) GetLifeCycleStage() string

+ func (x *LLOOutcomeProtoV1) GetObservationTimestampNanoseconds() uint64

+ func (x *LLOOutcomeProtoV1) GetStreamAggregates() []*LLOStreamAggregate

+ func (x *LLOOutcomeProtoV1) GetValidAfterNanoseconds() []*LLOChannelIDAndValidAfterNanosecondsProto

+ func (x *LLOOutcomeProtoV1) ProtoReflect() protoreflect.Message

+ func (x *LLOOutcomeProtoV1) Reset()

+ func (x *LLOOutcomeProtoV1) String() string

+ type LLOOutcomeTelemetry struct

+ ChannelDefinitions map[uint32]*LLOChannelDefinitionProto

+ ConfigDigest []byte

+ DonId uint32

+ LifeCycleStage string

+ ObservationTimestampNanoseconds uint64

+ SeqNr uint64

+ StreamAggregates map[uint32]*LLOAggregatorStreamValue

+ ValidAfterNanoseconds map[uint32]uint64

+ func (*LLOOutcomeTelemetry) Descriptor() ([]byte, []int)

+ func (*LLOOutcomeTelemetry) ProtoMessage()

+ func (x *LLOOutcomeTelemetry) GetChannelDefinitions() map[uint32]*LLOChannelDefinitionProto

+ func (x *LLOOutcomeTelemetry) GetConfigDigest() []byte

+ func (x *LLOOutcomeTelemetry) GetDonId() uint32

+ func (x *LLOOutcomeTelemetry) GetLifeCycleStage() string

+ func (x *LLOOutcomeTelemetry) GetObservationTimestampNanoseconds() uint64

+ func (x *LLOOutcomeTelemetry) GetSeqNr() uint64

+ func (x *LLOOutcomeTelemetry) GetStreamAggregates() map[uint32]*LLOAggregatorStreamValue

+ func (x *LLOOutcomeTelemetry) GetValidAfterNanoseconds() map[uint32]uint64

+ func (x *LLOOutcomeTelemetry) ProtoReflect() protoreflect.Message

+ func (x *LLOOutcomeTelemetry) Reset()

+ func (x *LLOOutcomeTelemetry) String() string

+ type LLOReportTelemetry struct

+ ChannelId uint32

+ ChannelOpts []byte

+ ConfigDigest []byte

+ DonId uint32

+ ObservationTimestampNanoseconds uint64

+ ReportFormat uint32

+ SeqNr uint64

+ Specimen bool

+ StreamDefinitions []*LLOStreamDefinition

+ StreamValues []*LLOStreamValue

+ ValidAfterNanoseconds uint64

+ func (*LLOReportTelemetry) Descriptor() ([]byte, []int)

+ func (*LLOReportTelemetry) ProtoMessage()

+ func (x *LLOReportTelemetry) GetChannelId() uint32

+ func (x *LLOReportTelemetry) GetChannelOpts() []byte

+ func (x *LLOReportTelemetry) GetConfigDigest() []byte

+ func (x *LLOReportTelemetry) GetDonId() uint32

+ func (x *LLOReportTelemetry) GetObservationTimestampNanoseconds() uint64

+ func (x *LLOReportTelemetry) GetReportFormat() uint32

+ func (x *LLOReportTelemetry) GetSeqNr() uint64

+ func (x *LLOReportTelemetry) GetSpecimen() bool

+ func (x *LLOReportTelemetry) GetStreamDefinitions() []*LLOStreamDefinition

+ func (x *LLOReportTelemetry) GetStreamValues() []*LLOStreamValue

+ func (x *LLOReportTelemetry) GetValidAfterNanoseconds() uint64

+ func (x *LLOReportTelemetry) ProtoReflect() protoreflect.Message

+ func (x *LLOReportTelemetry) Reset()

+ func (x *LLOReportTelemetry) String() string

type LLOStreamValue_Type

+ const LLOStreamValue_TimestampedStreamValue

+ type LLOTimestampedStreamValue struct

+ ObservedAtNanoseconds uint64

+ StreamValue *LLOStreamValue

+ func (*LLOTimestampedStreamValue) Descriptor() ([]byte, []int)

+ func (*LLOTimestampedStreamValue) ProtoMessage()

+ func (x *LLOTimestampedStreamValue) GetObservedAtNanoseconds() uint64

+ func (x *LLOTimestampedStreamValue) GetStreamValue() *LLOStreamValue

+ func (x *LLOTimestampedStreamValue) ProtoReflect() protoreflect.Message

+ func (x *LLOTimestampedStreamValue) Reset()

+ func (x *LLOTimestampedStreamValue) String() string

type ObservationCodec

+ func NewProtoObservationCodec(lggr logger.Logger, enableCompression bool) (ObservationCodec, error)

type OffchainConfig

+ DefaultMinReportIntervalNanoseconds uint64

+ EnableObservationCompression bool

+ ProtocolVersion uint32

+ func (c OffchainConfig) GetOutcomeCodec() OutcomeCodec

+ func (c OffchainConfig) Validate() error

+ type OnchainConfig struct

+ PredecessorConfigDigest *types.ConfigDigest

+ Version uint8

+ type OnchainConfigCodec interface

+ Decode func(b []byte) (OnchainConfig, error)

+ Encode func(OnchainConfig) ([]byte, error)

type Outcome

+ ObservationTimestampNanoseconds uint64

+ ValidAfterNanoseconds map[llotypes.ChannelID]uint64

+ func (out *Outcome) GenRetirementReport(protocolVersion uint32) RetirementReport

type Plugin

+ DefaultMinReportIntervalNanoseconds uint64

+ DonID uint32

+ MaxDurationObservation time.Duration

+ OutcomeTelemetryCh chan<- *LLOOutcomeTelemetry

+ ProtocolVersion uint32

+ ReportCodecs map[llotypes.ReportFormat]ReportCodec

+ ReportTelemetryCh chan<- *LLOReportTelemetry

+ RetirementReportCodec RetirementReportCodec

+ func (p *Plugin) ProcessCalculatedStreams(outcome *Outcome)

+ func (p *Plugin) ProcessCalculatedStreamsDryRun(expression string) error

+ type PluginFactoryParams struct

+ DonID uint32

+ OutcomeTelemetryCh chan<- *LLOOutcomeTelemetry

+ ReportCodecs map[llotypes.ReportFormat]ReportCodec

+ ReportTelemetryCh chan<- *LLOReportTelemetry

type Report

+ ObservationTimestampNanoseconds uint64

+ ValidAfterNanoseconds uint64

type ReportCodec

+ Verify func(llotypes.ChannelDefinition) error

type RetirementReport

+ ProtocolVersion uint32

+ ValidAfterNanoseconds map[llotypes.ChannelID]uint64

+ type RetirementReportCodec interface

+ Decode func([]byte) (RetirementReport, error)

+ Encode func(RetirementReport) ([]byte, error)

+ type StandardRetirementReportCodec struct

+ func (r StandardRetirementReportCodec) Decode(data []byte) (RetirementReport, error)

+ func (r StandardRetirementReportCodec) Encode(report RetirementReport) ([]byte, error)

type StreamValue

+ func UnmarshalTypedTextStreamValue(enc *TypedTextStreamValue) (StreamValue, error)

+ type TimestampedStreamValue struct

+ ObservedAtNanoseconds uint64

+ StreamValue StreamValue

+ func (v *TimestampedStreamValue) MarshalBinary() ([]byte, error)

+ func (v *TimestampedStreamValue) MarshalText() ([]byte, error)

+ func (v *TimestampedStreamValue) Type() LLOStreamValue_Type

+ func (v *TimestampedStreamValue) UnmarshalBinary(data []byte) error

+ func (v *TimestampedStreamValue) UnmarshalText(data []byte) error

+ type TypedTextStreamValue struct

+ SerializedStreamValue string

+ Type LLOStreamValue_Type

+ func NewTypedTextStreamValue(sv StreamValue) (TypedTextStreamValue, error)

+ type UnreportableChannelError struct

+ ChannelID llotypes.ChannelID

+ Inner error

+ Reason string

+ func (e *UnreportableChannelError) Error() string

+ func (e *UnreportableChannelError) String() string

+ func (e *UnreportableChannelError) Unwrap() error

v0.1.0

Oct 9, 2024

Changes in this version

+ const LifeCycleStageProduction

+ const LifeCycleStageRetired

+ const LifeCycleStageStaging

+ const MaxObservationRemoveChannelIDsLength

+ const MaxObservationStreamValuesLength

+ const MaxObservationUpdateChannelDefinitionsLength

+ const MaxOutcomeChannelDefinitionsLength

+ var ErrNilStreamValue = errors.New("nil stream value")

+ var File_llo_offchain_config_proto protoreflect.FileDescriptor

+ var File_plugin_codecs_proto protoreflect.FileDescriptor

+ var LLOStreamValue_Type_name = map[int32]string

+ var LLOStreamValue_Type_value = map[string]int32

+ func Decode(value StreamValue, data []byte) error

+ func VerifyChannelDefinitions(channelDefs llotypes.ChannelDefinitions) error

+ type AggregatorFunc func(values []StreamValue, f int) (StreamValue, error)

+ func GetAggregatorFunc(a llotypes.Aggregator) AggregatorFunc

+ type ChannelDefinitionCache interface

+ Definitions func() llotypes.ChannelDefinitions

+ type ChannelDefinitionWithID struct

+ ChannelID llotypes.ChannelID

+ type ChannelHash [32]byte

+ func MakeChannelHash(cd ChannelDefinitionWithID) ChannelHash

+ type Config struct

+ VerboseLogging bool

+ type DSOpts interface

+ ConfigDigest func() ocr2types.ConfigDigest

+ OutCtx func() ocr3types.OutcomeContext

+ SeqNr func() uint64

+ VerboseLogging func() bool

+ type DataSource interface

+ Observe func(ctx context.Context, streamValues StreamValues, opts DSOpts) error

+ type Decimal decimal.Decimal

+ func ToDecimal(d decimal.Decimal) *Decimal

+ func (v *Decimal) Decimal() decimal.Decimal

+ func (v *Decimal) MarshalBinary() ([]byte, error)

+ func (v *Decimal) MarshalText() ([]byte, error)

+ func (v *Decimal) String() string

+ func (v *Decimal) Type() LLOStreamValue_Type

+ func (v *Decimal) UnmarshalBinary(data []byte) error

+ func (v *Decimal) UnmarshalText(data []byte) error

+ type ErrUnreportableChannel struct

+ ChannelID llotypes.ChannelID

+ Inner error

+ Reason string

+ func (e *ErrUnreportableChannel) Error() string

+ func (e *ErrUnreportableChannel) String() string

+ func (e *ErrUnreportableChannel) Unwrap() error

+ type JSONReportCodec struct

+ func (cdc JSONReportCodec) Decode(b []byte) (r Report, err error)

+ func (cdc JSONReportCodec) Encode(ctx context.Context, r Report, _ llotypes.ChannelDefinition) ([]byte, error)

+ type JSONStreamValue struct

+ Type LLOStreamValue_Type

+ Value string

+ type LLOChannelDefinitionProto struct

+ Opts []byte

+ ReportFormat uint32

+ Streams []*LLOStreamDefinition

+ func (*LLOChannelDefinitionProto) Descriptor() ([]byte, []int)

+ func (*LLOChannelDefinitionProto) ProtoMessage()

+ func (x *LLOChannelDefinitionProto) GetOpts() []byte

+ func (x *LLOChannelDefinitionProto) GetReportFormat() uint32

+ func (x *LLOChannelDefinitionProto) GetStreams() []*LLOStreamDefinition

+ func (x *LLOChannelDefinitionProto) ProtoReflect() protoreflect.Message

+ func (x *LLOChannelDefinitionProto) Reset()

+ func (x *LLOChannelDefinitionProto) String() string

+ type LLOChannelIDAndDefinitionProto struct

+ ChannelDefinition *LLOChannelDefinitionProto

+ ChannelID uint32

+ func (*LLOChannelIDAndDefinitionProto) Descriptor() ([]byte, []int)

+ func (*LLOChannelIDAndDefinitionProto) ProtoMessage()

+ func (x *LLOChannelIDAndDefinitionProto) GetChannelDefinition() *LLOChannelDefinitionProto

+ func (x *LLOChannelIDAndDefinitionProto) GetChannelID() uint32

+ func (x *LLOChannelIDAndDefinitionProto) ProtoReflect() protoreflect.Message

+ func (x *LLOChannelIDAndDefinitionProto) Reset()

+ func (x *LLOChannelIDAndDefinitionProto) String() string

+ type LLOChannelIDAndValidAfterSecondsProto struct

+ ChannelID uint32

+ ValidAfterSeconds uint32

+ func (*LLOChannelIDAndValidAfterSecondsProto) Descriptor() ([]byte, []int)

+ func (*LLOChannelIDAndValidAfterSecondsProto) ProtoMessage()

+ func (x *LLOChannelIDAndValidAfterSecondsProto) GetChannelID() uint32

+ func (x *LLOChannelIDAndValidAfterSecondsProto) GetValidAfterSeconds() uint32

+ func (x *LLOChannelIDAndValidAfterSecondsProto) ProtoReflect() protoreflect.Message

+ func (x *LLOChannelIDAndValidAfterSecondsProto) Reset()

+ func (x *LLOChannelIDAndValidAfterSecondsProto) String() string

+ type LLOObservationProto struct

+ AttestedPredecessorRetirement []byte

+ RemoveChannelIDs []uint32

+ ShouldRetire bool

+ StreamValues map[uint32]*LLOStreamValue

+ UnixTimestampNanoseconds int64

+ UpdateChannelDefinitions map[uint32]*LLOChannelDefinitionProto

+ func (*LLOObservationProto) Descriptor() ([]byte, []int)

+ func (*LLOObservationProto) ProtoMessage()

+ func (x *LLOObservationProto) GetAttestedPredecessorRetirement() []byte

+ func (x *LLOObservationProto) GetRemoveChannelIDs() []uint32

+ func (x *LLOObservationProto) GetShouldRetire() bool

+ func (x *LLOObservationProto) GetStreamValues() map[uint32]*LLOStreamValue

+ func (x *LLOObservationProto) GetUnixTimestampNanoseconds() int64

+ func (x *LLOObservationProto) GetUpdateChannelDefinitions() map[uint32]*LLOChannelDefinitionProto

+ func (x *LLOObservationProto) ProtoReflect() protoreflect.Message

+ func (x *LLOObservationProto) Reset()

+ func (x *LLOObservationProto) String() string

+ type LLOOffchainConfigProto struct

+ PredecessorConfigDigest []byte

+ func (*LLOOffchainConfigProto) Descriptor() ([]byte, []int)

+ func (*LLOOffchainConfigProto) ProtoMessage()

+ func (x *LLOOffchainConfigProto) GetPredecessorConfigDigest() []byte

+ func (x *LLOOffchainConfigProto) ProtoReflect() protoreflect.Message

+ func (x *LLOOffchainConfigProto) Reset()

+ func (x *LLOOffchainConfigProto) String() string

+ type LLOOutcomeProto struct

+ ChannelDefinitions []*LLOChannelIDAndDefinitionProto

+ LifeCycleStage string

+ ObservationsTimestampNanoseconds int64

+ StreamAggregates []*LLOStreamAggregate

+ ValidAfterSeconds []*LLOChannelIDAndValidAfterSecondsProto

+ func (*LLOOutcomeProto) Descriptor() ([]byte, []int)

+ func (*LLOOutcomeProto) ProtoMessage()

+ func (x *LLOOutcomeProto) GetChannelDefinitions() []*LLOChannelIDAndDefinitionProto

+ func (x *LLOOutcomeProto) GetLifeCycleStage() string

+ func (x *LLOOutcomeProto) GetObservationsTimestampNanoseconds() int64

+ func (x *LLOOutcomeProto) GetStreamAggregates() []*LLOStreamAggregate

+ func (x *LLOOutcomeProto) GetValidAfterSeconds() []*LLOChannelIDAndValidAfterSecondsProto

+ func (x *LLOOutcomeProto) ProtoReflect() protoreflect.Message

+ func (x *LLOOutcomeProto) Reset()

+ func (x *LLOOutcomeProto) String() string

+ type LLOStreamAggregate struct

+ Aggregator uint32

+ StreamID uint32

+ StreamValue *LLOStreamValue

+ func StreamAggregatesToProtoOutcome(in StreamAggregates) (out []*LLOStreamAggregate, err error)

+ func (*LLOStreamAggregate) Descriptor() ([]byte, []int)

+ func (*LLOStreamAggregate) ProtoMessage()

+ func (x *LLOStreamAggregate) GetAggregator() uint32

+ func (x *LLOStreamAggregate) GetStreamID() uint32

+ func (x *LLOStreamAggregate) GetStreamValue() *LLOStreamValue

+ func (x *LLOStreamAggregate) ProtoReflect() protoreflect.Message

+ func (x *LLOStreamAggregate) Reset()

+ func (x *LLOStreamAggregate) String() string

+ type LLOStreamDefinition struct

+ Aggregator uint32

+ StreamID uint32

+ func (*LLOStreamDefinition) Descriptor() ([]byte, []int)

+ func (*LLOStreamDefinition) ProtoMessage()

+ func (x *LLOStreamDefinition) GetAggregator() uint32

+ func (x *LLOStreamDefinition) GetStreamID() uint32

+ func (x *LLOStreamDefinition) ProtoReflect() protoreflect.Message

+ func (x *LLOStreamDefinition) Reset()

+ func (x *LLOStreamDefinition) String() string

+ type LLOStreamObservationProto struct

+ Valid bool

+ Value []byte

+ func (*LLOStreamObservationProto) Descriptor() ([]byte, []int)

+ func (*LLOStreamObservationProto) ProtoMessage()

+ func (x *LLOStreamObservationProto) GetValid() bool

+ func (x *LLOStreamObservationProto) GetValue() []byte

+ func (x *LLOStreamObservationProto) ProtoReflect() protoreflect.Message

+ func (x *LLOStreamObservationProto) Reset()

+ func (x *LLOStreamObservationProto) String() string

+ type LLOStreamValue struct

+ Type LLOStreamValue_Type

+ Value []byte

+ func (*LLOStreamValue) Descriptor() ([]byte, []int)

+ func (*LLOStreamValue) ProtoMessage()

+ func (x *LLOStreamValue) GetType() LLOStreamValue_Type

+ func (x *LLOStreamValue) GetValue() []byte

+ func (x *LLOStreamValue) ProtoReflect() protoreflect.Message

+ func (x *LLOStreamValue) Reset()

+ func (x *LLOStreamValue) String() string

+ type LLOStreamValueQuote struct

+ Ask []byte

+ Benchmark []byte

+ Bid []byte

+ func (*LLOStreamValueQuote) Descriptor() ([]byte, []int)

+ func (*LLOStreamValueQuote) ProtoMessage()

+ func (x *LLOStreamValueQuote) GetAsk() []byte

+ func (x *LLOStreamValueQuote) GetBenchmark() []byte

+ func (x *LLOStreamValueQuote) GetBid() []byte

+ func (x *LLOStreamValueQuote) ProtoReflect() protoreflect.Message

+ func (x *LLOStreamValueQuote) Reset()

+ func (x *LLOStreamValueQuote) String() string

+ type LLOStreamValue_Type int32

+ const LLOStreamValue_Decimal

+ const LLOStreamValue_Quote

+ func (LLOStreamValue_Type) Descriptor() protoreflect.EnumDescriptor

+ func (LLOStreamValue_Type) EnumDescriptor() ([]byte, []int)

+ func (LLOStreamValue_Type) Type() protoreflect.EnumType

+ func (x LLOStreamValue_Type) Enum() *LLOStreamValue_Type

+ func (x LLOStreamValue_Type) Number() protoreflect.EnumNumber

+ func (x LLOStreamValue_Type) String() string

+ type Observation struct

+ AttestedPredecessorRetirement []byte

+ RemoveChannelIDs map[llotypes.ChannelID]struct{}

+ ShouldRetire bool

+ StreamValues StreamValues

+ UnixTimestampNanoseconds int64

+ UpdateChannelDefinitions llotypes.ChannelDefinitions

+ type ObservationCodec interface

+ Decode func(encoded types.Observation) (obs Observation, err error)

+ Encode func(obs Observation) (types.Observation, error)

+ type OffchainConfig struct

+ PredecessorConfigDigest *types.ConfigDigest

+ func DecodeOffchainConfig(b []byte) (o OffchainConfig, err error)

+ func (c OffchainConfig) Encode() ([]byte, error)

+ type Outcome struct

+ ChannelDefinitions llotypes.ChannelDefinitions

+ LifeCycleStage llotypes.LifeCycleStage

+ ObservationsTimestampNanoseconds int64

+ StreamAggregates StreamAggregates

+ ValidAfterSeconds map[llotypes.ChannelID]uint32

+ func (out *Outcome) IsReportable(channelID llotypes.ChannelID) *ErrUnreportableChannel

+ func (out *Outcome) ObservationsTimestampSeconds() (uint32, error)

+ func (out *Outcome) ReportableChannels() (reportable []llotypes.ChannelID, unreportable []*ErrUnreportableChannel)

+ type OutcomeCodec interface

+ Decode func(encoded ocr3types.Outcome) (outcome Outcome, err error)

+ Encode func(outcome Outcome) (ocr3types.Outcome, error)

+ type Plugin struct

+ ChannelDefinitionCache ChannelDefinitionCache

+ Codecs map[llotypes.ReportFormat]ReportCodec

+ Config Config

+ ConfigDigest types.ConfigDigest

+ DataSource DataSource

+ F int

+ Logger logger.Logger

+ N int

+ ObservationCodec ObservationCodec

+ OutcomeCodec OutcomeCodec

+ PredecessorConfigDigest *types.ConfigDigest

+ PredecessorRetirementReportCache PredecessorRetirementReportCache

+ 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) 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

+ ChannelDefinitionCache ChannelDefinitionCache

+ Codecs map[llotypes.ReportFormat]ReportCodec

+ Config Config

+ DataSource DataSource

+ Logger logger.Logger

+ PredecessorRetirementReportCache PredecessorRetirementReportCache

+ ShouldRetireCache ShouldRetireCache

+ func NewPluginFactory(cfg Config, prrc PredecessorRetirementReportCache, src ShouldRetireCache, ...) *PluginFactory

+ func (f *PluginFactory) NewReportingPlugin(ctx context.Context, cfg ocr3types.ReportingPluginConfig) (ocr3types.ReportingPlugin[llotypes.ReportInfo], ocr3types.ReportingPluginInfo, ...)

+ type PredecessorRetirementReportCache interface

+ AttestedRetirementReport func(predecessorConfigDigest ocr2types.ConfigDigest) ([]byte, error)

+ CheckAttestedRetirementReport func(predecessorConfigDigest ocr2types.ConfigDigest, ...) (RetirementReport, error)

+ func NewPredecessorRetirementReportCache() PredecessorRetirementReportCache

+ type Quote struct

+ Ask decimal.Decimal

+ Benchmark decimal.Decimal

+ Bid decimal.Decimal

+ func (v *Quote) IsValid() bool

+ func (v *Quote) MarshalBinary() (b []byte, err error)

+ func (v *Quote) MarshalText() ([]byte, error)

+ func (v *Quote) Type() LLOStreamValue_Type

+ func (v *Quote) UnmarshalBinary(data []byte) error

+ func (v *Quote) UnmarshalText(data []byte) error

+ type Report struct

+ ChannelID llotypes.ChannelID

+ ConfigDigest types.ConfigDigest

+ ObservationTimestampSeconds uint32

+ SeqNr uint64

+ Specimen bool

+ ValidAfterSeconds uint32

+ Values []StreamValue

+ type ReportCodec interface

+ Encode func(context.Context, Report, llotypes.ChannelDefinition) ([]byte, error)

+ type RetirementReport struct

+ ValidAfterSeconds map[llotypes.ChannelID]uint32

+ type ShouldRetireCache interface

+ ShouldRetire func() (bool, error)

+ func NewShouldRetireCache() ShouldRetireCache

+ type StreamAggregates map[llotypes.StreamID]map[llotypes.Aggregator]StreamValue

+ type StreamValue interface

+ Type func() LLOStreamValue_Type

+ func MedianAggregator(values []StreamValue, f int) (StreamValue, error)

+ func ModeAggregator(values []StreamValue, f int) (StreamValue, error)

+ func QuoteAggregator(values []StreamValue, f int) (StreamValue, error)

+ func UnmarshalJSONStreamValue(enc *JSONStreamValue) (StreamValue, error)

+ func UnmarshalProtoStreamValue(enc *LLOStreamValue) (sv StreamValue, err error)

+ type StreamValues map[llotypes.StreamID]StreamValue

+ type Transmitter interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL