Versions in this module Expand all Collapse all v0 v0.5.0 Oct 28, 2024 v0.4.1 Nov 21, 2024 v0.4.0 Sep 2, 2024 v0.3.1 Nov 21, 2024 v0.3.0 Aug 22, 2024 v0.2.1 Nov 21, 2024 v0.2.0 Jul 16, 2024 Changes in this version type ObservationQuorumReply + Quorum int32 + func (x *ObservationQuorumReply) GetQuorum() int32 type ReportsReply + ReportWithInfo []*ReportWithInfo + func (x *ReportsReply) GetReportWithInfo() []*ReportWithInfo v0.1.1 Nov 12, 2024 v0.0.1 Nov 21, 2024 Changes in this version + const ContractTransmitter_FromAccount_FullMethodName + const ContractTransmitter_Transmit_FullMethodName + const ReportingPluginFactory_NewReportingPlugin_FullMethodName + const ReportingPlugin_Close_FullMethodName + const ReportingPlugin_ObservationQuorum_FullMethodName + const ReportingPlugin_Observation_FullMethodName + const ReportingPlugin_Outcome_FullMethodName + const ReportingPlugin_Query_FullMethodName + const ReportingPlugin_Reports_FullMethodName + const ReportingPlugin_ShouldAcceptAttestedReport_FullMethodName + const ReportingPlugin_ShouldTransmitAcceptedReport_FullMethodName + const ReportingPlugin_ValidateObservation_FullMethodName + var ContractTransmitter_ServiceDesc = grpc.ServiceDesc + var File_contract_transmitter_proto protoreflect.FileDescriptor + var File_ocr3_reporting_proto protoreflect.FileDescriptor + var ReportingPluginFactory_ServiceDesc = grpc.ServiceDesc + var ReportingPlugin_ServiceDesc = grpc.ServiceDesc + func RegisterContractTransmitterServer(s grpc.ServiceRegistrar, srv ContractTransmitterServer) + func RegisterReportingPluginFactoryServer(s grpc.ServiceRegistrar, srv ReportingPluginFactoryServer) + func RegisterReportingPluginServer(s grpc.ServiceRegistrar, srv ReportingPluginServer) + type AttributedObservation struct + Observation []byte + Observer uint32 + func (*AttributedObservation) Descriptor() ([]byte, []int) + func (*AttributedObservation) ProtoMessage() + func (x *AttributedObservation) GetObservation() []byte + func (x *AttributedObservation) GetObserver() uint32 + func (x *AttributedObservation) ProtoReflect() protoreflect.Message + func (x *AttributedObservation) Reset() + func (x *AttributedObservation) String() string + type ContractTransmitterClient interface + FromAccount func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FromAccountReply, error) + Transmit func(ctx context.Context, in *TransmitRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + func NewContractTransmitterClient(cc grpc.ClientConnInterface) ContractTransmitterClient + type ContractTransmitterServer interface + FromAccount func(context.Context, *emptypb.Empty) (*FromAccountReply, error) + Transmit func(context.Context, *TransmitRequest) (*emptypb.Empty, error) + type FromAccountReply struct + Account string + func (*FromAccountReply) Descriptor() ([]byte, []int) + func (*FromAccountReply) ProtoMessage() + func (x *FromAccountReply) GetAccount() string + func (x *FromAccountReply) ProtoReflect() protoreflect.Message + func (x *FromAccountReply) Reset() + func (x *FromAccountReply) String() string + type NewReportingPluginReply struct + ReportingPluginID uint32 + ReportingPluginInfo *ReportingPluginInfo + func (*NewReportingPluginReply) Descriptor() ([]byte, []int) + func (*NewReportingPluginReply) ProtoMessage() + func (x *NewReportingPluginReply) GetReportingPluginID() uint32 + func (x *NewReportingPluginReply) GetReportingPluginInfo() *ReportingPluginInfo + func (x *NewReportingPluginReply) ProtoReflect() protoreflect.Message + func (x *NewReportingPluginReply) Reset() + func (x *NewReportingPluginReply) String() string + type NewReportingPluginRequest struct + ReportingPluginConfig *ReportingPluginConfig + func (*NewReportingPluginRequest) Descriptor() ([]byte, []int) + func (*NewReportingPluginRequest) ProtoMessage() + func (x *NewReportingPluginRequest) GetReportingPluginConfig() *ReportingPluginConfig + func (x *NewReportingPluginRequest) ProtoReflect() protoreflect.Message + func (x *NewReportingPluginRequest) Reset() + func (x *NewReportingPluginRequest) String() string + type ObservationQuorumReply struct + QuorumReached bool + func (*ObservationQuorumReply) Descriptor() ([]byte, []int) + func (*ObservationQuorumReply) ProtoMessage() + func (x *ObservationQuorumReply) GetQuorumReached() bool + func (x *ObservationQuorumReply) ProtoReflect() protoreflect.Message + func (x *ObservationQuorumReply) Reset() + func (x *ObservationQuorumReply) String() string + type ObservationQuorumRequest struct + Ao []*AttributedObservation + OutcomeContext *OutcomeContext + Query []byte + func (*ObservationQuorumRequest) Descriptor() ([]byte, []int) + func (*ObservationQuorumRequest) ProtoMessage() + func (x *ObservationQuorumRequest) GetAo() []*AttributedObservation + func (x *ObservationQuorumRequest) GetOutcomeContext() *OutcomeContext + func (x *ObservationQuorumRequest) GetQuery() []byte + func (x *ObservationQuorumRequest) ProtoReflect() protoreflect.Message + func (x *ObservationQuorumRequest) Reset() + func (x *ObservationQuorumRequest) String() string + type ObservationReply struct + Observation []byte + func (*ObservationReply) Descriptor() ([]byte, []int) + func (*ObservationReply) ProtoMessage() + func (x *ObservationReply) GetObservation() []byte + func (x *ObservationReply) ProtoReflect() protoreflect.Message + func (x *ObservationReply) Reset() + func (x *ObservationReply) String() string + type ObservationRequest struct + OutcomeContext *OutcomeContext + Query []byte + func (*ObservationRequest) Descriptor() ([]byte, []int) + func (*ObservationRequest) ProtoMessage() + func (x *ObservationRequest) GetOutcomeContext() *OutcomeContext + func (x *ObservationRequest) GetQuery() []byte + func (x *ObservationRequest) ProtoReflect() protoreflect.Message + func (x *ObservationRequest) Reset() + func (x *ObservationRequest) String() string + type OutcomeContext struct + Epoch uint64 + PreviousOutcome []byte + Round uint64 + SeqNr uint64 + func (*OutcomeContext) Descriptor() ([]byte, []int) + func (*OutcomeContext) ProtoMessage() + func (x *OutcomeContext) GetEpoch() uint64 + func (x *OutcomeContext) GetPreviousOutcome() []byte + func (x *OutcomeContext) GetRound() uint64 + func (x *OutcomeContext) GetSeqNr() uint64 + func (x *OutcomeContext) ProtoReflect() protoreflect.Message + func (x *OutcomeContext) Reset() + func (x *OutcomeContext) String() string + type OutcomeReply struct + Outcome []byte + func (*OutcomeReply) Descriptor() ([]byte, []int) + func (*OutcomeReply) ProtoMessage() + func (x *OutcomeReply) GetOutcome() []byte + func (x *OutcomeReply) ProtoReflect() protoreflect.Message + func (x *OutcomeReply) Reset() + func (x *OutcomeReply) String() string + type OutcomeRequest struct + Ao []*AttributedObservation + OutcomeContext *OutcomeContext + Query []byte + func (*OutcomeRequest) Descriptor() ([]byte, []int) + func (*OutcomeRequest) ProtoMessage() + func (x *OutcomeRequest) GetAo() []*AttributedObservation + func (x *OutcomeRequest) GetOutcomeContext() *OutcomeContext + func (x *OutcomeRequest) GetQuery() []byte + func (x *OutcomeRequest) ProtoReflect() protoreflect.Message + func (x *OutcomeRequest) Reset() + func (x *OutcomeRequest) String() string + type QueryReply struct + Query []byte + func (*QueryReply) Descriptor() ([]byte, []int) + func (*QueryReply) ProtoMessage() + func (x *QueryReply) GetQuery() []byte + func (x *QueryReply) ProtoReflect() protoreflect.Message + func (x *QueryReply) Reset() + func (x *QueryReply) String() string + type QueryRequest struct + OutcomeContext *OutcomeContext + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (x *QueryRequest) GetOutcomeContext() *OutcomeContext + func (x *QueryRequest) ProtoReflect() protoreflect.Message + func (x *QueryRequest) Reset() + func (x *QueryRequest) String() string + type ReportPlus struct + ReportWithInfo *ReportWithInfo + TransmissionScheduleOverride *TransmissionSchedule + func (*ReportPlus) Descriptor() ([]byte, []int) + func (*ReportPlus) ProtoMessage() + func (x *ReportPlus) GetReportWithInfo() *ReportWithInfo + func (x *ReportPlus) GetTransmissionScheduleOverride() *TransmissionSchedule + func (x *ReportPlus) ProtoReflect() protoreflect.Message + func (x *ReportPlus) Reset() + func (x *ReportPlus) String() string + type ReportWithInfo struct + Info []byte + Report []byte + func (*ReportWithInfo) Descriptor() ([]byte, []int) + func (*ReportWithInfo) ProtoMessage() + func (x *ReportWithInfo) GetInfo() []byte + func (x *ReportWithInfo) GetReport() []byte + func (x *ReportWithInfo) ProtoReflect() protoreflect.Message + func (x *ReportWithInfo) Reset() + func (x *ReportWithInfo) String() string + type ReportingPluginClient interface + Close func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) + Observation func(ctx context.Context, in *ObservationRequest, opts ...grpc.CallOption) (*ObservationReply, error) + ObservationQuorum func(ctx context.Context, in *ObservationQuorumRequest, opts ...grpc.CallOption) (*ObservationQuorumReply, error) + Outcome func(ctx context.Context, in *OutcomeRequest, opts ...grpc.CallOption) (*OutcomeReply, error) + Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryReply, error) + Reports func(ctx context.Context, in *ReportsRequest, opts ...grpc.CallOption) (*ReportsReply, error) + ShouldAcceptAttestedReport func(ctx context.Context, in *ShouldAcceptAttestedReportRequest, ...) (*ShouldAcceptAttestedReportReply, error) + ShouldTransmitAcceptedReport func(ctx context.Context, in *ShouldTransmitAcceptedReportRequest, ...) (*ShouldTransmitAcceptedReportReply, error) + ValidateObservation func(ctx context.Context, in *ValidateObservationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + func NewReportingPluginClient(cc grpc.ClientConnInterface) ReportingPluginClient + type ReportingPluginConfig struct + ConfigDigest []byte + EstimatedRoundInterval int64 + F uint32 + MaxDurationObservation int64 + MaxDurationQuery int64 + MaxDurationShouldAcceptAttestedReport int64 + MaxDurationShouldTransmitAcceptedReport int64 + N uint32 + OffchainConfig []byte + OnchainConfig []byte + OracleID uint32 + func (*ReportingPluginConfig) Descriptor() ([]byte, []int) + func (*ReportingPluginConfig) ProtoMessage() + func (x *ReportingPluginConfig) GetConfigDigest() []byte + func (x *ReportingPluginConfig) GetEstimatedRoundInterval() int64 + func (x *ReportingPluginConfig) GetF() uint32 + func (x *ReportingPluginConfig) GetMaxDurationObservation() int64 + func (x *ReportingPluginConfig) GetMaxDurationQuery() int64 + func (x *ReportingPluginConfig) GetMaxDurationShouldAcceptAttestedReport() int64 + func (x *ReportingPluginConfig) GetMaxDurationShouldTransmitAcceptedReport() int64 + func (x *ReportingPluginConfig) GetN() uint32 + func (x *ReportingPluginConfig) GetOffchainConfig() []byte + func (x *ReportingPluginConfig) GetOnchainConfig() []byte + func (x *ReportingPluginConfig) GetOracleID() uint32 + func (x *ReportingPluginConfig) ProtoReflect() protoreflect.Message + func (x *ReportingPluginConfig) Reset() + func (x *ReportingPluginConfig) String() string + type ReportingPluginFactoryClient interface + NewReportingPlugin func(ctx context.Context, in *NewReportingPluginRequest, opts ...grpc.CallOption) (*NewReportingPluginReply, error) + func NewReportingPluginFactoryClient(cc grpc.ClientConnInterface) ReportingPluginFactoryClient + type ReportingPluginFactoryServer interface + NewReportingPlugin func(context.Context, *NewReportingPluginRequest) (*NewReportingPluginReply, error) + type ReportingPluginInfo struct + Name string + ReportingPluginLimits *ReportingPluginLimits + func (*ReportingPluginInfo) Descriptor() ([]byte, []int) + func (*ReportingPluginInfo) ProtoMessage() + func (x *ReportingPluginInfo) GetName() string + func (x *ReportingPluginInfo) GetReportingPluginLimits() *ReportingPluginLimits + func (x *ReportingPluginInfo) ProtoReflect() protoreflect.Message + func (x *ReportingPluginInfo) Reset() + func (x *ReportingPluginInfo) String() string + type ReportingPluginLimits struct + MaxObservationLength uint64 + MaxOutcomeLength uint64 + MaxQueryLength uint64 + MaxReportCount uint64 + MaxReportLength uint64 + func (*ReportingPluginLimits) Descriptor() ([]byte, []int) + func (*ReportingPluginLimits) ProtoMessage() + func (x *ReportingPluginLimits) GetMaxObservationLength() uint64 + func (x *ReportingPluginLimits) GetMaxOutcomeLength() uint64 + func (x *ReportingPluginLimits) GetMaxQueryLength() uint64 + func (x *ReportingPluginLimits) GetMaxReportCount() uint64 + func (x *ReportingPluginLimits) GetMaxReportLength() uint64 + func (x *ReportingPluginLimits) ProtoReflect() protoreflect.Message + func (x *ReportingPluginLimits) Reset() + func (x *ReportingPluginLimits) String() string + type ReportingPluginServer interface + Close func(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + Observation func(context.Context, *ObservationRequest) (*ObservationReply, error) + ObservationQuorum func(context.Context, *ObservationQuorumRequest) (*ObservationQuorumReply, error) + Outcome func(context.Context, *OutcomeRequest) (*OutcomeReply, error) + Query func(context.Context, *QueryRequest) (*QueryReply, error) + Reports func(context.Context, *ReportsRequest) (*ReportsReply, error) + ShouldAcceptAttestedReport func(context.Context, *ShouldAcceptAttestedReportRequest) (*ShouldAcceptAttestedReportReply, error) + ShouldTransmitAcceptedReport func(context.Context, *ShouldTransmitAcceptedReportRequest) (*ShouldTransmitAcceptedReportReply, error) + ValidateObservation func(context.Context, *ValidateObservationRequest) (*emptypb.Empty, error) + type ReportsReply struct + ReportPlus []*ReportPlus + func (*ReportsReply) Descriptor() ([]byte, []int) + func (*ReportsReply) ProtoMessage() + func (x *ReportsReply) GetReportPlus() []*ReportPlus + func (x *ReportsReply) ProtoReflect() protoreflect.Message + func (x *ReportsReply) Reset() + func (x *ReportsReply) String() string + type ReportsRequest struct + Outcome []byte + SeqNr uint64 + func (*ReportsRequest) Descriptor() ([]byte, []int) + func (*ReportsRequest) ProtoMessage() + func (x *ReportsRequest) GetOutcome() []byte + func (x *ReportsRequest) GetSeqNr() uint64 + func (x *ReportsRequest) ProtoReflect() protoreflect.Message + func (x *ReportsRequest) Reset() + func (x *ReportsRequest) String() string + type ShouldAcceptAttestedReportReply struct + ShouldAccept bool + func (*ShouldAcceptAttestedReportReply) Descriptor() ([]byte, []int) + func (*ShouldAcceptAttestedReportReply) ProtoMessage() + func (x *ShouldAcceptAttestedReportReply) GetShouldAccept() bool + func (x *ShouldAcceptAttestedReportReply) ProtoReflect() protoreflect.Message + func (x *ShouldAcceptAttestedReportReply) Reset() + func (x *ShouldAcceptAttestedReportReply) String() string + type ShouldAcceptAttestedReportRequest struct + Ri *ReportWithInfo + SegNr uint64 + func (*ShouldAcceptAttestedReportRequest) Descriptor() ([]byte, []int) + func (*ShouldAcceptAttestedReportRequest) ProtoMessage() + func (x *ShouldAcceptAttestedReportRequest) GetRi() *ReportWithInfo + func (x *ShouldAcceptAttestedReportRequest) GetSegNr() uint64 + func (x *ShouldAcceptAttestedReportRequest) ProtoReflect() protoreflect.Message + func (x *ShouldAcceptAttestedReportRequest) Reset() + func (x *ShouldAcceptAttestedReportRequest) String() string + type ShouldTransmitAcceptedReportReply struct + ShouldTransmit bool + func (*ShouldTransmitAcceptedReportReply) Descriptor() ([]byte, []int) + func (*ShouldTransmitAcceptedReportReply) ProtoMessage() + func (x *ShouldTransmitAcceptedReportReply) GetShouldTransmit() bool + func (x *ShouldTransmitAcceptedReportReply) ProtoReflect() protoreflect.Message + func (x *ShouldTransmitAcceptedReportReply) Reset() + func (x *ShouldTransmitAcceptedReportReply) String() string + type ShouldTransmitAcceptedReportRequest struct + Ri *ReportWithInfo + SegNr uint64 + func (*ShouldTransmitAcceptedReportRequest) Descriptor() ([]byte, []int) + func (*ShouldTransmitAcceptedReportRequest) ProtoMessage() + func (x *ShouldTransmitAcceptedReportRequest) GetRi() *ReportWithInfo + func (x *ShouldTransmitAcceptedReportRequest) GetSegNr() uint64 + func (x *ShouldTransmitAcceptedReportRequest) ProtoReflect() protoreflect.Message + func (x *ShouldTransmitAcceptedReportRequest) Reset() + func (x *ShouldTransmitAcceptedReportRequest) String() string + type Signature struct + Signature []byte + Signer uint32 + func (*Signature) Descriptor() ([]byte, []int) + func (*Signature) ProtoMessage() + func (x *Signature) GetSignature() []byte + func (x *Signature) GetSigner() uint32 + func (x *Signature) ProtoReflect() protoreflect.Message + func (x *Signature) Reset() + func (x *Signature) String() string + type TransmissionSchedule struct + TransmissionDelays []int64 + Transmitters []uint32 + func (*TransmissionSchedule) Descriptor() ([]byte, []int) + func (*TransmissionSchedule) ProtoMessage() + func (x *TransmissionSchedule) GetTransmissionDelays() []int64 + func (x *TransmissionSchedule) GetTransmitters() []uint32 + func (x *TransmissionSchedule) ProtoReflect() protoreflect.Message + func (x *TransmissionSchedule) Reset() + func (x *TransmissionSchedule) String() string + type TransmitRequest struct + ConfigDigest []byte + ReportWithInfo *ReportWithInfo + SeqNr uint64 + Signatures []*Signature + func (*TransmitRequest) Descriptor() ([]byte, []int) + func (*TransmitRequest) ProtoMessage() + func (x *TransmitRequest) GetConfigDigest() []byte + func (x *TransmitRequest) GetReportWithInfo() *ReportWithInfo + func (x *TransmitRequest) GetSeqNr() uint64 + func (x *TransmitRequest) GetSignatures() []*Signature + func (x *TransmitRequest) ProtoReflect() protoreflect.Message + func (x *TransmitRequest) Reset() + func (x *TransmitRequest) String() string + type UnimplementedContractTransmitterServer struct + func (UnimplementedContractTransmitterServer) FromAccount(context.Context, *emptypb.Empty) (*FromAccountReply, error) + func (UnimplementedContractTransmitterServer) Transmit(context.Context, *TransmitRequest) (*emptypb.Empty, error) + type UnimplementedReportingPluginFactoryServer struct + func (UnimplementedReportingPluginFactoryServer) NewReportingPlugin(context.Context, *NewReportingPluginRequest) (*NewReportingPluginReply, error) + type UnimplementedReportingPluginServer struct + func (UnimplementedReportingPluginServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + func (UnimplementedReportingPluginServer) Observation(context.Context, *ObservationRequest) (*ObservationReply, error) + func (UnimplementedReportingPluginServer) ObservationQuorum(context.Context, *ObservationQuorumRequest) (*ObservationQuorumReply, error) + func (UnimplementedReportingPluginServer) Outcome(context.Context, *OutcomeRequest) (*OutcomeReply, error) + func (UnimplementedReportingPluginServer) Query(context.Context, *QueryRequest) (*QueryReply, error) + func (UnimplementedReportingPluginServer) Reports(context.Context, *ReportsRequest) (*ReportsReply, error) + func (UnimplementedReportingPluginServer) ShouldAcceptAttestedReport(context.Context, *ShouldAcceptAttestedReportRequest) (*ShouldAcceptAttestedReportReply, error) + func (UnimplementedReportingPluginServer) ShouldTransmitAcceptedReport(context.Context, *ShouldTransmitAcceptedReportRequest) (*ShouldTransmitAcceptedReportReply, error) + func (UnimplementedReportingPluginServer) ValidateObservation(context.Context, *ValidateObservationRequest) (*emptypb.Empty, error) + type UnsafeContractTransmitterServer interface + type UnsafeReportingPluginFactoryServer interface + type UnsafeReportingPluginServer interface + type ValidateObservationRequest struct + Ao *AttributedObservation + OutcomeContext *OutcomeContext + Query []byte + func (*ValidateObservationRequest) Descriptor() ([]byte, []int) + func (*ValidateObservationRequest) ProtoMessage() + func (x *ValidateObservationRequest) GetAo() *AttributedObservation + func (x *ValidateObservationRequest) GetOutcomeContext() *OutcomeContext + func (x *ValidateObservationRequest) GetQuery() []byte + func (x *ValidateObservationRequest) ProtoReflect() protoreflect.Message + func (x *ValidateObservationRequest) Reset() + func (x *ValidateObservationRequest) String() string v0.0.1-beta Nov 26, 2024
Go to main page