protocol

package

Go to main page

Versions in this module

v1

v1.1.3

Nov 3, 2026

v1.1.2

Nov 2, 2026

Changes in this version

+ const ABIZeroBytes

+ const MaxAttestedRetirementReportBytes

+ const MaxChannelOptsBytes

+ const MaxDecimalCoefficientBits

+ const MaxDefaultMinReportIntervalNanoseconds

+ const MaxExpressionBytes

+ const MaxExpressionNodes

+ const MaxExpressionsPerChannel

+ const MaxObservationPredecessorSignersLength

+ const MaxObservationSupportedReportFormatsLength

+ const MaxPersistedAggregates

+ const MaxPredecessorSignerBytes

+ const MaxReportRangeCeiling

+ const MaxRetirementReportChannels

+ const MaxStreamValueNesting

+ const MaxSupportedProtocolVersion

+ const MaxTotalCalculatedStreams

+ const MaxTotalOptsBytes

+ const MaxTotalStreamEntries

+ const MaxTotalTWAPCalls

+ var ErrDecimalCoefficientOutOfRange = errors.New("decimal coefficient out of range")

+ var ErrStreamValueNestingTooDeep = errors.New("stream value nesting too deep")

+ var ErrUnsupportedOnchainConfigVersion = errors.New("unsupported OnchainConfig version")

+ func CanonicalDecimal(d decimal.Decimal) decimal.Decimal

+ func CheckDecimalCoefficient(d decimal.Decimal) error

+ func CheckDecimalExponent(d decimal.Decimal) error

+ func CheckEncodableValues(optsCache *OptsCache, cd llotypes.ChannelDefinition, ...) error

+ func CheckSolidityInt(v *big.Int, t string) error

+ func EncodeStagingMarker(configDigest ocrtypes.ConfigDigest, seqNr uint64) ([]byte, error)

+ func GetOptsOrDecode[T any](c *OptsCache, cd llotypes.ChannelDefinition, channelID llotypes.ChannelID) (T, error)

+ func InadmissibleChannelIDsWithCache(codecs map[llotypes.ReportFormat]ReportCodec, ...) (map[llotypes.ChannelID]struct{}, error)

+ func IsStagingMarker(info llotypes.ReportInfo, report []byte) bool

+ func SaturatingAdd(a, b uint64) uint64

+ func UnverifiableChannelIDs(codecs map[llotypes.ReportFormat]ReportCodec, ...) (map[llotypes.ChannelID]struct{}, error)

+ func UnverifiableChannelIDsWithCache(codecs map[llotypes.ReportFormat]ReportCodec, ...) (map[llotypes.ChannelID]struct{}, error)

+ func ValidateHistoryBackfillValues(cd llotypes.ChannelDefinition, defs llotypes.ChannelDefinitions) error

+ func VerifyChannelDefinitionsForAdmissionWithCache(codecs map[llotypes.ReportFormat]ReportCodec, ...) error

+ func VerifyChannelDefinitionsWithCache(codecs map[llotypes.ReportFormat]ReportCodec, ...) error

+ func VerifyOptsKeys(raw []byte) error

+ type ABIElement struct

+ Multiplier *ubig.Big

+ Type string

+ func (e ABIElement) Scale(d decimal.Decimal) *big.Int

+ type ABISpec []ABIElement

+ func (s *ABISpec) UnmarshalJSON(data []byte) error

+ func (s ABISpec) CheckValue(sv StreamValue, packed bool) error

type AggregatorFunc

+ func GetAggregatorFuncV31(a llotypes.Aggregator) AggregatorFunc

+ type ChannelAnalysisCache struct

+ func NewChannelAnalysisCache() *ChannelAnalysisCache

+ func (c *ChannelAnalysisCache) Prune(channelDefs llotypes.ChannelDefinitions)

+ func (c *ChannelAnalysisCache) ReadOnly() *ChannelAnalysisCache

+ type ChannelDefinitionsBudget struct

+ func NewChannelDefinitionsBudget(codecs map[llotypes.ReportFormat]ReportCodec, defs llotypes.ChannelDefinitions, ...) *ChannelDefinitionsBudget

