Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterContractTransmitterServer(s grpc.ServiceRegistrar, srv ContractTransmitterServer)
- func RegisterReportingPluginFactoryServer(s grpc.ServiceRegistrar, srv ReportingPluginFactoryServer)
- func RegisterReportingPluginServer(s grpc.ServiceRegistrar, srv ReportingPluginServer)
- type AttributedObservation
- func (*AttributedObservation) Descriptor() ([]byte, []int)deprecated
- func (x *AttributedObservation) GetObservation() []byte
- func (x *AttributedObservation) GetObserver() uint32
- func (*AttributedObservation) ProtoMessage()
- func (x *AttributedObservation) ProtoReflect() protoreflect.Message
- func (x *AttributedObservation) Reset()
- func (x *AttributedObservation) String() string
- type ContractTransmitterClient
- type ContractTransmitterServer
- type FromAccountReply
- type NewReportingPluginReply
- func (*NewReportingPluginReply) Descriptor() ([]byte, []int)deprecated
- func (x *NewReportingPluginReply) GetReportingPluginID() uint32
- func (x *NewReportingPluginReply) GetReportingPluginInfo() *ReportingPluginInfo
- func (*NewReportingPluginReply) ProtoMessage()
- func (x *NewReportingPluginReply) ProtoReflect() protoreflect.Message
- func (x *NewReportingPluginReply) Reset()
- func (x *NewReportingPluginReply) String() string
- type NewReportingPluginRequest
- func (*NewReportingPluginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewReportingPluginRequest) GetReportingPluginConfig() *ReportingPluginConfig
- func (*NewReportingPluginRequest) ProtoMessage()
- func (x *NewReportingPluginRequest) ProtoReflect() protoreflect.Message
- func (x *NewReportingPluginRequest) Reset()
- func (x *NewReportingPluginRequest) String() string
- type ObservationQuorumReply
- func (*ObservationQuorumReply) Descriptor() ([]byte, []int)deprecated
- func (x *ObservationQuorumReply) GetQuorumReached() bool
- func (*ObservationQuorumReply) ProtoMessage()
- func (x *ObservationQuorumReply) ProtoReflect() protoreflect.Message
- func (x *ObservationQuorumReply) Reset()
- func (x *ObservationQuorumReply) String() string
- type ObservationQuorumRequest
- func (*ObservationQuorumRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ObservationQuorumRequest) GetAo() []*AttributedObservation
- func (x *ObservationQuorumRequest) GetOutcomeContext() *OutcomeContext
- func (x *ObservationQuorumRequest) GetQuery() []byte
- func (*ObservationQuorumRequest) ProtoMessage()
- func (x *ObservationQuorumRequest) ProtoReflect() protoreflect.Message
- func (x *ObservationQuorumRequest) Reset()
- func (x *ObservationQuorumRequest) String() string
- type ObservationReply
- type ObservationRequest
- func (*ObservationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ObservationRequest) GetOutcomeContext() *OutcomeContext
- func (x *ObservationRequest) GetQuery() []byte
- func (*ObservationRequest) ProtoMessage()
- func (x *ObservationRequest) ProtoReflect() protoreflect.Message
- func (x *ObservationRequest) Reset()
- func (x *ObservationRequest) String() string
- type OutcomeContext
- func (*OutcomeContext) Descriptor() ([]byte, []int)deprecated
- func (x *OutcomeContext) GetEpoch() uint64
- func (x *OutcomeContext) GetPreviousOutcome() []byte
- func (x *OutcomeContext) GetRound() uint64
- func (x *OutcomeContext) GetSeqNr() uint64
- func (*OutcomeContext) ProtoMessage()
- func (x *OutcomeContext) ProtoReflect() protoreflect.Message
- func (x *OutcomeContext) Reset()
- func (x *OutcomeContext) String() string
- type OutcomeReply
- type OutcomeRequest
- func (*OutcomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OutcomeRequest) GetAo() []*AttributedObservation
- func (x *OutcomeRequest) GetOutcomeContext() *OutcomeContext
- func (x *OutcomeRequest) GetQuery() []byte
- func (*OutcomeRequest) ProtoMessage()
- func (x *OutcomeRequest) ProtoReflect() protoreflect.Message
- func (x *OutcomeRequest) Reset()
- func (x *OutcomeRequest) String() string
- type QueryReply
- type QueryRequest
- type ReportPlus
- func (*ReportPlus) Descriptor() ([]byte, []int)deprecated
- func (x *ReportPlus) GetReportWithInfo() *ReportWithInfo
- func (x *ReportPlus) GetTransmissionScheduleOverride() *TransmissionSchedule
- func (*ReportPlus) ProtoMessage()
- func (x *ReportPlus) ProtoReflect() protoreflect.Message
- func (x *ReportPlus) Reset()
- func (x *ReportPlus) String() string
- type ReportWithInfo
- func (*ReportWithInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ReportWithInfo) GetInfo() []byte
- func (x *ReportWithInfo) GetReport() []byte
- func (*ReportWithInfo) ProtoMessage()
- func (x *ReportWithInfo) ProtoReflect() protoreflect.Message
- func (x *ReportWithInfo) Reset()
- func (x *ReportWithInfo) String() string
- type ReportingPluginClient
- type ReportingPluginConfig
- func (*ReportingPluginConfig) Descriptor() ([]byte, []int)deprecated
- 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 (*ReportingPluginConfig) ProtoMessage()
- func (x *ReportingPluginConfig) ProtoReflect() protoreflect.Message
- func (x *ReportingPluginConfig) Reset()
- func (x *ReportingPluginConfig) String() string
- type ReportingPluginFactoryClient
- type ReportingPluginFactoryServer
- type ReportingPluginInfo
- func (*ReportingPluginInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ReportingPluginInfo) GetName() string
- func (x *ReportingPluginInfo) GetReportingPluginLimits() *ReportingPluginLimits
- func (*ReportingPluginInfo) ProtoMessage()
- func (x *ReportingPluginInfo) ProtoReflect() protoreflect.Message
- func (x *ReportingPluginInfo) Reset()
- func (x *ReportingPluginInfo) String() string
- type ReportingPluginLimits
- func (*ReportingPluginLimits) Descriptor() ([]byte, []int)deprecated
- 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 (*ReportingPluginLimits) ProtoMessage()
- func (x *ReportingPluginLimits) ProtoReflect() protoreflect.Message
- func (x *ReportingPluginLimits) Reset()
- func (x *ReportingPluginLimits) String() string
- type ReportingPluginServer
- type ReportsReply
- type ReportsRequest
- func (*ReportsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReportsRequest) GetOutcome() []byte
- func (x *ReportsRequest) GetSeqNr() uint64
- func (*ReportsRequest) ProtoMessage()
- func (x *ReportsRequest) ProtoReflect() protoreflect.Message
- func (x *ReportsRequest) Reset()
- func (x *ReportsRequest) String() string
- type ShouldAcceptAttestedReportReply
- func (*ShouldAcceptAttestedReportReply) Descriptor() ([]byte, []int)deprecated
- func (x *ShouldAcceptAttestedReportReply) GetShouldAccept() bool
- func (*ShouldAcceptAttestedReportReply) ProtoMessage()
- func (x *ShouldAcceptAttestedReportReply) ProtoReflect() protoreflect.Message
- func (x *ShouldAcceptAttestedReportReply) Reset()
- func (x *ShouldAcceptAttestedReportReply) String() string
- type ShouldAcceptAttestedReportRequest
- func (*ShouldAcceptAttestedReportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ShouldAcceptAttestedReportRequest) GetRi() *ReportWithInfo
- func (x *ShouldAcceptAttestedReportRequest) GetSegNr() uint64
- func (*ShouldAcceptAttestedReportRequest) ProtoMessage()
- func (x *ShouldAcceptAttestedReportRequest) ProtoReflect() protoreflect.Message
- func (x *ShouldAcceptAttestedReportRequest) Reset()
- func (x *ShouldAcceptAttestedReportRequest) String() string
- type ShouldTransmitAcceptedReportReply
- func (*ShouldTransmitAcceptedReportReply) Descriptor() ([]byte, []int)deprecated
- func (x *ShouldTransmitAcceptedReportReply) GetShouldTransmit() bool
- func (*ShouldTransmitAcceptedReportReply) ProtoMessage()
- func (x *ShouldTransmitAcceptedReportReply) ProtoReflect() protoreflect.Message
- func (x *ShouldTransmitAcceptedReportReply) Reset()
- func (x *ShouldTransmitAcceptedReportReply) String() string
- type ShouldTransmitAcceptedReportRequest
- func (*ShouldTransmitAcceptedReportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ShouldTransmitAcceptedReportRequest) GetRi() *ReportWithInfo
- func (x *ShouldTransmitAcceptedReportRequest) GetSegNr() uint64
- func (*ShouldTransmitAcceptedReportRequest) ProtoMessage()
- func (x *ShouldTransmitAcceptedReportRequest) ProtoReflect() protoreflect.Message
- func (x *ShouldTransmitAcceptedReportRequest) Reset()
- func (x *ShouldTransmitAcceptedReportRequest) String() string
- type Signature
- type TransmissionSchedule
- func (*TransmissionSchedule) Descriptor() ([]byte, []int)deprecated
- func (x *TransmissionSchedule) GetTransmissionDelays() []int64
- func (x *TransmissionSchedule) GetTransmitters() []uint32
- func (*TransmissionSchedule) ProtoMessage()
- func (x *TransmissionSchedule) ProtoReflect() protoreflect.Message
- func (x *TransmissionSchedule) Reset()
- func (x *TransmissionSchedule) String() string
- type TransmitRequest
- func (*TransmitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TransmitRequest) GetConfigDigest() []byte
- func (x *TransmitRequest) GetReportWithInfo() *ReportWithInfo
- func (x *TransmitRequest) GetSeqNr() uint64
- func (x *TransmitRequest) GetSignatures() []*Signature
- func (*TransmitRequest) ProtoMessage()
- func (x *TransmitRequest) ProtoReflect() protoreflect.Message
- func (x *TransmitRequest) Reset()
- func (x *TransmitRequest) String() string
- type UnimplementedContractTransmitterServer
- type UnimplementedReportingPluginFactoryServer
- type UnimplementedReportingPluginServer
- 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
- type UnsafeReportingPluginFactoryServer
- type UnsafeReportingPluginServer
- type ValidateObservationRequest
- func (*ValidateObservationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateObservationRequest) GetAo() *AttributedObservation
- func (x *ValidateObservationRequest) GetOutcomeContext() *OutcomeContext
- func (x *ValidateObservationRequest) GetQuery() []byte
- func (*ValidateObservationRequest) ProtoMessage()
- func (x *ValidateObservationRequest) ProtoReflect() protoreflect.Message
- func (x *ValidateObservationRequest) Reset()
- func (x *ValidateObservationRequest) String() string
Constants ¶
const ( ContractTransmitter_Transmit_FullMethodName = "/loop.internal.pb.ocr3.ContractTransmitter/Transmit" ContractTransmitter_FromAccount_FullMethodName = "/loop.internal.pb.ocr3.ContractTransmitter/FromAccount" )
const ( ReportingPlugin_Query_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/Query" ReportingPlugin_Observation_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/Observation" ReportingPlugin_ValidateObservation_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/ValidateObservation" ReportingPlugin_ObservationQuorum_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/ObservationQuorum" ReportingPlugin_Outcome_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/Outcome" ReportingPlugin_Reports_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/Reports" ReportingPlugin_ShouldAcceptAttestedReport_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/ShouldAcceptAttestedReport" ReportingPlugin_ShouldTransmitAcceptedReport_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/ShouldTransmitAcceptedReport" ReportingPlugin_Close_FullMethodName = "/loop.internal.pb.ocr3.ReportingPlugin/Close" )
const (
ReportingPluginFactory_NewReportingPlugin_FullMethodName = "/loop.internal.pb.ocr3.ReportingPluginFactory/NewReportingPlugin"
)
Variables ¶
var ContractTransmitter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.internal.pb.ocr3.ContractTransmitter", HandlerType: (*ContractTransmitterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Transmit", Handler: _ContractTransmitter_Transmit_Handler, }, { MethodName: "FromAccount", Handler: _ContractTransmitter_FromAccount_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "contract_transmitter.proto", }
ContractTransmitter_ServiceDesc is the grpc.ServiceDesc for ContractTransmitter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_contract_transmitter_proto protoreflect.FileDescriptor
var File_ocr3_reporting_proto protoreflect.FileDescriptor
var ReportingPluginFactory_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.internal.pb.ocr3.ReportingPluginFactory", HandlerType: (*ReportingPluginFactoryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "NewReportingPlugin", Handler: _ReportingPluginFactory_NewReportingPlugin_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ocr3_reporting.proto", }
ReportingPluginFactory_ServiceDesc is the grpc.ServiceDesc for ReportingPluginFactory service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReportingPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.internal.pb.ocr3.ReportingPlugin", HandlerType: (*ReportingPluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Query", Handler: _ReportingPlugin_Query_Handler, }, { MethodName: "Observation", Handler: _ReportingPlugin_Observation_Handler, }, { MethodName: "ValidateObservation", Handler: _ReportingPlugin_ValidateObservation_Handler, }, { MethodName: "ObservationQuorum", Handler: _ReportingPlugin_ObservationQuorum_Handler, }, { MethodName: "Outcome", Handler: _ReportingPlugin_Outcome_Handler, }, { MethodName: "Reports", Handler: _ReportingPlugin_Reports_Handler, }, { MethodName: "ShouldAcceptAttestedReport", Handler: _ReportingPlugin_ShouldAcceptAttestedReport_Handler, }, { MethodName: "ShouldTransmitAcceptedReport", Handler: _ReportingPlugin_ShouldTransmitAcceptedReport_Handler, }, { MethodName: "Close", Handler: _ReportingPlugin_Close_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ocr3_reporting.proto", }
ReportingPlugin_ServiceDesc is the grpc.ServiceDesc for ReportingPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterContractTransmitterServer ¶
func RegisterContractTransmitterServer(s grpc.ServiceRegistrar, srv ContractTransmitterServer)
func RegisterReportingPluginFactoryServer ¶
func RegisterReportingPluginFactoryServer(s grpc.ServiceRegistrar, srv ReportingPluginFactoryServer)
func RegisterReportingPluginServer ¶
func RegisterReportingPluginServer(s grpc.ServiceRegistrar, srv ReportingPluginServer)
Types ¶
type AttributedObservation ¶
type AttributedObservation struct { Observation []byte `protobuf:"bytes,1,opt,name=observation,proto3" json:"observation,omitempty"` Observer uint32 `protobuf:"varint,2,opt,name=observer,proto3" json:"observer,omitempty"` // contains filtered or unexported fields }
func (*AttributedObservation) Descriptor
deprecated
func (*AttributedObservation) Descriptor() ([]byte, []int)
Deprecated: Use AttributedObservation.ProtoReflect.Descriptor instead.
func (*AttributedObservation) GetObservation ¶
func (x *AttributedObservation) GetObservation() []byte
func (*AttributedObservation) GetObserver ¶
func (x *AttributedObservation) GetObserver() uint32
func (*AttributedObservation) ProtoMessage ¶
func (*AttributedObservation) ProtoMessage()
func (*AttributedObservation) ProtoReflect ¶
func (x *AttributedObservation) ProtoReflect() protoreflect.Message
func (*AttributedObservation) Reset ¶
func (x *AttributedObservation) Reset()
func (*AttributedObservation) String ¶
func (x *AttributedObservation) String() string
type ContractTransmitterClient ¶
type ContractTransmitterClient interface { Transmit(ctx context.Context, in *TransmitRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) FromAccount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FromAccountReply, error) }
ContractTransmitterClient is the client API for ContractTransmitter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewContractTransmitterClient ¶
func NewContractTransmitterClient(cc grpc.ClientConnInterface) ContractTransmitterClient
type ContractTransmitterServer ¶
type ContractTransmitterServer interface { Transmit(context.Context, *TransmitRequest) (*emptypb.Empty, error) FromAccount(context.Context, *emptypb.Empty) (*FromAccountReply, error) // contains filtered or unexported methods }
ContractTransmitterServer is the server API for ContractTransmitter service. All implementations must embed UnimplementedContractTransmitterServer for forward compatibility
type FromAccountReply ¶
type FromAccountReply struct { Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"` // contains filtered or unexported fields }
func (*FromAccountReply) Descriptor
deprecated
func (*FromAccountReply) Descriptor() ([]byte, []int)
Deprecated: Use FromAccountReply.ProtoReflect.Descriptor instead.
func (*FromAccountReply) GetAccount ¶
func (x *FromAccountReply) GetAccount() string
func (*FromAccountReply) ProtoMessage ¶
func (*FromAccountReply) ProtoMessage()
func (*FromAccountReply) ProtoReflect ¶
func (x *FromAccountReply) ProtoReflect() protoreflect.Message
func (*FromAccountReply) Reset ¶
func (x *FromAccountReply) Reset()
func (*FromAccountReply) String ¶
func (x *FromAccountReply) String() string
type NewReportingPluginReply ¶
type NewReportingPluginReply struct { ReportingPluginID uint32 `protobuf:"varint,1,opt,name=reportingPluginID,proto3" json:"reportingPluginID,omitempty"` ReportingPluginInfo *ReportingPluginInfo `protobuf:"bytes,2,opt,name=reportingPluginInfo,proto3" json:"reportingPluginInfo,omitempty"` // contains filtered or unexported fields }
func (*NewReportingPluginReply) Descriptor
deprecated
func (*NewReportingPluginReply) Descriptor() ([]byte, []int)
Deprecated: Use NewReportingPluginReply.ProtoReflect.Descriptor instead.
func (*NewReportingPluginReply) GetReportingPluginID ¶
func (x *NewReportingPluginReply) GetReportingPluginID() uint32
func (*NewReportingPluginReply) GetReportingPluginInfo ¶
func (x *NewReportingPluginReply) GetReportingPluginInfo() *ReportingPluginInfo
func (*NewReportingPluginReply) ProtoMessage ¶
func (*NewReportingPluginReply) ProtoMessage()
func (*NewReportingPluginReply) ProtoReflect ¶
func (x *NewReportingPluginReply) ProtoReflect() protoreflect.Message
func (*NewReportingPluginReply) Reset ¶
func (x *NewReportingPluginReply) Reset()
func (*NewReportingPluginReply) String ¶
func (x *NewReportingPluginReply) String() string
type NewReportingPluginRequest ¶
type NewReportingPluginRequest struct { ReportingPluginConfig *ReportingPluginConfig `protobuf:"bytes,1,opt,name=reportingPluginConfig,proto3" json:"reportingPluginConfig,omitempty"` // contains filtered or unexported fields }
func (*NewReportingPluginRequest) Descriptor
deprecated
func (*NewReportingPluginRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewReportingPluginRequest.ProtoReflect.Descriptor instead.
func (*NewReportingPluginRequest) GetReportingPluginConfig ¶
func (x *NewReportingPluginRequest) GetReportingPluginConfig() *ReportingPluginConfig
func (*NewReportingPluginRequest) ProtoMessage ¶
func (*NewReportingPluginRequest) ProtoMessage()
func (*NewReportingPluginRequest) ProtoReflect ¶
func (x *NewReportingPluginRequest) ProtoReflect() protoreflect.Message
func (*NewReportingPluginRequest) Reset ¶
func (x *NewReportingPluginRequest) Reset()
func (*NewReportingPluginRequest) String ¶
func (x *NewReportingPluginRequest) String() string
type ObservationQuorumReply ¶
type ObservationQuorumReply struct { QuorumReached bool `protobuf:"varint,1,opt,name=quorumReached,proto3" json:"quorumReached,omitempty"` // contains filtered or unexported fields }
func (*ObservationQuorumReply) Descriptor
deprecated
func (*ObservationQuorumReply) Descriptor() ([]byte, []int)
Deprecated: Use ObservationQuorumReply.ProtoReflect.Descriptor instead.
func (*ObservationQuorumReply) GetQuorumReached ¶
func (x *ObservationQuorumReply) GetQuorumReached() bool
func (*ObservationQuorumReply) ProtoMessage ¶
func (*ObservationQuorumReply) ProtoMessage()
func (*ObservationQuorumReply) ProtoReflect ¶
func (x *ObservationQuorumReply) ProtoReflect() protoreflect.Message
func (*ObservationQuorumReply) Reset ¶
func (x *ObservationQuorumReply) Reset()
func (*ObservationQuorumReply) String ¶
func (x *ObservationQuorumReply) String() string
type ObservationQuorumRequest ¶
type ObservationQuorumRequest struct { OutcomeContext *OutcomeContext `protobuf:"bytes,1,opt,name=outcomeContext,proto3" json:"outcomeContext,omitempty"` Query []byte `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` Ao []*AttributedObservation `protobuf:"bytes,3,rep,name=ao,proto3" json:"ao,omitempty"` // contains filtered or unexported fields }
func (*ObservationQuorumRequest) Descriptor
deprecated
func (*ObservationQuorumRequest) Descriptor() ([]byte, []int)
Deprecated: Use ObservationQuorumRequest.ProtoReflect.Descriptor instead.
func (*ObservationQuorumRequest) GetAo ¶
func (x *ObservationQuorumRequest) GetAo() []*AttributedObservation
func (*ObservationQuorumRequest) GetOutcomeContext ¶
func (x *ObservationQuorumRequest) GetOutcomeContext() *OutcomeContext
func (*ObservationQuorumRequest) GetQuery ¶
func (x *ObservationQuorumRequest) GetQuery() []byte
func (*ObservationQuorumRequest) ProtoMessage ¶
func (*ObservationQuorumRequest) ProtoMessage()
func (*ObservationQuorumRequest) ProtoReflect ¶
func (x *ObservationQuorumRequest) ProtoReflect() protoreflect.Message
func (*ObservationQuorumRequest) Reset ¶
func (x *ObservationQuorumRequest) Reset()
func (*ObservationQuorumRequest) String ¶
func (x *ObservationQuorumRequest) String() string
type ObservationReply ¶
type ObservationReply struct { Observation []byte `protobuf:"bytes,1,opt,name=observation,proto3" json:"observation,omitempty"` // contains filtered or unexported fields }
func (*ObservationReply) Descriptor
deprecated
func (*ObservationReply) Descriptor() ([]byte, []int)
Deprecated: Use ObservationReply.ProtoReflect.Descriptor instead.
func (*ObservationReply) GetObservation ¶
func (x *ObservationReply) GetObservation() []byte
func (*ObservationReply) ProtoMessage ¶
func (*ObservationReply) ProtoMessage()
func (*ObservationReply) ProtoReflect ¶
func (x *ObservationReply) ProtoReflect() protoreflect.Message
func (*ObservationReply) Reset ¶
func (x *ObservationReply) Reset()
func (*ObservationReply) String ¶
func (x *ObservationReply) String() string
type ObservationRequest ¶
type ObservationRequest struct { OutcomeContext *OutcomeContext `protobuf:"bytes,1,opt,name=outcomeContext,proto3" json:"outcomeContext,omitempty"` Query []byte `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*ObservationRequest) Descriptor
deprecated
func (*ObservationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ObservationRequest.ProtoReflect.Descriptor instead.
func (*ObservationRequest) GetOutcomeContext ¶
func (x *ObservationRequest) GetOutcomeContext() *OutcomeContext
func (*ObservationRequest) GetQuery ¶
func (x *ObservationRequest) GetQuery() []byte
func (*ObservationRequest) ProtoMessage ¶
func (*ObservationRequest) ProtoMessage()
func (*ObservationRequest) ProtoReflect ¶
func (x *ObservationRequest) ProtoReflect() protoreflect.Message
func (*ObservationRequest) Reset ¶
func (x *ObservationRequest) Reset()
func (*ObservationRequest) String ¶
func (x *ObservationRequest) String() string
type OutcomeContext ¶
type OutcomeContext struct { SeqNr uint64 `protobuf:"varint,1,opt,name=seqNr,proto3" json:"seqNr,omitempty"` PreviousOutcome []byte `protobuf:"bytes,2,opt,name=previousOutcome,proto3" json:"previousOutcome,omitempty"` Epoch uint64 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint64 `protobuf:"varint,4,opt,name=round,proto3" json:"round,omitempty"` // contains filtered or unexported fields }
func (*OutcomeContext) Descriptor
deprecated
func (*OutcomeContext) Descriptor() ([]byte, []int)
Deprecated: Use OutcomeContext.ProtoReflect.Descriptor instead.
func (*OutcomeContext) GetEpoch ¶
func (x *OutcomeContext) GetEpoch() uint64
func (*OutcomeContext) GetPreviousOutcome ¶
func (x *OutcomeContext) GetPreviousOutcome() []byte
func (*OutcomeContext) GetRound ¶
func (x *OutcomeContext) GetRound() uint64
func (*OutcomeContext) GetSeqNr ¶
func (x *OutcomeContext) GetSeqNr() uint64
func (*OutcomeContext) ProtoMessage ¶
func (*OutcomeContext) ProtoMessage()
func (*OutcomeContext) ProtoReflect ¶
func (x *OutcomeContext) ProtoReflect() protoreflect.Message
func (*OutcomeContext) Reset ¶
func (x *OutcomeContext) Reset()
func (*OutcomeContext) String ¶
func (x *OutcomeContext) String() string
type OutcomeReply ¶
type OutcomeReply struct { Outcome []byte `protobuf:"bytes,1,opt,name=outcome,proto3" json:"outcome,omitempty"` // contains filtered or unexported fields }
func (*OutcomeReply) Descriptor
deprecated
func (*OutcomeReply) Descriptor() ([]byte, []int)
Deprecated: Use OutcomeReply.ProtoReflect.Descriptor instead.
func (*OutcomeReply) GetOutcome ¶
func (x *OutcomeReply) GetOutcome() []byte
func (*OutcomeReply) ProtoMessage ¶
func (*OutcomeReply) ProtoMessage()
func (*OutcomeReply) ProtoReflect ¶
func (x *OutcomeReply) ProtoReflect() protoreflect.Message
func (*OutcomeReply) Reset ¶
func (x *OutcomeReply) Reset()
func (*OutcomeReply) String ¶
func (x *OutcomeReply) String() string
type OutcomeRequest ¶
type OutcomeRequest struct { OutcomeContext *OutcomeContext `protobuf:"bytes,1,opt,name=outcomeContext,proto3" json:"outcomeContext,omitempty"` Query []byte `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` Ao []*AttributedObservation `protobuf:"bytes,3,rep,name=ao,proto3" json:"ao,omitempty"` // contains filtered or unexported fields }
func (*OutcomeRequest) Descriptor
deprecated
func (*OutcomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use OutcomeRequest.ProtoReflect.Descriptor instead.
func (*OutcomeRequest) GetAo ¶
func (x *OutcomeRequest) GetAo() []*AttributedObservation
func (*OutcomeRequest) GetOutcomeContext ¶
func (x *OutcomeRequest) GetOutcomeContext() *OutcomeContext
func (*OutcomeRequest) GetQuery ¶
func (x *OutcomeRequest) GetQuery() []byte
func (*OutcomeRequest) ProtoMessage ¶
func (*OutcomeRequest) ProtoMessage()
func (*OutcomeRequest) ProtoReflect ¶
func (x *OutcomeRequest) ProtoReflect() protoreflect.Message
func (*OutcomeRequest) Reset ¶
func (x *OutcomeRequest) Reset()
func (*OutcomeRequest) String ¶
func (x *OutcomeRequest) String() string
type QueryReply ¶
type QueryReply struct { Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*QueryReply) Descriptor
deprecated
func (*QueryReply) Descriptor() ([]byte, []int)
Deprecated: Use QueryReply.ProtoReflect.Descriptor instead.
func (*QueryReply) GetQuery ¶
func (x *QueryReply) GetQuery() []byte
func (*QueryReply) ProtoMessage ¶
func (*QueryReply) ProtoMessage()
func (*QueryReply) ProtoReflect ¶
func (x *QueryReply) ProtoReflect() protoreflect.Message
func (*QueryReply) Reset ¶
func (x *QueryReply) Reset()
func (*QueryReply) String ¶
func (x *QueryReply) String() string
type QueryRequest ¶
type QueryRequest struct { OutcomeContext *OutcomeContext `protobuf:"bytes,1,opt,name=outcomeContext,proto3" json:"outcomeContext,omitempty"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetOutcomeContext ¶
func (x *QueryRequest) GetOutcomeContext() *OutcomeContext
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type ReportPlus ¶
type ReportPlus struct { ReportWithInfo *ReportWithInfo `protobuf:"bytes,1,opt,name=reportWithInfo,proto3" json:"reportWithInfo,omitempty"` TransmissionScheduleOverride *TransmissionSchedule `protobuf:"bytes,2,opt,name=transmissionScheduleOverride,proto3" json:"transmissionScheduleOverride,omitempty"` // contains filtered or unexported fields }
func (*ReportPlus) Descriptor
deprecated
func (*ReportPlus) Descriptor() ([]byte, []int)
Deprecated: Use ReportPlus.ProtoReflect.Descriptor instead.
func (*ReportPlus) GetReportWithInfo ¶
func (x *ReportPlus) GetReportWithInfo() *ReportWithInfo
func (*ReportPlus) GetTransmissionScheduleOverride ¶
func (x *ReportPlus) GetTransmissionScheduleOverride() *TransmissionSchedule
func (*ReportPlus) ProtoMessage ¶
func (*ReportPlus) ProtoMessage()
func (*ReportPlus) ProtoReflect ¶
func (x *ReportPlus) ProtoReflect() protoreflect.Message
func (*ReportPlus) Reset ¶
func (x *ReportPlus) Reset()
func (*ReportPlus) String ¶
func (x *ReportPlus) String() string
type ReportWithInfo ¶
type ReportWithInfo struct { Report []byte `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"` Info []byte `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*ReportWithInfo) Descriptor
deprecated
func (*ReportWithInfo) Descriptor() ([]byte, []int)
Deprecated: Use ReportWithInfo.ProtoReflect.Descriptor instead.
func (*ReportWithInfo) GetInfo ¶
func (x *ReportWithInfo) GetInfo() []byte
func (*ReportWithInfo) GetReport ¶
func (x *ReportWithInfo) GetReport() []byte
func (*ReportWithInfo) ProtoMessage ¶
func (*ReportWithInfo) ProtoMessage()
func (*ReportWithInfo) ProtoReflect ¶
func (x *ReportWithInfo) ProtoReflect() protoreflect.Message
func (*ReportWithInfo) Reset ¶
func (x *ReportWithInfo) Reset()
func (*ReportWithInfo) String ¶
func (x *ReportWithInfo) String() string
type ReportingPluginClient ¶
type ReportingPluginClient interface { Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryReply, error) Observation(ctx context.Context, in *ObservationRequest, opts ...grpc.CallOption) (*ObservationReply, error) ValidateObservation(ctx context.Context, in *ValidateObservationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) ObservationQuorum(ctx context.Context, in *ObservationQuorumRequest, opts ...grpc.CallOption) (*ObservationQuorumReply, error) Outcome(ctx context.Context, in *OutcomeRequest, opts ...grpc.CallOption) (*OutcomeReply, error) Reports(ctx context.Context, in *ReportsRequest, opts ...grpc.CallOption) (*ReportsReply, error) ShouldAcceptAttestedReport(ctx context.Context, in *ShouldAcceptAttestedReportRequest, opts ...grpc.CallOption) (*ShouldAcceptAttestedReportReply, error) ShouldTransmitAcceptedReport(ctx context.Context, in *ShouldTransmitAcceptedReportRequest, opts ...grpc.CallOption) (*ShouldTransmitAcceptedReportReply, error) Close(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) }
ReportingPluginClient is the client API for ReportingPlugin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewReportingPluginClient ¶
func NewReportingPluginClient(cc grpc.ClientConnInterface) ReportingPluginClient
type ReportingPluginConfig ¶
type ReportingPluginConfig struct { ConfigDigest []byte `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` OracleID uint32 `protobuf:"varint,2,opt,name=oracleID,proto3" json:"oracleID,omitempty"` N uint32 `protobuf:"varint,3,opt,name=n,proto3" json:"n,omitempty"` F uint32 `protobuf:"varint,4,opt,name=f,proto3" json:"f,omitempty"` OnchainConfig []byte `protobuf:"bytes,5,opt,name=onchainConfig,proto3" json:"onchainConfig,omitempty"` OffchainConfig []byte `protobuf:"bytes,6,opt,name=offchainConfig,proto3" json:"offchainConfig,omitempty"` EstimatedRoundInterval int64 `protobuf:"varint,7,opt,name=estimatedRoundInterval,proto3" json:"estimatedRoundInterval,omitempty"` MaxDurationQuery int64 `protobuf:"varint,8,opt,name=maxDurationQuery,proto3" json:"maxDurationQuery,omitempty"` MaxDurationObservation int64 `protobuf:"varint,9,opt,name=maxDurationObservation,proto3" json:"maxDurationObservation,omitempty"` MaxDurationShouldAcceptAttestedReport int64 `` /* 129-byte string literal not displayed */ MaxDurationShouldTransmitAcceptedReport int64 `` /* 133-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ReportingPluginConfig) Descriptor
deprecated
func (*ReportingPluginConfig) Descriptor() ([]byte, []int)
Deprecated: Use ReportingPluginConfig.ProtoReflect.Descriptor instead.
func (*ReportingPluginConfig) GetConfigDigest ¶
func (x *ReportingPluginConfig) GetConfigDigest() []byte
func (*ReportingPluginConfig) GetEstimatedRoundInterval ¶
func (x *ReportingPluginConfig) GetEstimatedRoundInterval() int64
func (*ReportingPluginConfig) GetF ¶
func (x *ReportingPluginConfig) GetF() uint32
func (*ReportingPluginConfig) GetMaxDurationObservation ¶
func (x *ReportingPluginConfig) GetMaxDurationObservation() int64
func (*ReportingPluginConfig) GetMaxDurationQuery ¶
func (x *ReportingPluginConfig) GetMaxDurationQuery() int64
func (*ReportingPluginConfig) GetMaxDurationShouldAcceptAttestedReport ¶
func (x *ReportingPluginConfig) GetMaxDurationShouldAcceptAttestedReport() int64
func (*ReportingPluginConfig) GetMaxDurationShouldTransmitAcceptedReport ¶
func (x *ReportingPluginConfig) GetMaxDurationShouldTransmitAcceptedReport() int64
func (*ReportingPluginConfig) GetN ¶
func (x *ReportingPluginConfig) GetN() uint32
func (*ReportingPluginConfig) GetOffchainConfig ¶
func (x *ReportingPluginConfig) GetOffchainConfig() []byte
func (*ReportingPluginConfig) GetOnchainConfig ¶
func (x *ReportingPluginConfig) GetOnchainConfig() []byte
func (*ReportingPluginConfig) GetOracleID ¶
func (x *ReportingPluginConfig) GetOracleID() uint32
func (*ReportingPluginConfig) ProtoMessage ¶
func (*ReportingPluginConfig) ProtoMessage()
func (*ReportingPluginConfig) ProtoReflect ¶
func (x *ReportingPluginConfig) ProtoReflect() protoreflect.Message
func (*ReportingPluginConfig) Reset ¶
func (x *ReportingPluginConfig) Reset()
func (*ReportingPluginConfig) String ¶
func (x *ReportingPluginConfig) String() string
type ReportingPluginFactoryClient ¶
type ReportingPluginFactoryClient interface {
NewReportingPlugin(ctx context.Context, in *NewReportingPluginRequest, opts ...grpc.CallOption) (*NewReportingPluginReply, error)
}
ReportingPluginFactoryClient is the client API for ReportingPluginFactory service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewReportingPluginFactoryClient ¶
func NewReportingPluginFactoryClient(cc grpc.ClientConnInterface) ReportingPluginFactoryClient
type ReportingPluginFactoryServer ¶
type ReportingPluginFactoryServer interface { NewReportingPlugin(context.Context, *NewReportingPluginRequest) (*NewReportingPluginReply, error) // contains filtered or unexported methods }
ReportingPluginFactoryServer is the server API for ReportingPluginFactory service. All implementations must embed UnimplementedReportingPluginFactoryServer for forward compatibility
type ReportingPluginInfo ¶
type ReportingPluginInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ReportingPluginLimits *ReportingPluginLimits `protobuf:"bytes,2,opt,name=reportingPluginLimits,proto3" json:"reportingPluginLimits,omitempty"` // contains filtered or unexported fields }
func (*ReportingPluginInfo) Descriptor
deprecated
func (*ReportingPluginInfo) Descriptor() ([]byte, []int)
Deprecated: Use ReportingPluginInfo.ProtoReflect.Descriptor instead.
func (*ReportingPluginInfo) GetName ¶
func (x *ReportingPluginInfo) GetName() string
func (*ReportingPluginInfo) GetReportingPluginLimits ¶
func (x *ReportingPluginInfo) GetReportingPluginLimits() *ReportingPluginLimits
func (*ReportingPluginInfo) ProtoMessage ¶
func (*ReportingPluginInfo) ProtoMessage()
func (*ReportingPluginInfo) ProtoReflect ¶
func (x *ReportingPluginInfo) ProtoReflect() protoreflect.Message
func (*ReportingPluginInfo) Reset ¶
func (x *ReportingPluginInfo) Reset()
func (*ReportingPluginInfo) String ¶
func (x *ReportingPluginInfo) String() string
type ReportingPluginLimits ¶
type ReportingPluginLimits struct { MaxQueryLength uint64 `protobuf:"varint,1,opt,name=maxQueryLength,proto3" json:"maxQueryLength,omitempty"` MaxObservationLength uint64 `protobuf:"varint,2,opt,name=maxObservationLength,proto3" json:"maxObservationLength,omitempty"` MaxOutcomeLength uint64 `protobuf:"varint,3,opt,name=MaxOutcomeLength,proto3" json:"MaxOutcomeLength,omitempty"` MaxReportLength uint64 `protobuf:"varint,4,opt,name=MaxReportLength,proto3" json:"MaxReportLength,omitempty"` MaxReportCount uint64 `protobuf:"varint,5,opt,name=MaxReportCount,proto3" json:"MaxReportCount,omitempty"` // contains filtered or unexported fields }
func (*ReportingPluginLimits) Descriptor
deprecated
func (*ReportingPluginLimits) Descriptor() ([]byte, []int)
Deprecated: Use ReportingPluginLimits.ProtoReflect.Descriptor instead.
func (*ReportingPluginLimits) GetMaxObservationLength ¶
func (x *ReportingPluginLimits) GetMaxObservationLength() uint64
func (*ReportingPluginLimits) GetMaxOutcomeLength ¶
func (x *ReportingPluginLimits) GetMaxOutcomeLength() uint64
func (*ReportingPluginLimits) GetMaxQueryLength ¶
func (x *ReportingPluginLimits) GetMaxQueryLength() uint64
func (*ReportingPluginLimits) GetMaxReportCount ¶
func (x *ReportingPluginLimits) GetMaxReportCount() uint64
func (*ReportingPluginLimits) GetMaxReportLength ¶
func (x *ReportingPluginLimits) GetMaxReportLength() uint64
func (*ReportingPluginLimits) ProtoMessage ¶
func (*ReportingPluginLimits) ProtoMessage()
func (*ReportingPluginLimits) ProtoReflect ¶
func (x *ReportingPluginLimits) ProtoReflect() protoreflect.Message
func (*ReportingPluginLimits) Reset ¶
func (x *ReportingPluginLimits) Reset()
func (*ReportingPluginLimits) String ¶
func (x *ReportingPluginLimits) String() string
type ReportingPluginServer ¶
type ReportingPluginServer interface { Query(context.Context, *QueryRequest) (*QueryReply, error) Observation(context.Context, *ObservationRequest) (*ObservationReply, error) ValidateObservation(context.Context, *ValidateObservationRequest) (*emptypb.Empty, error) ObservationQuorum(context.Context, *ObservationQuorumRequest) (*ObservationQuorumReply, error) Outcome(context.Context, *OutcomeRequest) (*OutcomeReply, error) Reports(context.Context, *ReportsRequest) (*ReportsReply, error) ShouldAcceptAttestedReport(context.Context, *ShouldAcceptAttestedReportRequest) (*ShouldAcceptAttestedReportReply, error) ShouldTransmitAcceptedReport(context.Context, *ShouldTransmitAcceptedReportRequest) (*ShouldTransmitAcceptedReportReply, error) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // contains filtered or unexported methods }
ReportingPluginServer is the server API for ReportingPlugin service. All implementations must embed UnimplementedReportingPluginServer for forward compatibility
type ReportsReply ¶
type ReportsReply struct { ReportPlus []*ReportPlus `protobuf:"bytes,1,rep,name=reportPlus,proto3" json:"reportPlus,omitempty"` // contains filtered or unexported fields }
func (*ReportsReply) Descriptor
deprecated
func (*ReportsReply) Descriptor() ([]byte, []int)
Deprecated: Use ReportsReply.ProtoReflect.Descriptor instead.
func (*ReportsReply) GetReportPlus ¶
func (x *ReportsReply) GetReportPlus() []*ReportPlus
func (*ReportsReply) ProtoMessage ¶
func (*ReportsReply) ProtoMessage()
func (*ReportsReply) ProtoReflect ¶
func (x *ReportsReply) ProtoReflect() protoreflect.Message
func (*ReportsReply) Reset ¶
func (x *ReportsReply) Reset()
func (*ReportsReply) String ¶
func (x *ReportsReply) String() string
type ReportsRequest ¶
type ReportsRequest struct { SeqNr uint64 `protobuf:"varint,1,opt,name=seqNr,proto3" json:"seqNr,omitempty"` Outcome []byte `protobuf:"bytes,2,opt,name=outcome,proto3" json:"outcome,omitempty"` // contains filtered or unexported fields }
func (*ReportsRequest) Descriptor
deprecated
func (*ReportsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportsRequest.ProtoReflect.Descriptor instead.
func (*ReportsRequest) GetOutcome ¶
func (x *ReportsRequest) GetOutcome() []byte
func (*ReportsRequest) GetSeqNr ¶
func (x *ReportsRequest) GetSeqNr() uint64
func (*ReportsRequest) ProtoMessage ¶
func (*ReportsRequest) ProtoMessage()
func (*ReportsRequest) ProtoReflect ¶
func (x *ReportsRequest) ProtoReflect() protoreflect.Message
func (*ReportsRequest) Reset ¶
func (x *ReportsRequest) Reset()
func (*ReportsRequest) String ¶
func (x *ReportsRequest) String() string
type ShouldAcceptAttestedReportReply ¶
type ShouldAcceptAttestedReportReply struct { ShouldAccept bool `protobuf:"varint,1,opt,name=shouldAccept,proto3" json:"shouldAccept,omitempty"` // contains filtered or unexported fields }
func (*ShouldAcceptAttestedReportReply) Descriptor
deprecated
func (*ShouldAcceptAttestedReportReply) Descriptor() ([]byte, []int)
Deprecated: Use ShouldAcceptAttestedReportReply.ProtoReflect.Descriptor instead.
func (*ShouldAcceptAttestedReportReply) GetShouldAccept ¶
func (x *ShouldAcceptAttestedReportReply) GetShouldAccept() bool
func (*ShouldAcceptAttestedReportReply) ProtoMessage ¶
func (*ShouldAcceptAttestedReportReply) ProtoMessage()
func (*ShouldAcceptAttestedReportReply) ProtoReflect ¶
func (x *ShouldAcceptAttestedReportReply) ProtoReflect() protoreflect.Message
func (*ShouldAcceptAttestedReportReply) Reset ¶
func (x *ShouldAcceptAttestedReportReply) Reset()
func (*ShouldAcceptAttestedReportReply) String ¶
func (x *ShouldAcceptAttestedReportReply) String() string
type ShouldAcceptAttestedReportRequest ¶
type ShouldAcceptAttestedReportRequest struct { SegNr uint64 `protobuf:"varint,1,opt,name=segNr,proto3" json:"segNr,omitempty"` Ri *ReportWithInfo `protobuf:"bytes,2,opt,name=ri,proto3" json:"ri,omitempty"` // contains filtered or unexported fields }
func (*ShouldAcceptAttestedReportRequest) Descriptor
deprecated
func (*ShouldAcceptAttestedReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ShouldAcceptAttestedReportRequest.ProtoReflect.Descriptor instead.
func (*ShouldAcceptAttestedReportRequest) GetRi ¶
func (x *ShouldAcceptAttestedReportRequest) GetRi() *ReportWithInfo
func (*ShouldAcceptAttestedReportRequest) GetSegNr ¶
func (x *ShouldAcceptAttestedReportRequest) GetSegNr() uint64
func (*ShouldAcceptAttestedReportRequest) ProtoMessage ¶
func (*ShouldAcceptAttestedReportRequest) ProtoMessage()
func (*ShouldAcceptAttestedReportRequest) ProtoReflect ¶
func (x *ShouldAcceptAttestedReportRequest) ProtoReflect() protoreflect.Message
func (*ShouldAcceptAttestedReportRequest) Reset ¶
func (x *ShouldAcceptAttestedReportRequest) Reset()
func (*ShouldAcceptAttestedReportRequest) String ¶
func (x *ShouldAcceptAttestedReportRequest) String() string
type ShouldTransmitAcceptedReportReply ¶
type ShouldTransmitAcceptedReportReply struct { ShouldTransmit bool `protobuf:"varint,1,opt,name=shouldTransmit,proto3" json:"shouldTransmit,omitempty"` // contains filtered or unexported fields }
func (*ShouldTransmitAcceptedReportReply) Descriptor
deprecated
func (*ShouldTransmitAcceptedReportReply) Descriptor() ([]byte, []int)
Deprecated: Use ShouldTransmitAcceptedReportReply.ProtoReflect.Descriptor instead.
func (*ShouldTransmitAcceptedReportReply) GetShouldTransmit ¶
func (x *ShouldTransmitAcceptedReportReply) GetShouldTransmit() bool
func (*ShouldTransmitAcceptedReportReply) ProtoMessage ¶
func (*ShouldTransmitAcceptedReportReply) ProtoMessage()
func (*ShouldTransmitAcceptedReportReply) ProtoReflect ¶
func (x *ShouldTransmitAcceptedReportReply) ProtoReflect() protoreflect.Message
func (*ShouldTransmitAcceptedReportReply) Reset ¶
func (x *ShouldTransmitAcceptedReportReply) Reset()
func (*ShouldTransmitAcceptedReportReply) String ¶
func (x *ShouldTransmitAcceptedReportReply) String() string
type ShouldTransmitAcceptedReportRequest ¶
type ShouldTransmitAcceptedReportRequest struct { SegNr uint64 `protobuf:"varint,1,opt,name=segNr,proto3" json:"segNr,omitempty"` Ri *ReportWithInfo `protobuf:"bytes,2,opt,name=ri,proto3" json:"ri,omitempty"` // contains filtered or unexported fields }
func (*ShouldTransmitAcceptedReportRequest) Descriptor
deprecated
func (*ShouldTransmitAcceptedReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ShouldTransmitAcceptedReportRequest.ProtoReflect.Descriptor instead.
func (*ShouldTransmitAcceptedReportRequest) GetRi ¶
func (x *ShouldTransmitAcceptedReportRequest) GetRi() *ReportWithInfo
func (*ShouldTransmitAcceptedReportRequest) GetSegNr ¶
func (x *ShouldTransmitAcceptedReportRequest) GetSegNr() uint64
func (*ShouldTransmitAcceptedReportRequest) ProtoMessage ¶
func (*ShouldTransmitAcceptedReportRequest) ProtoMessage()
func (*ShouldTransmitAcceptedReportRequest) ProtoReflect ¶
func (x *ShouldTransmitAcceptedReportRequest) ProtoReflect() protoreflect.Message
func (*ShouldTransmitAcceptedReportRequest) Reset ¶
func (x *ShouldTransmitAcceptedReportRequest) Reset()
func (*ShouldTransmitAcceptedReportRequest) String ¶
func (x *ShouldTransmitAcceptedReportRequest) String() string
type Signature ¶
type Signature struct { Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` Signer uint32 `protobuf:"varint,2,opt,name=signer,proto3" json:"signer,omitempty"` // NOTE: this is actually a uint8, but proto doesn't support this. // contains filtered or unexported fields }
func (*Signature) Descriptor
deprecated
func (*Signature) GetSignature ¶
func (*Signature) ProtoMessage ¶
func (*Signature) ProtoMessage()
func (*Signature) ProtoReflect ¶
func (x *Signature) ProtoReflect() protoreflect.Message
type TransmissionSchedule ¶
type TransmissionSchedule struct { Transmitters []uint32 `protobuf:"varint,1,rep,packed,name=transmitters,proto3" json:"transmitters,omitempty"` // OracleID TransmissionDelays []int64 `protobuf:"varint,2,rep,packed,name=transmissionDelays,proto3" json:"transmissionDelays,omitempty"` // contains filtered or unexported fields }
func (*TransmissionSchedule) Descriptor
deprecated
func (*TransmissionSchedule) Descriptor() ([]byte, []int)
Deprecated: Use TransmissionSchedule.ProtoReflect.Descriptor instead.
func (*TransmissionSchedule) GetTransmissionDelays ¶
func (x *TransmissionSchedule) GetTransmissionDelays() []int64
func (*TransmissionSchedule) GetTransmitters ¶
func (x *TransmissionSchedule) GetTransmitters() []uint32
func (*TransmissionSchedule) ProtoMessage ¶
func (*TransmissionSchedule) ProtoMessage()
func (*TransmissionSchedule) ProtoReflect ¶
func (x *TransmissionSchedule) ProtoReflect() protoreflect.Message
func (*TransmissionSchedule) Reset ¶
func (x *TransmissionSchedule) Reset()
func (*TransmissionSchedule) String ¶
func (x *TransmissionSchedule) String() string
type TransmitRequest ¶
type TransmitRequest struct { ConfigDigest []byte `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // NOTE: this is actually [32]byte SeqNr uint64 `protobuf:"varint,2,opt,name=seqNr,proto3" json:"seqNr,omitempty"` ReportWithInfo *ReportWithInfo `protobuf:"bytes,3,opt,name=reportWithInfo,proto3" json:"reportWithInfo,omitempty"` Signatures []*Signature `protobuf:"bytes,4,rep,name=signatures,proto3" json:"signatures,omitempty"` // contains filtered or unexported fields }
func (*TransmitRequest) Descriptor
deprecated
func (*TransmitRequest) Descriptor() ([]byte, []int)
Deprecated: Use TransmitRequest.ProtoReflect.Descriptor instead.
func (*TransmitRequest) GetConfigDigest ¶
func (x *TransmitRequest) GetConfigDigest() []byte
func (*TransmitRequest) GetReportWithInfo ¶
func (x *TransmitRequest) GetReportWithInfo() *ReportWithInfo
func (*TransmitRequest) GetSeqNr ¶
func (x *TransmitRequest) GetSeqNr() uint64
func (*TransmitRequest) GetSignatures ¶
func (x *TransmitRequest) GetSignatures() []*Signature
func (*TransmitRequest) ProtoMessage ¶
func (*TransmitRequest) ProtoMessage()
func (*TransmitRequest) ProtoReflect ¶
func (x *TransmitRequest) ProtoReflect() protoreflect.Message
func (*TransmitRequest) Reset ¶
func (x *TransmitRequest) Reset()
func (*TransmitRequest) String ¶
func (x *TransmitRequest) String() string
type UnimplementedContractTransmitterServer ¶
type UnimplementedContractTransmitterServer struct { }
UnimplementedContractTransmitterServer must be embedded to have forward compatible implementations.
func (UnimplementedContractTransmitterServer) FromAccount ¶
func (UnimplementedContractTransmitterServer) FromAccount(context.Context, *emptypb.Empty) (*FromAccountReply, error)
func (UnimplementedContractTransmitterServer) Transmit ¶
func (UnimplementedContractTransmitterServer) Transmit(context.Context, *TransmitRequest) (*emptypb.Empty, error)
type UnimplementedReportingPluginFactoryServer ¶
type UnimplementedReportingPluginFactoryServer struct { }
UnimplementedReportingPluginFactoryServer must be embedded to have forward compatible implementations.
func (UnimplementedReportingPluginFactoryServer) NewReportingPlugin ¶
func (UnimplementedReportingPluginFactoryServer) NewReportingPlugin(context.Context, *NewReportingPluginRequest) (*NewReportingPluginReply, error)
type UnimplementedReportingPluginServer ¶
type UnimplementedReportingPluginServer struct { }
UnimplementedReportingPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedReportingPluginServer) Observation ¶
func (UnimplementedReportingPluginServer) Observation(context.Context, *ObservationRequest) (*ObservationReply, error)
func (UnimplementedReportingPluginServer) ObservationQuorum ¶
func (UnimplementedReportingPluginServer) ObservationQuorum(context.Context, *ObservationQuorumRequest) (*ObservationQuorumReply, error)
func (UnimplementedReportingPluginServer) Outcome ¶
func (UnimplementedReportingPluginServer) Outcome(context.Context, *OutcomeRequest) (*OutcomeReply, error)
func (UnimplementedReportingPluginServer) Query ¶
func (UnimplementedReportingPluginServer) Query(context.Context, *QueryRequest) (*QueryReply, error)
func (UnimplementedReportingPluginServer) Reports ¶
func (UnimplementedReportingPluginServer) Reports(context.Context, *ReportsRequest) (*ReportsReply, error)
func (UnimplementedReportingPluginServer) ShouldAcceptAttestedReport ¶
func (UnimplementedReportingPluginServer) ShouldAcceptAttestedReport(context.Context, *ShouldAcceptAttestedReportRequest) (*ShouldAcceptAttestedReportReply, error)
func (UnimplementedReportingPluginServer) ShouldTransmitAcceptedReport ¶
func (UnimplementedReportingPluginServer) ShouldTransmitAcceptedReport(context.Context, *ShouldTransmitAcceptedReportRequest) (*ShouldTransmitAcceptedReportReply, error)
func (UnimplementedReportingPluginServer) ValidateObservation ¶
func (UnimplementedReportingPluginServer) ValidateObservation(context.Context, *ValidateObservationRequest) (*emptypb.Empty, error)
type UnsafeContractTransmitterServer ¶
type UnsafeContractTransmitterServer interface {
// contains filtered or unexported methods
}
UnsafeContractTransmitterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContractTransmitterServer will result in compilation errors.
type UnsafeReportingPluginFactoryServer ¶
type UnsafeReportingPluginFactoryServer interface {
// contains filtered or unexported methods
}
UnsafeReportingPluginFactoryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReportingPluginFactoryServer will result in compilation errors.
type UnsafeReportingPluginServer ¶
type UnsafeReportingPluginServer interface {
// contains filtered or unexported methods
}
UnsafeReportingPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReportingPluginServer will result in compilation errors.
type ValidateObservationRequest ¶
type ValidateObservationRequest struct { OutcomeContext *OutcomeContext `protobuf:"bytes,1,opt,name=outcomeContext,proto3" json:"outcomeContext,omitempty"` Query []byte `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` Ao *AttributedObservation `protobuf:"bytes,3,opt,name=ao,proto3" json:"ao,omitempty"` // contains filtered or unexported fields }
func (*ValidateObservationRequest) Descriptor
deprecated
func (*ValidateObservationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidateObservationRequest.ProtoReflect.Descriptor instead.
func (*ValidateObservationRequest) GetAo ¶
func (x *ValidateObservationRequest) GetAo() *AttributedObservation
func (*ValidateObservationRequest) GetOutcomeContext ¶
func (x *ValidateObservationRequest) GetOutcomeContext() *OutcomeContext
func (*ValidateObservationRequest) GetQuery ¶
func (x *ValidateObservationRequest) GetQuery() []byte
func (*ValidateObservationRequest) ProtoMessage ¶
func (*ValidateObservationRequest) ProtoMessage()
func (*ValidateObservationRequest) ProtoReflect ¶
func (x *ValidateObservationRequest) ProtoReflect() protoreflect.Message
func (*ValidateObservationRequest) Reset ¶
func (x *ValidateObservationRequest) Reset()
func (*ValidateObservationRequest) String ¶
func (x *ValidateObservationRequest) String() string