llo

Documentation

Index

• Constants
• Variables
• func NewChannelDefinitionCache(lggr logger.Logger, orm ChannelDefinitionCacheORM, lp logpoller.LogPoller, ...) llotypes.ChannelDefinitionCache
• func NewDelegate(cfg DelegateConfig) (job.ServiceCtx, error)
• func NewStaticChannelDefinitionCache(lggr logger.Logger, dfnstr string) (llotypes.ChannelDefinitionCache, error)
• type ChannelDefinitionCacheFactory
  • func NewChannelDefinitionCacheFactory(lggr logger.Logger, orm ChannelDefinitionCacheORM, lp logpoller.LogPoller) ChannelDefinitionCacheFactory
• type ChannelDefinitionCacheORM
• type Closer
• type DelegateConfig
• type ErrObservationFailed
  • func (e *ErrObservationFailed) Error() string
  • func (e *ErrObservationFailed) String() string
  • func (e *ErrObservationFailed) Unwrap() error
• type JSONOnchainConfigCodec
  • func (c *JSONOnchainConfigCodec) Decode([]byte) (OnchainConfig, error)
  • func (c *JSONOnchainConfigCodec) Encode(OnchainConfig) ([]byte, error)
• type Key
• type LLOOnchainKeyring
  • func NewOnchainKeyring(lggr logger.Logger, keys map[llotypes.ReportFormat]Key) LLOOnchainKeyring
• type ORM
  • func NewORM(ds sqlutil.DataSource, evmChainID *big.Int) ORM
• type OffchainConfigDigester
  • func NewOffchainConfigDigester(chainID *big.Int, contractAddress common.Address) OffchainConfigDigester
  • func (d OffchainConfigDigester) ConfigDigest(cc ocrtypes.ContractConfig) (ocrtypes.ConfigDigest, error)
  • func (d OffchainConfigDigester) ConfigDigestPrefix() (ocrtypes.ConfigDigestPrefix, error)
• type OnchainConfig
• type OnchainConfigCodec
• type Registry
• type Transmitter
  • func NewTransmitter(lggr logger.Logger, rpcClient wsrpc.Client, fromAccount ed25519.PublicKey) Transmitter

Constants

const (
	// Mercury server error codes
	DuplicateReport = 2
)

Variables

var PayloadTypes = getPayloadTypes()

Functions

func NewChannelDefinitionCache

func NewChannelDefinitionCache(lggr logger.Logger, orm ChannelDefinitionCacheORM, lp logpoller.LogPoller, addr common.Address, fromBlock int64) llotypes.ChannelDefinitionCache

func NewDelegate

func NewDelegate(cfg DelegateConfig) (job.ServiceCtx, error)

func NewStaticChannelDefinitionCache

func NewStaticChannelDefinitionCache(lggr logger.Logger, dfnstr string) (llotypes.ChannelDefinitionCache, error)

Types

type ChannelDefinitionCacheFactory

type ChannelDefinitionCacheFactory interface {
	NewCache(cfg lloconfig.PluginConfig) (llotypes.ChannelDefinitionCache, error)
}

func NewChannelDefinitionCacheFactory

func NewChannelDefinitionCacheFactory(lggr logger.Logger, orm ChannelDefinitionCacheORM, lp logpoller.LogPoller) ChannelDefinitionCacheFactory

type ChannelDefinitionCacheORM

type ChannelDefinitionCacheORM interface {
	// TODO: What about delete/cleanup?
	// https://smartcontract-it.atlassian.net/browse/MERC-3653
	LoadChannelDefinitions(ctx context.Context, addr common.Address) (dfns llotypes.ChannelDefinitions, blockNum int64, err error)
	StoreChannelDefinitions(ctx context.Context, addr common.Address, dfns llotypes.ChannelDefinitions, blockNum int64) (err error)
}

type Closer

type Closer interface {
	Close() error
}

type DelegateConfig

