mercury

type BenchmarkPriceDecoder func(ctx context.Context, feedID mercury.FeedID, report ocrtypes.Report) (*big.Int, error)

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

type EpochRound struct {
	Epoch uint32
	Round uint8
}

type ORM interface {
	InsertTransmitRequest(ctx context.Context, serverURLs []string, req *pb.TransmitRequest, jobID int32, reportCtx ocrtypes.ReportContext) error
	DeleteTransmitRequests(ctx context.Context, serverURL string, reqs []*pb.TransmitRequest) error
	GetTransmitRequests(ctx context.Context, serverURL string, jobID int32) ([]*Transmission, error)
	PruneTransmitRequests(ctx context.Context, serverURL string, jobID int32, maxSize int) error
	LatestReport(ctx context.Context, feedID [32]byte) (report []byte, err error)
}

type OffchainConfig struct {
	ExpirationWindow uint32          `json:"expirationWindow"` // Integer number of seconds
	BaseUSDFee       decimal.Decimal `json:"baseUSDFee"`       // Base USD fee
}

type OffchainConfigDigester struct {
	FeedID          mercury.FeedID
	ChainID         *big.Int
	ContractAddress common.Address
	Prefix          ocrtypes.ConfigDigestPrefix
}

type PAO interface {
	// These fields are common to all observations
	GetTimestamp() uint32
	GetObserver() commontypes.OracleID
	GetBenchmarkPrice() (*big.Int, bool)
}

type PAOAsk interface {
	GetAsk() (*big.Int, bool)
}

type PAOBid interface {
	GetBid() (*big.Int, bool)
}

type PAOLinkFee interface {
	GetLinkFee() (*big.Int, bool)
}

type PAOMaxFinalizedTimestamp interface {
	GetMaxFinalizedTimestamp() (int64, bool)
}

type PAONativeFee interface {
	GetNativeFee() (*big.Int, bool)
}

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

type StandardOnchainConfigCodec struct{}

type Transmission struct {
	Req       *pb.TransmitRequest    // the payload to transmit
	ReportCtx ocrtypes.ReportContext // contains priority information (latest epoch/round wins)
}

type TransmitQueue interface {
	services.Service

	BlockingPop() (t *Transmission)
	Push(req *pb.TransmitRequest, reportCtx ocrtypes.ReportContext) (ok bool)
	Init(transmissions []*Transmission)
	IsEmpty() bool
}

type Transmitter interface {
	mercury.Transmitter
	services.Service
}

type TransmitterConfig interface {
	TransmitTimeout() time.Duration
}

type TransmitterReportDecoder interface {
	BenchmarkPriceFromReport(ctx context.Context, report ocrtypes.Report) (*big.Int, error)
	ObservationTimestampFromReport(ctx context.Context, report ocrtypes.Report) (uint32, error)
}