ocr2

package

v0.0.0-...-0cd4e98 Latest Latest Go to latest Published: Jul 12, 2022 License: MIT Imports: 21 Imported by: 0

Documentation ¶

Index ¶

Constants
func DecodeBytes(felts []*big.Int) ([]byte, error)
func EncodeBytes(data []byte) (felts []*big.Int)
func Min[T constraints.Ordered](a, b T) T
func NewConfigProvider(chainID string, contractAddress string, cfg starknet.Config, ...) (*configProvider, error)
func NewContractCache(cfg starknet.Config, reader *contractReader, lggr logger.Logger) *contractCache
func NewContractReader(address string, reader OCR2Reader, lggr logger.Logger) *contractReader
func NewContractTransmitter(reader *contractReader) *contractTransmitter
func NewMedianProvider(chainID string, contractAddress string, cfg starknet.Config, ...) (*medianProvider, error)
func NewOffchainConfigDigester(chainID rpc.ChainID, contract rpc.Address) offchainConfigDigester
func NewTransmissionsCache(cfg starknet.Config, reader *contractReader, lggr logger.Logger) *transmissionsCache
type BillingDetails
- func NewBillingDetails(observationPaymentFelt junotypes.Felt, transmissionPaymentFelt junotypes.Felt) (bd BillingDetails, err error)
type Client
- func NewClient(chainID string, lggr logger.Logger) (*Client, error)
- func (c *Client) BaseClient() *starknet.Client
- func (c *Client) BillingDetails(ctx context.Context, address string) (bd BillingDetails, err error)
- func (c *Client) ConfigFromEventAt(ctx context.Context, address string, blockNum uint64) (cc ContractConfig, err error)
- func (c *Client) LatestConfigDetails(ctx context.Context, address string) (ccd ContractConfigDetails, err error)
type ContractConfig
type ContractConfigDetails
- func NewContractConfigDetails(blockFelt junotypes.Felt, digestFelt junotypes.Felt) (ccd ContractConfigDetails, err error)
type OCR2Reader
type Tracker
type TransmissionDetails

Constants ¶

const ConfigDigestPrefixStarknet types.ConfigDigestPrefix = 4

TODO: use libocr constant

Variables ¶

This section is empty.

Functions ¶

func DecodeBytes ¶

func DecodeBytes(felts []*big.Int) ([]byte, error)

func EncodeBytes ¶

func EncodeBytes(data []byte) (felts []*big.Int)

Encodes a byte slice as a bunch of felts. First felt indicates the total byte size.

func Min ¶

func Min[T constraints.Ordered](a, b T) T

func NewConfigProvider ¶

func NewConfigProvider(chainID string, contractAddress string, cfg starknet.Config, lggr logger.Logger) (*configProvider, error)

func NewContractCache ¶

func NewContractCache(cfg starknet.Config, reader *contractReader, lggr logger.Logger) *contractCache

func NewContractReader ¶

func NewContractReader(address string, reader OCR2Reader, lggr logger.Logger) *contractReader

func NewContractTransmitter ¶

func NewContractTransmitter(
	reader *contractReader,
) *contractTransmitter

func NewMedianProvider ¶

func NewMedianProvider(chainID string, contractAddress string, cfg starknet.Config, lggr logger.Logger) (*medianProvider, error)

func NewOffchainConfigDigester ¶

func NewOffchainConfigDigester(chainID rpc.ChainID, contract rpc.Address) offchainConfigDigester

func NewTransmissionsCache ¶

func NewTransmissionsCache(cfg starknet.Config, reader *contractReader, lggr logger.Logger) *transmissionsCache

Types ¶

type BillingDetails ¶

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

func NewBillingDetails ¶

func NewBillingDetails(observationPaymentFelt junotypes.Felt, transmissionPaymentFelt junotypes.Felt) (bd BillingDetails, err error)

type Client ¶

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

func NewClient ¶

func NewClient(chainID string, lggr logger.Logger) (*Client, error)

func (*Client) BaseClient ¶

func (c *Client) BaseClient() *starknet.Client

func (*Client) BillingDetails ¶

func (c *Client) BillingDetails(ctx context.Context, address string) (bd BillingDetails, err error)

func (*Client) ConfigFromEventAt ¶

func (c *Client) ConfigFromEventAt(ctx context.Context, address string, blockNum uint64) (cc ContractConfig, err error)

func (*Client) LatestConfigDetails ¶

func (c *Client) LatestConfigDetails(ctx context.Context, address string) (ccd ContractConfigDetails, err error)

type ContractConfig ¶

type ContractConfig struct {
	Config      types.ContractConfig
	ConfigBlock uint64
}

type ContractConfigDetails ¶

type ContractConfigDetails struct {
	Block  uint64
	Digest types.ConfigDigest
}

func NewContractConfigDetails ¶

func NewContractConfigDetails(blockFelt junotypes.Felt, digestFelt junotypes.Felt) (ccd ContractConfigDetails, err error)

type OCR2Reader ¶

type OCR2Reader interface {
	LatestConfigDetails(context.Context, string) (ContractConfigDetails, error)
	ConfigFromEventAt(context.Context, string, uint64) (ContractConfig, error)
	BillingDetails(context.Context, string) (BillingDetails, error)

	BaseClient() *starknet.Client
}

type Tracker ¶

type Tracker interface {
	Start() error
	Close() error
	// contains filtered or unexported methods
}

type TransmissionDetails ¶

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

Source Files ¶

View all Source files

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