Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + type LimitCheckReportingPlugin struct + Limits types.ReportingPluginLimits + Plugin types.ReportingPlugin + func (rp LimitCheckReportingPlugin) Close() error + func (rp LimitCheckReportingPlugin) Observation(ctx context.Context, ts types.ReportTimestamp, query types.Query) (types.Observation, error) + func (rp LimitCheckReportingPlugin) Query(ctx context.Context, ts types.ReportTimestamp) (types.Query, error) + func (rp LimitCheckReportingPlugin) Report(ctx context.Context, ts types.ReportTimestamp, query types.Query, ...) (bool, types.Report, error) + func (rp LimitCheckReportingPlugin) ShouldAcceptFinalizedReport(ctx context.Context, ts types.ReportTimestamp, report types.Report) (bool, error) + func (rp LimitCheckReportingPlugin) ShouldTransmitAcceptedReport(ctx context.Context, ts types.ReportTimestamp, report types.Report) (bool, error) + type OCR2SerializingEndpoint struct + func NewOCR2SerializingEndpoint(chTelemetry chan<- *serialization.TelemetryWrapper, ...) *OCR2SerializingEndpoint + func (n *OCR2SerializingEndpoint) Broadcast(msg protocol.Message) + func (n *OCR2SerializingEndpoint) Close() error + func (n *OCR2SerializingEndpoint) Receive() <-chan protocol.MessageWithSender + func (n *OCR2SerializingEndpoint) SendTo(msg protocol.Message, to commontypes.OracleID) + func (n *OCR2SerializingEndpoint) Start() error + type OCR2TelemetrySender struct + func MakeOCR2TelemetrySender(chTelemetry chan<- *serialization.TelemetryWrapper, logger commontypes.Logger) OCR2TelemetrySender + func (ts OCR2TelemetrySender) RoundStarted(configDigest types.ConfigDigest, epoch uint32, round uint8, ...) + type OCR3SerializingEndpoint struct + func NewOCR3SerializingEndpoint[RI any](chTelemetry chan<- *serialization.TelemetryWrapper, ...) *OCR3SerializingEndpoint[RI] + func (n *OCR3SerializingEndpoint[RI]) Broadcast(msg protocol.Message[RI]) + func (n *OCR3SerializingEndpoint[RI]) Close() error + func (n *OCR3SerializingEndpoint[RI]) Receive() <-chan protocol.MessageWithSender[RI] + func (n *OCR3SerializingEndpoint[RI]) SendTo(msg protocol.Message[RI], to commontypes.OracleID) + func (n *OCR3SerializingEndpoint[RI]) Start() error + type OCR3TelemetrySender struct + func MakeOCR3TelemetrySender(chTelemetry chan<- *serialization.TelemetryWrapper, logger commontypes.Logger) OCR3TelemetrySender + func (ts OCR3TelemetrySender) RoundStarted(configDigest types.ConfigDigest, epoch uint64, round uint8, ...) + type SerializingOCR3Database struct + BinaryDb ocr3types.Database + func (db *SerializingOCR3Database) ReadCert(ctx context.Context, configDigest types.ConfigDigest) (protocol.CertifiedPrepareOrCommit, error) + func (db *SerializingOCR3Database) ReadConfig(ctx context.Context) (*types.ContractConfig, error) + func (db *SerializingOCR3Database) WriteCert(ctx context.Context, configDigest types.ConfigDigest, ...) error + func (db *SerializingOCR3Database) WriteConfig(ctx context.Context, config types.ContractConfig) error
Go to main page