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
- type ChannelDefinitionCacheORM
- type Closer
- type DelegateConfig
- type ErrMissingStream
- type JSONOnchainConfigCodec
- type Key
- type LLOOnchainKeyring
- type ORM
- type OffchainConfigDigester
- type OnchainConfig
- type OnchainConfigCodec
- type Registry
- type Transmitter
Constants ¶
View Source
const (
// Mercury server error codes
DuplicateReport = 2
)
Variables ¶
View Source
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)
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 DelegateConfig ¶
type DelegateConfig struct { Logger logger.Logger DataSource sqlutil.DataSource Runner streams.Runner Registry Registry JobName null.String // LLO ChannelDefinitionCache llotypes.ChannelDefinitionCache // 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 ErrMissingStream ¶
type ErrMissingStream struct {
// contains filtered or unexported fields
}
func (ErrMissingStream) Error ¶
func (e ErrMissingStream) Error() string
type JSONOnchainConfigCodec ¶ added in v2.14.0
type JSONOnchainConfigCodec struct{}
TODO: Replace this with protobuf, if it is actually used for something
func (*JSONOnchainConfigCodec) Decode ¶ added in v2.14.0
func (c *JSONOnchainConfigCodec) Decode([]byte) (OnchainConfig, error)
func (*JSONOnchainConfigCodec) Encode ¶ added in v2.14.0
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 }
type OffchainConfigDigester ¶
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 ¶ added in v2.14.0
type OnchainConfig struct{}
type OnchainConfigCodec ¶ added in v2.14.0
type OnchainConfigCodec interface { Encode(OnchainConfig) ([]byte, error) Decode([]byte) (OnchainConfig, error) }
type Transmitter ¶
type Transmitter interface { llotypes.Transmitter services.Service }
func NewTransmitter ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.