ocr3pb

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ContractTransmitter_Transmit_FullMethodName    = "/loop.internal.pb.ocr3.ContractTransmitter/Transmit"
	ContractTransmitter_FromAccount_FullMethodName = "/loop.internal.pb.ocr3.ContractTransmitter/FromAccount"
)
View Source 
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"
)
View Source 
const (
	ReportingPluginFactory_NewReportingPlugin_FullMethodName = "/loop.internal.pb.ocr3.ReportingPluginFactory/NewReportingPlugin"
)

Variables

View Source 
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)

View Source 
var File_contract_transmitter_proto protoreflect.FileDescriptor
View Source 
var File_ocr3_reporting_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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 {
	Quorum int32 `protobuf:"varint,1,opt,name=quorum,proto3" json:"quorum,omitempty"`
	// contains filtered or unexported fields
}

func (*ObservationQuorumReply) Descriptor deprecated 

func (*ObservationQuorumReply) Descriptor() ([]byte, []int)

Deprecated: Use ObservationQuorumReply.ProtoReflect.Descriptor instead.

func (*ObservationQuorumReply) GetQuorum added in v0.2.0 

func (x *ObservationQuorumReply) GetQuorum() int32

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"`
	// contains filtered or unexported fields
}

func (*ObservationQuorumRequest) Descriptor deprecated 

func (*ObservationQuorumRequest) Descriptor() ([]byte, []int)

Deprecated: Use ObservationQuorumRequest.ProtoReflect.Descriptor instead.

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 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 {
	ReportWithInfo []*ReportWithInfo `protobuf:"bytes,1,rep,name=ReportWithInfo,proto3" json:"ReportWithInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportsReply) Descriptor deprecated 

func (*ReportsReply) Descriptor() ([]byte, []int)

Deprecated: Use ReportsReply.ProtoReflect.Descriptor instead.

func (*ReportsReply) GetReportWithInfo added in v0.2.0 

func (x *ReportsReply) GetReportWithInfo() []*ReportWithInfo

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) Descriptor() ([]byte, []int)

Deprecated: Use Signature.ProtoReflect.Descriptor instead.

func (*Signature) GetSignature 

func (x *Signature) GetSignature() []byte

func (*Signature) GetSigner 

func (x *Signature) GetSigner() uint32

func (*Signature) ProtoMessage 

func (*Signature) ProtoMessage()

func (*Signature) ProtoReflect 

func (x *Signature) ProtoReflect() protoreflect.Message

func (*Signature) Reset 

func (x *Signature) Reset()

func (*Signature) String 

func (x *Signature) 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) Close 

func (UnimplementedReportingPluginServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.