+ func (b *ChannelDefinitionsBudget) Err() error

+ func (b *ChannelDefinitionsBudget) Replace(channelID llotypes.ChannelID, prev *llotypes.ChannelDefinition, ...) bool

type ChannelGeneration

+ func (g *ChannelGeneration) Record() []byte

type ChannelHash

+ func ChannelHashV2(cd ChannelDefinitionWithID) ChannelHash

+ type LLOAttributedObservationTelemetry struct

+ AgreedObservationTimestampNanoseconds uint64

+ ConfigDigest []byte

+ DecodeError *string

+ DonId uint32

+ Emitter uint32

+ Observer uint32

+ OracleObservationTimestampNanoseconds uint64

+ RemoveChannelIds []uint32

+ SeqNr uint64

+ StreamValues map[uint32]*LLOStreamValue

+ UpdateChannelDefinitions map[uint32]*LLOChannelDefinitionProto

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

+ func (*LLOAttributedObservationTelemetry) ProtoMessage()

+ func (x *LLOAttributedObservationTelemetry) GetAgreedObservationTimestampNanoseconds() uint64

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

+ func (x *LLOAttributedObservationTelemetry) GetDecodeError() string

+ func (x *LLOAttributedObservationTelemetry) GetDonId() uint32

+ func (x *LLOAttributedObservationTelemetry) GetEmitter() uint32

+ func (x *LLOAttributedObservationTelemetry) GetObserver() uint32

+ func (x *LLOAttributedObservationTelemetry) GetOracleObservationTimestampNanoseconds() uint64

+ func (x *LLOAttributedObservationTelemetry) GetRemoveChannelIds() []uint32

+ func (x *LLOAttributedObservationTelemetry) GetSeqNr() uint64

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

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

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

+ func (x *LLOAttributedObservationTelemetry) Reset()

+ func (x *LLOAttributedObservationTelemetry) String() string

+ type LLOBlobPayloadProto struct

+ CycleStartSeqNr uint64

+ StreamValues map[uint32]*LLOStreamValue

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

+ func (*LLOBlobPayloadProto) ProtoMessage()

+ func (x *LLOBlobPayloadProto) GetCycleStartSeqNr() uint64

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

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

+ func (x *LLOBlobPayloadProto) Reset()

+ func (x *LLOBlobPayloadProto) String() string

+ type LLOCodecSupportProto struct

+ Oracles []*LLOOracleCodecSupportProto

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

+ func (*LLOCodecSupportProto) ProtoMessage()

+ func (x *LLOCodecSupportProto) GetOracles() []*LLOOracleCodecSupportProto

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

+ func (x *LLOCodecSupportProto) Reset()

+ func (x *LLOCodecSupportProto) String() string

type LLOHotStateProto

+ RecentAgreedTimestampsNanoseconds []uint64

+ func (x *LLOHotStateProto) GetRecentAgreedTimestampsNanoseconds() []uint64

type LLOObservationProto

+ PredecessorF uint32

+ PredecessorSigners [][]byte

+ SupportedReportFormats []uint32

+ func (x *LLOObservationProto) GetPredecessorF() uint32

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

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

type LLOOffchainConfigProto

+ AggregationFaultTolerance *uint32

+ func (x *LLOOffchainConfigProto) GetAggregationFaultTolerance() uint32

+ type LLOOracleCodecSupportProto struct

+ OracleID uint32

+ ReportFormats []uint32

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

+ func (*LLOOracleCodecSupportProto) ProtoMessage()

+ func (x *LLOOracleCodecSupportProto) GetOracleID() uint32

+ func (x *LLOOracleCodecSupportProto) GetReportFormats() []uint32

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

+ func (x *LLOOracleCodecSupportProto) Reset()

+ func (x *LLOOracleCodecSupportProto) String() string

type LLOOutcomeTelemetry

+ ContributionsStale uint32

+ MinContributions uint32

+ StreamsFallenBack uint32

+ StreamsFiltered uint32

+ func (x *LLOOutcomeTelemetry) GetContributionsStale() uint32

+ func (x *LLOOutcomeTelemetry) GetMinContributions() uint32

+ func (x *LLOOutcomeTelemetry) GetStreamsFallenBack() uint32