type DelegateConfig struct {
	Logger     logger.Logger
	DataSource sqlutil.DataSource
	Runner     streams.Runner
	Registry   Registry
	JobName    null.String

	// LLO
	ChannelDefinitionCache llotypes.ChannelDefinitionCache
	ReportingPluginConfig  llo.Config

	// OCR3
	BinaryNetworkEndpointFactory ocr2types.BinaryNetworkEndpointFactory
	V2Bootstrappers              []ocrcommontypes.BootstrapperLocator
	ContractConfigTracker        ocr2types.ContractConfigTracker
	ContractTransmitter          ocr3types.ContractTransmitter[llotypes.ReportInfo]
	Database                     ocr3types.Database
	OCRLogger                    ocrcommontypes.Logger
	MonitoringEndpoint           ocrcommontypes.MonitoringEndpoint
	OffchainConfigDigester       ocr2types.OffchainConfigDigester
	OffchainKeyring              ocr2types.OffchainKeyring
	OnchainKeyring               ocr3types.OnchainKeyring[llotypes.ReportInfo]
	LocalConfig                  ocr2types.LocalConfig
}

type ErrObservationFailed

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

func (*ErrObservationFailed) Error

func (e *ErrObservationFailed) Error() string

func (*ErrObservationFailed) String

func (e *ErrObservationFailed) String() string

func (*ErrObservationFailed) Unwrap

func (e *ErrObservationFailed) Unwrap() error

type JSONOnchainConfigCodec

type JSONOnchainConfigCodec struct{}

TODO: Replace this with protobuf, if it is actually used for something

func (*JSONOnchainConfigCodec) Decode

func (c *JSONOnchainConfigCodec) Decode([]byte) (OnchainConfig, error)

func (*JSONOnchainConfigCodec) Encode

func (c *JSONOnchainConfigCodec) Encode(OnchainConfig) ([]byte, error)

type Key

type Key interface {
	Sign3(digest ocrtypes.ConfigDigest, seqNr uint64, r ocrtypes.Report) (signature []byte, err error)
	Verify3(publicKey ocrtypes.OnchainPublicKey, cd ocrtypes.ConfigDigest, seqNr uint64, r ocrtypes.Report, signature []byte) bool
	PublicKey() ocrtypes.OnchainPublicKey
	MaxSignatureLength() int
}

type LLOOnchainKeyring

type LLOOnchainKeyring ocr3types.OnchainKeyring[llotypes.ReportInfo]

func NewOnchainKeyring

func NewOnchainKeyring(lggr logger.Logger, keys map[llotypes.ReportFormat]Key) LLOOnchainKeyring

type ORM

type ORM interface {
	ChannelDefinitionCacheORM
}

func NewORM

func NewORM(ds sqlutil.DataSource, evmChainID *big.Int) ORM

type OffchainConfigDigester

type OffchainConfigDigester struct {
	ChainID         *big.Int
	ContractAddress common.Address
}

func NewOffchainConfigDigester

func NewOffchainConfigDigester(chainID *big.Int, contractAddress common.Address) OffchainConfigDigester

func (OffchainConfigDigester) ConfigDigest

func (d OffchainConfigDigester) ConfigDigest(cc ocrtypes.ContractConfig) (ocrtypes.ConfigDigest, error)

func (OffchainConfigDigester) ConfigDigestPrefix

func (d OffchainConfigDigester) ConfigDigestPrefix() (ocrtypes.ConfigDigestPrefix, error)

type OnchainConfig

type OnchainConfig struct{}

type OnchainConfigCodec

type OnchainConfigCodec interface {
	Encode(OnchainConfig) ([]byte, error)
	Decode([]byte) (OnchainConfig, error)
}

type Registry

type Registry interface {
	Get(streamID streams.StreamID) (strm streams.Stream, exists bool)
}

type Transmitter

type Transmitter interface {
	llotypes.Transmitter
	services.Service
}

func NewTransmitter

func NewTransmitter(lggr logger.Logger, rpcClient wsrpc.Client, fromAccount ed25519.PublicKey) Transmitter