Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + const ContractTransmitterTimeoutWarningGracePeriod + const ReportingPluginTimeoutWarningGracePeriod + func Leader(epoch uint32, n int, key [16]byte) (leader commontypes.OracleID) + func RunOracle(ctx context.Context, config ocr2config.SharedConfig, ...) + func RunPacemaker(ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + func RunReportFinalization(ctx context.Context, ...) + func RunReportGeneration(ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + func RunTransmission(ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + type AttestedReportMany struct + AttributedSignatures []types.AttributedOnchainSignature + Report types.Report + func (rep *AttestedReportMany) VerifySignatures(numSignatures int, onchainKeyring types.OnchainKeyring, ...) error + func (rep AttestedReportMany) TestEqual(c2 AttestedReportMany) bool + type AttestedReportOne struct + Report types.Report + Signature []byte + Skip bool + func MakeAttestedReportOneNoskip(repctx types.ReportContext, report types.Report, ...) (AttestedReportOne, error) + func MakeAttestedReportOneSkip() AttestedReportOne + func (aro *AttestedReportOne) Verify(contractSigner types.OnchainKeyring, publicKey types.OnchainPublicKey, ...) (err error) + func (rep AttestedReportOne) EqualExceptSignature(rep2 AttestedReportOne) bool + func (rep AttestedReportOne) TestEqual(rep2 AttestedReportOne) bool + type AttributedObservation struct + Observation types.Observation + Observer commontypes.OracleID + type AttributedSignedObservation struct + Observer commontypes.OracleID + SignedObservation SignedObservation + func (aso AttributedSignedObservation) Equal(aso2 AttributedSignedObservation) bool + type EpochRound struct + Epoch uint32 + Round uint8 + func (x EpochRound) Less(y EpochRound) bool + type EventChangeLeader struct + type EventFinal struct + type EventProgress struct + type EventToPacemaker interface + type EventToReportFinalization interface + type EventToTransmission interface + type EventTransmit struct + AttestedReport AttestedReportMany + Epoch uint32 + H [32]byte + Round uint8 + type Message interface + CheckSize func(reportingPluginLimits types.ReportingPluginLimits) bool + type MessageBuffer struct + func NewMessageBuffer(cap int) *MessageBuffer + func (rb *MessageBuffer) Peek() *MessageToReportGeneration + func (rb *MessageBuffer) Pop() *MessageToReportGeneration + func (rb *MessageBuffer) Push(msg MessageToReportGeneration) + type MessageFinal struct + AttestedReport AttestedReportMany + Epoch uint32 + H [32]byte + Round uint8 + func (msg MessageFinal) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + func (msg MessageFinal) TestEqual(m2 MessageFinal) bool + type MessageFinalEcho struct + func (msg MessageFinalEcho) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + func (msg MessageFinalEcho) TestEqual(m2 MessageFinalEcho) bool + type MessageNewEpoch struct + Epoch uint32 + func (msg MessageNewEpoch) CheckSize(types.ReportingPluginLimits) bool + type MessageObserve struct + Epoch uint32 + Round uint8 + SignedObservation SignedObservation + func (msg MessageObserve) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + func (msg MessageObserve) TestEqual(msg2 MessageObserve) bool + type MessageObserveReq struct + Epoch uint32 + Query types.Query + Round uint8 + func (msg MessageObserveReq) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + func (msg MessageObserveReq) TestEqual(msg2 MessageObserveReq) bool + type MessageReport struct + AttestedReport AttestedReportOne + Epoch uint32 + Round uint8 + func (msg MessageReport) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + func (msg MessageReport) TestEqual(m2 MessageReport) bool + type MessageReportReq struct + AttributedSignedObservations []AttributedSignedObservation + Epoch uint32 + Query types.Query + Round uint8 + func (msg MessageReportReq) CheckSize(reportingPluginLimits types.ReportingPluginLimits) bool + func (msg MessageReportReq) TestEqual(msg2 MessageReportReq) bool + type MessageToPacemaker interface + type MessageToPacemakerWithSender struct + type MessageToReportFinalization interface + type MessageToReportFinalizationWithSender struct + type MessageToReportGeneration interface + type MessageToReportGenerationWithSender struct + type MessageWithSender struct + Msg Message + Sender commontypes.OracleID + type MinHeapTimeToPendingTransmission struct + func (h *MinHeapTimeToPendingTransmission) Len() int + func (h *MinHeapTimeToPendingTransmission) Peek() MinHeapTimeToPendingTransmissionItem + func (h *MinHeapTimeToPendingTransmission) Pop() MinHeapTimeToPendingTransmissionItem + func (h *MinHeapTimeToPendingTransmission) Push(item MinHeapTimeToPendingTransmissionItem) + type MinHeapTimeToPendingTransmissionInternal []MinHeapTimeToPendingTransmissionItem + func (pq *MinHeapTimeToPendingTransmissionInternal) Pop() interface{} + func (pq *MinHeapTimeToPendingTransmissionInternal) Push(x interface{}) + func (pq MinHeapTimeToPendingTransmissionInternal) Len() int + func (pq MinHeapTimeToPendingTransmissionInternal) Less(i, j int) bool + func (pq MinHeapTimeToPendingTransmissionInternal) Swap(i, j int) + type MinHeapTimeToPendingTransmissionItem struct + type NetworkEndpoint interface + Close func() error + Receive func() <-chan MessageWithSender + Start func() error + type NetworkSender interface + Broadcast func(msg Message) + SendTo func(msg Message, to commontypes.OracleID) + type SignedObservation struct + Observation types.Observation + Signature []byte + func MakeSignedObservation(repts types.ReportTimestamp, query types.Query, observation types.Observation, ...) (SignedObservation, error) + func (so SignedObservation) Equal(so2 SignedObservation) bool + func (so SignedObservation) Verify(repts types.ReportTimestamp, query types.Query, ...) error + type SimpleNetwork struct + func NewSimpleNetwork(n int) *SimpleNetwork + func (net *SimpleNetwork) Endpoint(id commontypes.OracleID) (NetworkEndpoint, error) + type SimpleNetworkEndpoint struct + func (SimpleNetworkEndpoint) Close() error + func (SimpleNetworkEndpoint) Start() error + func (end SimpleNetworkEndpoint) Broadcast(msg Message) + func (end SimpleNetworkEndpoint) Receive() <-chan MessageWithSender + func (end SimpleNetworkEndpoint) SendTo(msg Message, to commontypes.OracleID) + type TelemetrySender interface + RoundStarted func(configDigest types.ConfigDigest, epoch uint32, round uint8, ...) + type XXXUnknownMessageType struct + func (XXXUnknownMessageType) CheckSize(types.ReportingPluginLimits) bool
Go to main page