+ func (x *LLOOutcomeTelemetry) GetStreamsFiltered() uint32

type LLOPrecursorProto

+ ChannelState []byte

+ ReportableChannelIDs []uint32

+ func (x *LLOPrecursorProto) GetChannelState() []byte

+ func (x *LLOPrecursorProto) GetReportableChannelIDs() []uint32

type OffchainConfig

+ AggregationFaultTolerance *uint32

type OptsCache

+ func (c *OptsCache) SyncTo(channelDefinitions llotypes.ChannelDefinitions)

type PredecessorRetirementReportCache

+ PredecessorConfig func(predecessorConfigDigest ocr2types.ConfigDigest) (signers [][]byte, f uint8, exists bool)

+ VerifyAttestedRetirementReport func(predecessorConfigDigest ocr2types.ConfigDigest, signers [][]byte, f uint8, ...) (RetirementReport, error)

type RetirementReport

+ func (r RetirementReport) CheckCompatible(successorProtocolVersion uint32) error

+ type SolidityInt struct

+ Bits uint

+ Name string

+ Signed bool

+ func ParseSolidityInt(t string) (SolidityInt, error)

+ func (s SolidityInt) Check(v *big.Int) error

type StreamValue

+ func ABIPayload(format llotypes.ReportFormat, abiLen int, values []StreamValue) ([]StreamValue, error)

+ func MedianAggregatorV31(values []StreamValue, minContributions int) (StreamValue, error)

+ func UnmarshalObservedProtoStreamValue(enc *LLOStreamValue) (StreamValue, error)

+ type TWAPCounter interface

+ TWAPCalls func(llotypes.ChannelDefinition) int

type TimeResolution

+ func ReportTimeResolution(optsCache *OptsCache, cd llotypes.ChannelDefinition, ...) (TimeResolution, error)

v1.1.1

Aug 26, 2026

Changes in this version

+ const MaxDecimalExponent

+ const MaxDecompressedObservationLength

+ const MaxHistoryBackfillObservations

+ const MaxHistoryChunkRecords

+ const MaxHistoryChunkSlots

+ const MaxHistoryHeaderBytes

+ const MaxHistoryPairRoundBytes

+ const MaxHistoryPairs

+ const MaxHistoryRecordBytes

+ const MaxHistoryRecordsPerExpression

+ const MaxHistoryRecordsPerPair

+ const MaxHistoryRetainedRecords

+ const MaxHistoryTotalBytes

+ const MaxTWAPCallsPerExpression

+ var ErrCorruptStreamHistory = errors.New("corrupt stream history")

+ var ErrDecimalExponentOutOfRange = errors.New("decimal exponent out of range")

+ var ErrHistoryAlreadyAppended = errors.New("stream history already appended this round")

+ var ErrHistoryChunkNotLoaded = errors.New("stream history chunk not loaded")

+ var ErrHistoryRecordTooLarge = errors.New("history record too large")

+ var ErrInsufficientStreamHistory = errors.New("insufficient stream history")

+ func CalculatedStreamIDs(optsCache *OptsCache, cd llotypes.ChannelDefinition, cid llotypes.ChannelID) ([]llotypes.StreamID, error)

+ func ChangedChannelIDs(current, desired llotypes.ChannelDefinitions) map[llotypes.ChannelID]struct

+ func CloneChannelDefinitions(in llotypes.ChannelDefinitions) llotypes.ChannelDefinitions

+ func EffectiveStreams(optsCache *OptsCache, cd llotypes.ChannelDefinition, cid llotypes.ChannelID) ([]llotypes.Stream, error)

+ func HasCalculatedStreams(cd llotypes.ChannelDefinition) bool

+ func HistoryChunkSlot(sequence uint64) uint32

+ func ValidateHistoryBackfillTarget(cd llotypes.ChannelDefinition, defs llotypes.ChannelDefinitions) error

+ func VerifyChannelDefinitionsForAdmission(codecs map[llotypes.ReportFormat]ReportCodec, ...) error

+ type AdmissionVerifier interface

+ VerifyForAdmission func(llotypes.ChannelDefinition) error

+ type CalculatedStreamABI struct

