datafeeds

Documentation

Index

• Constants
• Variables
• func NewDataFeedsAggregator(config values.Map, reportCodec datastreams.ReportCodec) (types.Aggregator, error)
• func ParseConfig(config values.Map) (aggregatorConfig, error)
• type DataFeedsMercuryReportInfo
  • func (*DataFeedsMercuryReportInfo) Descriptor() ([]byte, []int)
  • func (x *DataFeedsMercuryReportInfo) GetBenchmarkPrice() []byte
  • func (x *DataFeedsMercuryReportInfo) GetObservationTimestamp() int64
  • func (*DataFeedsMercuryReportInfo) ProtoMessage()
  • func (x *DataFeedsMercuryReportInfo) ProtoReflect() protoreflect.Message
  • func (x *DataFeedsMercuryReportInfo) Reset()
  • func (x *DataFeedsMercuryReportInfo) String() string
• type DataFeedsOutcomeMetadata
  • func (*DataFeedsOutcomeMetadata) Descriptor() ([]byte, []int)
  • func (x *DataFeedsOutcomeMetadata) GetFeedInfo() map[string]*DataFeedsMercuryReportInfo
  • func (*DataFeedsOutcomeMetadata) ProtoMessage()
  • func (x *DataFeedsOutcomeMetadata) ProtoReflect() protoreflect.Message
  • func (x *DataFeedsOutcomeMetadata) Reset()
  • func (x *DataFeedsOutcomeMetadata) String() string

Constants

const (
	// Aggregator outputs reports in the following format:
	//   []Reports{FeedID []byte, RawReport []byte, Price *big.Int, Timestamp int64}
	// Example of a compatible EVM encoder ABI config:
	//   (bytes32 FeedID, bytes RawReport, uint256 Price, uint64 Timestamp)[] Reports
	TopLevelListOutputFieldName = "Reports"
	FeedIDOutputFieldName       = "FeedID"
	RawReportOutputFieldName    = "RawReport"
	PriceOutputFieldName        = "Price"
	TimestampOutputFieldName    = "Timestamp"
	RemappedIDOutputFieldName   = "RemappedID"
)

Variables

var File_pkg_capabilities_consensus_ocr3_datafeeds_data_feeds_types_proto protoreflect.FileDescriptor

Functions

func NewDataFeedsAggregator

func NewDataFeedsAggregator(config values.Map, reportCodec datastreams.ReportCodec) (types.Aggregator, error)

func ParseConfig

func ParseConfig(config values.Map) (aggregatorConfig, error)

Types

type DataFeedsMercuryReportInfo

type DataFeedsMercuryReportInfo struct {
	ObservationTimestamp int64  `protobuf:"varint,3,opt,name=observation_timestamp,json=observationTimestamp,proto3" json:"observation_timestamp,omitempty"`
	BenchmarkPrice       []byte `protobuf:"bytes,5,opt,name=benchmark_price,json=benchmarkPrice,proto3" json:"benchmark_price,omitempty"` // big.Int
	// contains filtered or unexported fields
}

func (*DataFeedsMercuryReportInfo) Descriptor

func (*DataFeedsMercuryReportInfo) Descriptor() ([]byte, []int)

Deprecated: Use DataFeedsMercuryReportInfo.ProtoReflect.Descriptor instead.

func (*DataFeedsMercuryReportInfo) GetBenchmarkPrice

func (x *DataFeedsMercuryReportInfo) GetBenchmarkPrice() []byte

func (*DataFeedsMercuryReportInfo) GetObservationTimestamp

func (x *DataFeedsMercuryReportInfo) GetObservationTimestamp() int64

func (*DataFeedsMercuryReportInfo) ProtoMessage

func (*DataFeedsMercuryReportInfo) ProtoMessage()

func (*DataFeedsMercuryReportInfo) ProtoReflect

func (x *DataFeedsMercuryReportInfo) ProtoReflect() protoreflect.Message

func (*DataFeedsMercuryReportInfo) Reset

func (x *DataFeedsMercuryReportInfo) Reset()

func (*DataFeedsMercuryReportInfo) String

func (x *DataFeedsMercuryReportInfo) String() string

type DataFeedsOutcomeMetadata

type DataFeedsOutcomeMetadata struct {
	FeedInfo map[string]*DataFeedsMercuryReportInfo `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DataFeedsOutcomeMetadata) Descriptor

func (*DataFeedsOutcomeMetadata) Descriptor() ([]byte, []int)

Deprecated: Use DataFeedsOutcomeMetadata.ProtoReflect.Descriptor instead.

func (*DataFeedsOutcomeMetadata) GetFeedInfo

func (x *DataFeedsOutcomeMetadata) GetFeedInfo() map[string]*DataFeedsMercuryReportInfo

func (*DataFeedsOutcomeMetadata) ProtoMessage

func (*DataFeedsOutcomeMetadata) ProtoMessage()

func (*DataFeedsOutcomeMetadata) ProtoReflect

func (x *DataFeedsOutcomeMetadata) ProtoReflect() protoreflect.Message

func (*DataFeedsOutcomeMetadata) Reset

func (x *DataFeedsOutcomeMetadata) Reset()

func (*DataFeedsOutcomeMetadata) String

func (x *DataFeedsOutcomeMetadata) String() string