cre

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 14, 2026 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LLOStreamID

type LLOStreamID uint32

type LLOTriggerConfig

type LLOTriggerConfig struct {
	// The IDs of the data feeds (LLO streams) that will be included in the trigger event.
	StreamIDs []LLOStreamID `json:"streamIds" yaml:"streamIds" mapstructure:"streamIds"`

	// The interval in seconds after which a new trigger event is generated.
	MaxFrequencyMs uint64 `json:"maxFrequencyMs" yaml:"maxFrequencyMs" mapstructure:"maxFrequencyMs"`
}

type ReportCodecCapabilityTrigger

type ReportCodecCapabilityTrigger struct {
	// contains filtered or unexported fields
}

func NewReportCodecCapabilityTrigger

func NewReportCodecCapabilityTrigger(lggr logger.Logger, donID uint32) ReportCodecCapabilityTrigger

func (ReportCodecCapabilityTrigger) Encode

Encode a report into a capability trigger report the returned byte slice is the marshaled protobuf of capabilitiespb.OCRTriggerReport

func (ReportCodecCapabilityTrigger) EventID

EventID is expected to uniquely identify a (don, round)

func (ReportCodecCapabilityTrigger) ParseOpts

func (r ReportCodecCapabilityTrigger) ParseOpts(opts []byte) (any, error)

func (ReportCodecCapabilityTrigger) Verify

type ReportCodecCapabilityTriggerMultiplier

type ReportCodecCapabilityTriggerMultiplier struct {
	Multiplier decimal.Decimal   `json:"multiplier"`
	StreamID   llotypes.StreamID `json:"streamID"`
}

type ReportCodecCapabilityTriggerOpts

type ReportCodecCapabilityTriggerOpts struct {
	// EXAMPLE
	//
	// [{streamID: 1000000001, "multiplier":"10000"}, ...]
	//
	// The total number of streams must be n, where n is the number of
	// top-level elements in this ReportCodecCapabilityTriggerMultipliers array
	Multipliers []ReportCodecCapabilityTriggerMultiplier `json:"multipliers"`
}

Opts format remains unchanged

func (*ReportCodecCapabilityTriggerOpts) Decode

func (r *ReportCodecCapabilityTriggerOpts) Decode(opts []byte) error

func (*ReportCodecCapabilityTriggerOpts) Encode

func (r *ReportCodecCapabilityTriggerOpts) Encode() ([]byte, error)

type Transmitter

type Transmitter interface {
	llotypes.Transmitter
	services.Service
}

type TransmitterConfig

type TransmitterConfig struct {
	Logger               logger.Logger                  `json:"-"`
	CapabilitiesRegistry coretypes.CapabilitiesRegistry `json:"-"`
	DonID                uint32                         `json:"-"`

	TriggerCapabilityName        string `json:"triggerCapabilityName"`
	TriggerCapabilityVersion     string `json:"triggerCapabilityVersion"`
	TriggerTickerMinResolutionMs int    `json:"triggerTickerMinResolutionMs"`
	TriggerSendChannelBufferSize int    `json:"triggerSendChannelBufferSize"`
}

func (TransmitterConfig) NewTransmitter

func (c TransmitterConfig) NewTransmitter() (*transmitter, error)

Jump to

Keyboard shortcuts

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