+ Expression string

+ ExpressionStreamID llotypes.StreamID

+ Type string

+ type CalculatedStreamOpts struct

+ ABI []CalculatedStreamABI

+ func DecodeCalculatedStreamOpts(optsCache *OptsCache, cd llotypes.ChannelDefinition, cid llotypes.ChannelID) (CalculatedStreamOpts, error)

+ type ChannelCache struct

+ func NewChannelCache() *ChannelCache

+ func (c *ChannelCache) Load(seqNr uint64, build func() (llotypes.ChannelDefinitions, error)) (*ChannelGeneration, error)

+ type ChannelGeneration struct

+ func (g *ChannelGeneration) Definitions() llotypes.ChannelDefinitions

+ func (g *ChannelGeneration) Opts() *OptsCache

+ func (g *ChannelGeneration) SeqNr() uint64

+ type FeedIDer interface

+ FeedID func(llotypes.ChannelDefinition) (feedID [32]byte, ok bool, err error)

type HistoryBackfillOpts

+ func GetHistoryBackfillOpts(optsCache *OptsCache, cd llotypes.ChannelDefinition, cid llotypes.ChannelID) (HistoryBackfillOpts, error)

+ type LLOChannelStateProto struct

+ ChannelDefinitions []*LLOChannelIDAndDefinitionProto

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

+ func (*LLOChannelStateProto) ProtoMessage()

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

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

+ func (x *LLOChannelStateProto) Reset()

+ func (x *LLOChannelStateProto) String() string

+ type LLOHotStateProto struct

+ ObservationTimestampNanoseconds uint64

+ ReportableChannelIDs []uint32

+ StreamAggregates []*LLOStreamAggregate

+ ValidAfterNanoseconds []*LLOChannelIDAndValidAfterNanosecondsProto

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

+ func (*LLOHotStateProto) ProtoMessage()

+ func (x *LLOHotStateProto) GetObservationTimestampNanoseconds() uint64

+ func (x *LLOHotStateProto) GetReportableChannelIDs() []uint32

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

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

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

+ func (x *LLOHotStateProto) Reset()

+ func (x *LLOHotStateProto) String() string

+ type LLOPrecursorProto struct

+ ChannelDefinitions []*LLOChannelIDAndDefinitionProto

+ ChannelStateSeqNr uint64

+ LifeCycleStage string

+ ObservationTimestampNanoseconds uint64

+ StreamAggregates []*LLOStreamAggregate

+ ValidAfterNanoseconds []*LLOChannelIDAndValidAfterNanosecondsProto

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

+ func (*LLOPrecursorProto) ProtoMessage()

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

+ func (x *LLOPrecursorProto) GetChannelStateSeqNr() uint64

+ func (x *LLOPrecursorProto) GetLifeCycleStage() string

+ func (x *LLOPrecursorProto) GetObservationTimestampNanoseconds() uint64

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

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

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

+ func (x *LLOPrecursorProto) Reset()

+ func (x *LLOPrecursorProto) String() string

+ type LLOStreamHistoryChunkProto struct

+ Records []*LLOStreamHistoryRecord

+ Sequence uint64

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

+ func (*LLOStreamHistoryChunkProto) ProtoMessage()

+ func (x *LLOStreamHistoryChunkProto) GetRecords() []*LLOStreamHistoryRecord

+ func (x *LLOStreamHistoryChunkProto) GetSequence() uint64

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

+ func (x *LLOStreamHistoryChunkProto) Reset()

+ func (x *LLOStreamHistoryChunkProto) String() string

+ type LLOStreamHistoryHeaderProto struct

+ ChunkFirstObservationTimestampNanoseconds []uint64

+ Counts []uint32

+ FirstSequence uint64

+ LastObservationTimestampNanoseconds uint64

+ RequiredCount uint32

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

+ func (*LLOStreamHistoryHeaderProto) ProtoMessage()

+ func (x *LLOStreamHistoryHeaderProto) GetChunkFirstObservationTimestampNanoseconds() []uint64

+ func (x *LLOStreamHistoryHeaderProto) GetCounts() []uint32

+ func (x *LLOStreamHistoryHeaderProto) GetFirstSequence() uint64

