Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + const ContractTransmitterTimeoutWarningGracePeriod + const ReportingPluginTimeoutWarningGracePeriod + func ByzQuorumSize(n, f int) int + func Leader(epoch uint64, n int, key [16]byte) (leader commontypes.OracleID) + func RunOracle[RI any](ctx context.Context, config ocr3config.SharedConfig, ...) + func RunPacemaker[RI any](ctx context.Context, chNetToPacemaker <-chan MessageToPacemakerWithSender[RI], ...) + func RunReportFinalization[RI any](ctx context.Context, ...) + func RunReportGeneration[RI any](ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + func RunTransmission[RI any](ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + type AttestedReportMany struct + AttributedSignatures []types.AttributedOnchainSignature + ReportWithInfo ocr3types.ReportWithInfo[RI] + type AttributedCommitSignature struct + Signature CommitSignature + Signer commontypes.OracleID + type AttributedPrepareSignature struct + Signature PrepareSignature + Signer commontypes.OracleID + type AttributedSignedHighestCertifiedTimestamp struct + SignedHighestCertifiedTimestamp SignedHighestCertifiedTimestamp + Signer commontypes.OracleID + type AttributedSignedObservation struct + Observer commontypes.OracleID + SignedObservation SignedObservation + type CertifiedPrepareOrCommit interface + Epoch func() uint64 + IsGenesis func() bool + Timestamp func() HighestCertifiedTimestamp + Verify func(_ types.ConfigDigest, _ []config.OracleIdentity, n int, f int) error + type CertifiedPrepareOrCommitCommit struct + CommitEpoch uint64 + CommitQuorumCertificate []AttributedCommitSignature + Outcome ocr3types.Outcome + SeqNr uint64 + func (hc *CertifiedPrepareOrCommitCommit) Epoch() uint64 + func (hc *CertifiedPrepareOrCommitCommit) IsGenesis() bool + func (hc *CertifiedPrepareOrCommitCommit) Timestamp() HighestCertifiedTimestamp + func (hc *CertifiedPrepareOrCommitCommit) Verify(configDigest types.ConfigDigest, oracleIdentities []config.OracleIdentity, ...) error + type CertifiedPrepareOrCommitPrepare struct + Outcome ocr3types.Outcome + OutcomeInputsDigest OutcomeInputsDigest + PrepareEpoch uint64 + PrepareQuorumCertificate []AttributedPrepareSignature + SeqNr uint64 + func (hc *CertifiedPrepareOrCommitPrepare) Epoch() uint64 + func (hc *CertifiedPrepareOrCommitPrepare) IsGenesis() bool + func (hc *CertifiedPrepareOrCommitPrepare) Timestamp() HighestCertifiedTimestamp + func (hc *CertifiedPrepareOrCommitPrepare) Verify(configDigest types.ConfigDigest, oracleIdentities []config.OracleIdentity, ...) error + type CommitSignature []byte + func MakeCommitSignature(ocr3ts Timestamp, seqNr uint64, outcomeDigest OutcomeDigest, ...) (CommitSignature, error) + func (sig CommitSignature) Verify(ocr3ts Timestamp, seqNr uint64, outcomeDigest OutcomeDigest, ...) error + type Database interface + ReadCert func(ctx context.Context, configDigest types.ConfigDigest) (CertifiedPrepareOrCommit, error) + WriteCert func(ctx context.Context, configDigest types.ConfigDigest, ...) error + type EventChangeLeader struct + type EventDeliver struct + CertifiedCommit CertifiedPrepareOrCommitCommit + type EventMissingOutcome struct + SeqNr uint64 + type EventProgress struct + type EventStartNewEpoch struct + Epoch uint64 + type EventToPacemaker interface + type EventToReportFinalization interface + type EventToReportGeneration interface + type EventToTransmission interface + type EventTransmit struct + AttestedReport AttestedReportMany[RI] + Index int + SeqNr uint64 + type HighestCertifiedTimestamp struct + CommittedElsePrepared bool + SeqNr uint64 + func (t HighestCertifiedTimestamp) Less(t2 HighestCertifiedTimestamp) bool + type Message interface + CheckSize func(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageBuffer struct + func NewMessageBuffer[RI any](cap int) *MessageBuffer[RI] + func (rb *MessageBuffer[RI]) Peek() *MessageToReportGeneration[RI] + func (rb *MessageBuffer[RI]) Pop() *MessageToReportGeneration[RI] + func (rb *MessageBuffer[RI]) Push(msg MessageToReportGeneration[RI]) + type MessageCommit struct + Epoch uint64 + SeqNr uint64 + Signature CommitSignature + func (msg MessageCommit[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageFinal struct + ReportSignatures [][]byte + SeqNr uint64 + func (msg MessageFinal[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageNewEpoch struct + Epoch uint64 + func (msg MessageNewEpoch[RI]) CheckSize(types.ReportingPluginLimits) bool + type MessageObserve struct + Epoch uint64 + SeqNr uint64 + SignedObservation SignedObservation + func (msg MessageObserve[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessagePrepare struct + Epoch uint64 + SeqNr uint64 + Signature PrepareSignature + func (msg MessagePrepare[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessagePropose struct + AttributedSignedObservations []AttributedSignedObservation + Epoch uint64 + SeqNr uint64 + func (msg MessagePropose[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageReconcile struct + Epoch uint64 + HighestCertified CertifiedPrepareOrCommit + SignedHighestCertifiedTimestamp SignedHighestCertifiedTimestamp + func (msg MessageReconcile[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageRequestCertifiedCommit struct + SeqNr uint64 + func (msg MessageRequestCertifiedCommit[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageStartEpoch struct + Epoch uint64 + StartEpochProof StartEpochProof + func (msg MessageStartEpoch[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageStartRound struct + Epoch uint64 + Query types.Query + SeqNr uint64 + func (msg MessageStartRound[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageSupplyCertifiedCommit struct + CertifiedCommit CertifiedPrepareOrCommitCommit + func (msg MessageSupplyCertifiedCommit[RI]) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageToPacemaker interface + type MessageToPacemakerWithSender struct + type MessageToReportFinalization interface + type MessageToReportFinalizationWithSender struct + type MessageToReportGeneration interface + type MessageToReportGenerationWithSender struct + type MessageWithSender struct + Msg Message[RI] + Sender commontypes.OracleID + type MinHeapTimeToPendingTransmission struct + func (h *MinHeapTimeToPendingTransmission[RI]) Len() int + func (h *MinHeapTimeToPendingTransmission[RI]) Peek() MinHeapTimeToPendingTransmissionItem[RI] + func (h *MinHeapTimeToPendingTransmission[RI]) Pop() MinHeapTimeToPendingTransmissionItem[RI] + func (h *MinHeapTimeToPendingTransmission[RI]) Push(item MinHeapTimeToPendingTransmissionItem[RI]) + type MinHeapTimeToPendingTransmissionInternal []MinHeapTimeToPendingTransmissionItem[RI] + func (pq *MinHeapTimeToPendingTransmissionInternal[RI]) Pop() interface{} + func (pq *MinHeapTimeToPendingTransmissionInternal[RI]) Push(x interface{}) + func (pq MinHeapTimeToPendingTransmissionInternal[RI]) Len() int + func (pq MinHeapTimeToPendingTransmissionInternal[RI]) Less(i, j int) bool + func (pq MinHeapTimeToPendingTransmissionInternal[RI]) Swap(i, j int) + type MinHeapTimeToPendingTransmissionItem struct + AttestedReport AttestedReportMany[RI] + Index int + SeqNr uint64 + Time time.Time + type NetworkEndpoint interface + Close func() error + Receive func() <-chan MessageWithSender[RI] + Start func() error + type NetworkSender interface + Broadcast func(msg Message[RI]) + SendTo func(msg Message[RI], to commontypes.OracleID) + type OutcomeDigest [32]byte + func MakeOutcomeDigest(outcome ocr3types.Outcome) OutcomeDigest + type OutcomeInputsDigest [32]byte + func MakeOutcomeInputsDigest(ocr3ts Timestamp, previousOutcome ocr3types.Outcome, seqNr uint64, ...) OutcomeInputsDigest + type PrepareSignature []byte + func MakePrepareSignature(ocr3ts Timestamp, seqNr uint64, outcomeInputsDigest OutcomeInputsDigest, ...) (PrepareSignature, error) + func (sig PrepareSignature) Verify(ocr3ts Timestamp, seqNr uint64, outcomeInputsDigest OutcomeInputsDigest, ...) error + type SignedHighestCertifiedTimestamp struct + HighestCertifiedTimestamp HighestCertifiedTimestamp + Signature []byte + func MakeSignedHighestCertifiedTimestamp(ocr3ts Timestamp, highestCertifiedTimestamp HighestCertifiedTimestamp, ...) (SignedHighestCertifiedTimestamp, error) + func (shct *SignedHighestCertifiedTimestamp) Verify(ocr3ts Timestamp, publicKey types.OffchainPublicKey) error + type SignedObservation struct + Observation types.Observation + Signature []byte + func MakeSignedObservation(ocr3ts Timestamp, query types.Query, observation types.Observation, ...) (SignedObservation, error) + func (so SignedObservation) Verify(ocr3ts Timestamp, query types.Query, publicKey types.OffchainPublicKey) error + type SimpleNetwork struct + func NewSimpleNetwork[RI any](n int) *SimpleNetwork[RI] + func (net *SimpleNetwork[RI]) Endpoint(id commontypes.OracleID) (NetworkEndpoint[RI], error) + type SimpleNetworkEndpoint struct + func (SimpleNetworkEndpoint[RI]) Close() error + func (SimpleNetworkEndpoint[RI]) Start() error + func (end SimpleNetworkEndpoint[RI]) Broadcast(msg Message[RI]) + func (end SimpleNetworkEndpoint[RI]) Receive() <-chan MessageWithSender[RI] + func (end SimpleNetworkEndpoint[RI]) SendTo(msg Message[RI], to commontypes.OracleID) + type StartEpochProof struct + HighestCertified CertifiedPrepareOrCommit + HighestCertifiedProof []AttributedSignedHighestCertifiedTimestamp + func (qc *StartEpochProof) Verify(ocr3ts Timestamp, oracleIdentities []config.OracleIdentity, n int, f int) error + type TelemetrySender interface + RoundStarted func(configDigest types.ConfigDigest, epoch uint64, round uint8, ...) + type Timestamp struct + ConfigDigest types.ConfigDigest + Epoch uint64 + type XXXUnknownMessageType struct + func (XXXUnknownMessageType[RI]) CheckSize(types.ReportingPluginLimits) bool
Go to main page