Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + func Leader(epoch uint32, n int, key [16]byte) (leader commontypes.OracleID) + func RunOracle(ctx context.Context, config config.SharedConfig, ...) + func RunPacemaker(ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + func RunReportGeneration(ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + func RunTransmission(ctx context.Context, subprocesses *subprocesses.Subprocesses, ...) + type AttestedReportMany struct + AttributedObservations AttributedObservations + Signatures [][]byte + func (rep *AttestedReportMany) TransmissionArgs(repctx ReportContext) (report []byte, rs, ss [][32]byte, vs [32]byte, err error) + func (rep *AttestedReportMany) VerifySignatures(repctx ReportContext, as signature.EthAddresses) error + func (rep AttestedReportMany) Equal(c2 AttestedReportMany) bool + type AttestedReportOne struct + AttributedObservations AttributedObservations + Signature []byte + func MakeAttestedReportOne(aos AttributedObservations, repctx ReportContext, ...) (AttestedReportOne, error) + func (c *AttestedReportOne) Verify(repctx ReportContext, a types.OnChainSigningAddress) (err error) + func (rep AttestedReportOne) Equal(rep2 AttestedReportOne) bool + type AttributedObservation struct + Observation observation.Observation + Observer commontypes.OracleID + func (o AttributedObservation) Equal(o2 AttributedObservation) bool + type AttributedObservations []AttributedObservation + func (aos AttributedObservations) Equal(aos2 AttributedObservations) bool + func (aos AttributedObservations) Median() (observation.Observation, error) + func (aos AttributedObservations) OnChainReport(repctx ReportContext) ([]byte, error) + type AttributedSignedObservation struct + Observer commontypes.OracleID + SignedObservation SignedObservation + func (aso AttributedSignedObservation) Equal(aso2 AttributedSignedObservation) bool + type DomainSeparationTag [32]byte + type EpochRound struct + Epoch uint32 + Round uint8 + func (x EpochRound) Less(y EpochRound) bool + type EventChangeLeader struct + type EventProgress struct + type EventToPacemaker interface + type EventToTransmission interface + type EventTransmit struct + Epoch uint32 + Report AttestedReportMany + Round uint8 + type Message interface + 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 + Epoch uint32 + Report AttestedReportMany + Round uint8 + func (msg MessageFinal) Equal(m2 MessageFinal) bool + type MessageFinalEcho struct + func (msg MessageFinalEcho) Equal(m2 MessageFinalEcho) bool + type MessageNewEpoch struct + Epoch uint32 + type MessageObserve struct + Epoch uint32 + Round uint8 + SignedObservation SignedObservation + func (msg MessageObserve) Equal(msg2 MessageObserve) bool + type MessageObserveReq struct + Epoch uint32 + Round uint8 + type MessageReport struct + Epoch uint32 + Report AttestedReportOne + Round uint8 + func (msg MessageReport) Equal(m2 MessageReport) bool + type MessageReportReq struct + AttributedSignedObservations []AttributedSignedObservation + Epoch uint32 + Round uint8 + type MessageToPacemaker interface + type MessageToPacemakerWithSender 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 ReportContext struct + ConfigDigest types.ConfigDigest + Epoch uint32 + Round uint8 + func (r ReportContext) DomainSeparationTag() (d DomainSeparationTag) + func (r ReportContext) Equal(r2 ReportContext) bool + type SignedObservation struct + Observation observation.Observation + Signature []byte + func MakeSignedObservation(observation observation.Observation, repctx ReportContext, ...) (SignedObservation, error) + func (so SignedObservation) Equal(so2 SignedObservation) bool + func (so SignedObservation) Verify(repctx ReportContext, publicKey types.OffchainPublicKey) 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
Go to main page