+ func (x *LLOStreamHistoryHeaderProto) GetLastObservationTimestampNanoseconds() uint64

+ func (x *LLOStreamHistoryHeaderProto) GetRequiredCount() uint32

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

+ func (x *LLOStreamHistoryHeaderProto) Reset()

+ func (x *LLOStreamHistoryHeaderProto) String() string

+ type LLOStreamHistoryRecord struct

+ ObservedAtNanoseconds uint64

+ Value *LLOStreamValue

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

+ func (*LLOStreamHistoryRecord) ProtoMessage()

+ func (x *LLOStreamHistoryRecord) GetObservedAtNanoseconds() uint64

+ func (x *LLOStreamHistoryRecord) GetValue() *LLOStreamValue

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

+ func (x *LLOStreamHistoryRecord) Reset()

+ func (x *LLOStreamHistoryRecord) String() string

+ type RingWindow struct

+ func NewRingWindow(header *StreamHistoryHeader) *RingWindow

+ func ResetRingWindow() *RingWindow

+ func (w *RingWindow) Append(observedAtNanoseconds uint64, value StreamValue) (appended bool, err error)

+ func (w *RingWindow) AppendPlan() []uint64

+ func (w *RingWindow) FirstObservationTimestampNanoseconds() uint64

+ func (w *RingWindow) Header() *StreamHistoryHeader

+ func (w *RingWindow) LastObservationTimestampNanoseconds() uint64

+ func (w *RingWindow) Len() int

+ func (w *RingWindow) Loaded(sequence uint64) bool

+ func (w *RingWindow) Newest(n uint32) ([]StreamHistoryRecord, error)

+ func (w *RingWindow) Provide(chunk *StreamHistoryChunk) error

+ func (w *RingWindow) ReadPlan(n uint32) ([]uint64, error)

+ func (w *RingWindow) RequiredCount() uint32

+ func (w *RingWindow) SetRequiredCount(requiredCount uint32) (changed bool, err error)

+ func (w *RingWindow) WriteSet() RingWriteSet

+ type RingWriteSet struct

+ Chunk *StreamHistoryChunk

+ DeletedSlots []uint32

+ Header *StreamHistoryHeader

+ func (s RingWriteSet) Empty() bool

+ type StreamHistoryChunk struct

+ func StreamHistoryChunkFromProto(pb *LLOStreamHistoryChunkProto) (*StreamHistoryChunk, error)

+ func UnmarshalStreamHistoryChunk(data []byte) (*StreamHistoryChunk, error)

+ func (c *StreamHistoryChunk) Len() int

+ func (c *StreamHistoryChunk) MarshalBinary() ([]byte, error)

+ func (c *StreamHistoryChunk) Records() []StreamHistoryRecord

+ func (c *StreamHistoryChunk) Sequence() uint64

+ func (c *StreamHistoryChunk) Slot() uint32

+ func (c *StreamHistoryChunk) ToProto() (*LLOStreamHistoryChunkProto, error)

+ type StreamHistoryHeader struct

+ func StreamHistoryHeaderFromProto(pb *LLOStreamHistoryHeaderProto) (*StreamHistoryHeader, error)

+ func UnmarshalStreamHistoryHeader(data []byte) (*StreamHistoryHeader, error)

+ func (h *StreamHistoryHeader) ChunkCount() int

+ func (h *StreamHistoryHeader) Counts() []uint32

+ func (h *StreamHistoryHeader) FirstObservationTimestampNanoseconds() uint64

+ func (h *StreamHistoryHeader) FirstSequence() uint64

+ func (h *StreamHistoryHeader) LastObservationTimestampNanoseconds() uint64

+ func (h *StreamHistoryHeader) Len() int

+ func (h *StreamHistoryHeader) MarshalBinary() ([]byte, error)

+ func (h *StreamHistoryHeader) RequiredCount() uint32

+ func (h *StreamHistoryHeader) Sequences() []uint64

+ func (h *StreamHistoryHeader) ToProto() *LLOStreamHistoryHeaderProto

+ type StreamHistoryRecord struct

+ ObservedAtNanoseconds uint64

+ Value StreamValue

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)

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