Versions in this module Expand all Collapse all v1 v1.1.0 Aug 7, 2026 Changes in this version + const DefaultMaxReportRange + const LifeCycleStageProduction + const LifeCycleStageRetired + const LifeCycleStageStaging + const MaxObservationRemoveChannelIDsLength + const MaxObservationStreamValuesLength + const MaxObservationUpdateChannelDefinitionsLength + const MaxOutcomeChannelDefinitionsLength + const MaxReportCount + const MaxStreamsPerChannel + var ErrNilStreamValue = errors.New("nil stream value") + var File_attested_retirement_report_proto protoreflect.FileDescriptor + var File_llo_offchain_config_proto protoreflect.FileDescriptor + var File_llo_plugin_telemetry_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 ChannelDefinitionFromProto(pb *LLOChannelDefinitionProto) llotypes.ChannelDefinition + func ConvertTimestamp(timestampNanos uint64, resolution TimeResolution) uint64 + func Decode(value StreamValue, data []byte) error + func DropInvalidHistoryBackfillChannels(lggr logger.Logger, defs llotypes.ChannelDefinitions, nowNanos uint64) llotypes.ChannelDefinitions + func GetOpts[T any](c *OptsCache, channelID llotypes.ChannelID) (T, error) + func InitMemoryBallast() + func ObservationTimestampKeyToNanoseconds(rawKey uint64, res TimeResolution) uint64 + func ReportTimestampResolutionNanos(target llotypes.ChannelDefinition) (uint64, error) + func ScaleSeconds(seconds uint32, resolution TimeResolution) uint64 + func SubtractChannelDefinitions(minuend llotypes.ChannelDefinitions, subtrahend llotypes.ChannelDefinitions, ...) llotypes.ChannelDefinitions + func ValidateHistoryBackfillAgainstDefinitions(cd llotypes.ChannelDefinition, defs llotypes.ChannelDefinitions, ...) error + func VerifyChannelDefinitions(codecs map[llotypes.ReportFormat]ReportCodec, ...) (merr error) + type AggregatorFunc func(values []StreamValue, f int) (StreamValue, error) + func GetAggregatorFunc(a llotypes.Aggregator) AggregatorFunc + type AttestedRetirementReport struct + RetirementReport []byte + SeqNr uint64 + Sigs []*AttributedOnchainSignature + func (*AttestedRetirementReport) Descriptor() ([]byte, []int) + func (*AttestedRetirementReport) ProtoMessage() + func (x *AttestedRetirementReport) GetRetirementReport() []byte + func (x *AttestedRetirementReport) GetSeqNr() uint64 + func (x *AttestedRetirementReport) GetSigs() []*AttributedOnchainSignature + func (x *AttestedRetirementReport) ProtoReflect() protoreflect.Message + func (x *AttestedRetirementReport) Reset() + func (x *AttestedRetirementReport) String() string + type AttributedOnchainSignature struct + Signature []byte + Signer uint32 + func (*AttributedOnchainSignature) Descriptor() ([]byte, []int) + func (*AttributedOnchainSignature) ProtoMessage() + func (x *AttributedOnchainSignature) GetSignature() []byte + func (x *AttributedOnchainSignature) GetSigner() uint32 + func (x *AttributedOnchainSignature) ProtoReflect() protoreflect.Message + func (x *AttributedOnchainSignature) Reset() + func (x *AttributedOnchainSignature) String() string + type ChannelDefinitionWithID struct + ChannelID llotypes.ChannelID + type ChannelHash [32]byte + 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 Duration time.Duration + func (d *Duration) UnmarshalJSON(b []byte) error + func (d Duration) MarshalJSON() ([]byte, error) + func (d Duration) String() string + type EVMOnchainConfigCodec struct + func (EVMOnchainConfigCodec) Decode(b []byte) (OnchainConfig, error) + func (EVMOnchainConfigCodec) Encode(c OnchainConfig) ([]byte, error) + type HistoryBackfillOpts struct + Observations map[uint64]map[llotypes.StreamID]string + TargetChannelID llotypes.ChannelID + func ParseHistoryBackfillOpts(raw llotypes.ChannelOpts) (HistoryBackfillOpts, error) + func (o *HistoryBackfillOpts) UnmarshalJSON(data []byte) 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 LLOChannelDefinitionProto struct + DisableNilStreamValues bool + Opts []byte + ReportFormat uint32 + Source uint32 + Streams []*LLOStreamDefinition + Tombstone bool + func ChannelDefinitionToProto(d llotypes.ChannelDefinition) *LLOChannelDefinitionProto + func (*LLOChannelDefinitionProto) Descriptor() ([]byte, []int) + func (*LLOChannelDefinitionProto) ProtoMessage() + func (x *LLOChannelDefinitionProto) GetDisableNilStreamValues() bool + func (x *LLOChannelDefinitionProto) GetOpts() []byte + func (x *LLOChannelDefinitionProto) GetReportFormat() uint32 + func (x *LLOChannelDefinitionProto) GetSource() uint32 + func (x *LLOChannelDefinitionProto) GetStreams() []*LLOStreamDefinition + func (x *LLOChannelDefinitionProto) GetTombstone() bool + 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 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 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 uint64 + UnixTimestampNanosecondsLegacy 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() uint64 + func (x *LLOObservationProto) GetUnixTimestampNanosecondsLegacy() 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 + DefaultMinReportIntervalNanoseconds uint64 + EnableObservationCompression bool + ProtocolVersion uint32 + func (*LLOOffchainConfigProto) Descriptor() ([]byte, []int) + func (*LLOOffchainConfigProto) ProtoMessage() + func (x *LLOOffchainConfigProto) GetDefaultMinReportIntervalNanoseconds() uint64 + func (x *LLOOffchainConfigProto) GetEnableObservationCompression() bool + func (x *LLOOffchainConfigProto) GetProtocolVersion() uint32 + func (x *LLOOffchainConfigProto) ProtoReflect() protoreflect.Message + func (x *LLOOffchainConfigProto) Reset() + func (x *LLOOffchainConfigProto) String() string + 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 LLOStreamAggregate struct + Aggregator uint32 + StreamID uint32 + StreamValue *LLOStreamValue + 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 StreamValueToProto(v StreamValue) (*LLOStreamValue, error) + 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 + const LLOStreamValue_TimestampedStreamValue + 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 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 OffchainConfig struct + DefaultMinReportIntervalNanoseconds uint64 + EnableObservationCompression bool + ProtocolVersion uint32 + func DecodeOffchainConfig(b []byte) (o OffchainConfig, err error) + func (c OffchainConfig) Encode() ([]byte, error) + 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 OptsCache struct + func NewOptsCache() *OptsCache + func (c *OptsCache) Len() int + func (c *OptsCache) Remove(channelID llotypes.ChannelID) + func (c *OptsCache) ResetTo(channelDefinitions llotypes.ChannelDefinitions) + func (c *OptsCache) Set(channelID llotypes.ChannelID, raw llotypes.ChannelOpts) + type PredecessorRetirementReportCache interface + AttestedRetirementReport func(predecessorConfigDigest ocr2types.ConfigDigest) ([]byte, error) + CheckAttestedRetirementReport func(predecessorConfigDigest ocr2types.ConfigDigest, ...) (RetirementReport, error) + 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 + ObservationTimestampNanoseconds uint64 + SeqNr uint64 + Specimen bool + ValidAfterNanoseconds uint64 + Values []StreamValue + type ReportCodec interface + Encode func(Report, llotypes.ChannelDefinition, *OptsCache) ([]byte, error) + Verify func(llotypes.ChannelDefinition) error + type ReportCodecHistoryBackfill struct + func (ReportCodecHistoryBackfill) Encode(Report, llotypes.ChannelDefinition, *OptsCache) ([]byte, error) + func (ReportCodecHistoryBackfill) Verify(cd llotypes.ChannelDefinition) error + type RetirementReport struct + 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 StreamAggregates map[llotypes.StreamID]map[llotypes.Aggregator]StreamValue + type StreamValue interface + Type func() LLOStreamValue_Type + func BuildBackfillStreamValues(target llotypes.ChannelDefinition, row map[llotypes.StreamID]string) ([]StreamValue, error) + 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 StreamValueFromBackfillString(agg llotypes.Aggregator, s string) (StreamValue, error) + func UnmarshalProtoStreamValue(enc *LLOStreamValue) (sv StreamValue, err error) + func UnmarshalTypedTextStreamValue(enc *TypedTextStreamValue) (StreamValue, error) + type StreamValues map[llotypes.StreamID]StreamValue + type TimeResolution uint8 + const ResolutionMicroseconds + const ResolutionMilliseconds + const ResolutionNanoseconds + const ResolutionSeconds + func TargetChannelTimeResolution(target llotypes.ChannelDefinition) (TimeResolution, error) + func (tp *TimeResolution) UnmarshalJSON(data []byte) error + func (tp TimeResolution) MarshalJSON() ([]byte, 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)
Go to main page