mercury

Documentation

Index

• Variables
• func FilterName(addr common.Address) string
• func NewDataSource(pr pipeline.Runner, jb job.Job, spec pipeline.Spec, lggr logger.Logger, ...) *datasource
• func NewTransmitter(lggr logger.Logger, cfgTracker ConfigTracker, rpcClient wsrpc.Client, ...) *mercuryTransmitter
• type ConfigPoller
  • func NewConfigPoller(lggr logger.Logger, destChainPoller logpoller.LogPoller, addr common.Address, ...) (*ConfigPoller, error)
  • func (lp *ConfigPoller) LatestBlockHeight(ctx context.Context) (blockHeight uint64, err error)
  • func (lp *ConfigPoller) LatestConfig(ctx context.Context, changedInBlock uint64) (ocrtypes.ContractConfig, error)
  • func (lp *ConfigPoller) LatestConfigDetails(ctx context.Context) (changedInBlock uint64, configDigest ocrtypes.ConfigDigest, err error)
  • func (lp *ConfigPoller) Notify() <-chan struct{}
  • func (lp *ConfigPoller) Replay(ctx context.Context, fromBlock int64) error
• type ConfigTracker
• type FullConfigFromLog
• type OffchainConfigDigester
  • func NewOffchainConfigDigester(feedID [32]byte, chainID uint64, contractAddress common.Address) OffchainConfigDigester
  • func (d OffchainConfigDigester) ConfigDigest(cc types.ContractConfig) (types.ConfigDigest, error)
  • func (d OffchainConfigDigester) ConfigDigestPrefix() types.ConfigDigestPrefix
• type Transmitter

Variables

var FeedScopedConfigSet common.Hash

FeedScopedConfigSet ConfigSet with FeedID for use with mercury (and multi-config DON)

var PayloadTypes = getPayloadTypes()

Functions

func FilterName

func FilterName(addr common.Address) string

func NewDataSource

func NewDataSource(pr pipeline.Runner, jb job.Job, spec pipeline.Spec, lggr logger.Logger, rr chan pipeline.Run) *datasource

func NewTransmitter

func NewTransmitter(lggr logger.Logger, cfgTracker ConfigTracker, rpcClient wsrpc.Client, fromAccount ed25519.PublicKey, feedID [32]byte) *mercuryTransmitter

Types

type ConfigPoller

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

ConfigPoller defines the Mercury Config Poller

func NewConfigPoller

func NewConfigPoller(lggr logger.Logger, destChainPoller logpoller.LogPoller, addr common.Address, feedId common.Hash) (*ConfigPoller, error)

NewConfigPoller creates a new Mercury ConfigPoller

func (*ConfigPoller) LatestBlockHeight

func (lp *ConfigPoller) LatestBlockHeight(ctx context.Context) (blockHeight uint64, err error)

LatestBlockHeight returns the latest block height from the logs

func (*ConfigPoller) LatestConfig

func (lp *ConfigPoller) LatestConfig(ctx context.Context, changedInBlock uint64) (ocrtypes.ContractConfig, error)

LatestConfig returns the latest config from the logs on a certain block

func (*ConfigPoller) LatestConfigDetails

func (lp *ConfigPoller) LatestConfigDetails(ctx context.Context) (changedInBlock uint64, configDigest ocrtypes.ConfigDigest, err error)

LatestConfigDetails returns the latest config details from the logs

func (*ConfigPoller) Notify

func (lp *ConfigPoller) Notify() <-chan struct{}

Notify noop method TODO: implement this, see: https://smartcontract-it.atlassian.net/browse/MERC-302

func (*ConfigPoller) Replay

func (lp *ConfigPoller) Replay(ctx context.Context, fromBlock int64) error

Replay abstracts the logpoller.LogPoller Replay() implementation

type ConfigTracker

type ConfigTracker interface {
	LatestConfigDetails(ctx context.Context) (changedInBlock uint64, configDigest ocrtypes.ConfigDigest, err error)
}

type FullConfigFromLog

type FullConfigFromLog struct {
	ocrtypes.ContractConfig
	// contains filtered or unexported fields
}

FullConfigFromLog defines the contract config with the feedID

type OffchainConfigDigester

type OffchainConfigDigester struct {
	FeedID          [32]byte
	ChainID         uint64
	ContractAddress common.Address
}

func NewOffchainConfigDigester

func NewOffchainConfigDigester(feedID [32]byte, chainID uint64, contractAddress common.Address) OffchainConfigDigester

func (OffchainConfigDigester) ConfigDigest

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

func (OffchainConfigDigester) ConfigDigestPrefix

func (d OffchainConfigDigester) ConfigDigestPrefix() types.ConfigDigestPrefix

type Transmitter

type Transmitter interface {
	relaymercury.Transmitter
	services.ServiceCtx
}