ocr3pb

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 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.

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 (*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 (*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.

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.

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

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 (*ShouldAcceptAttestedReportReply) Reset

func (*ShouldAcceptAttestedReportReply) 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 (*ShouldAcceptAttestedReportRequest) GetSegNr

func (*ShouldAcceptAttestedReportRequest) ProtoMessage

func (*ShouldAcceptAttestedReportRequest) ProtoMessage()

func (*ShouldAcceptAttestedReportRequest) ProtoReflect

func (*ShouldAcceptAttestedReportRequest) Reset

func (*ShouldAcceptAttestedReportRequest) 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 (*ShouldTransmitAcceptedReportReply) Reset

func (*ShouldTransmitAcceptedReportReply) 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 (*ShouldTransmitAcceptedReportRequest) GetSegNr

func (*ShouldTransmitAcceptedReportRequest) ProtoMessage

func (*ShouldTransmitAcceptedReportRequest) ProtoMessage()

func (*ShouldTransmitAcceptedReportRequest) ProtoReflect

func (*ShouldTransmitAcceptedReportRequest) Reset

func (*ShouldTransmitAcceptedReportRequest) 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 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) Transmit

type UnimplementedReportingPluginFactoryServer

type UnimplementedReportingPluginFactoryServer struct {
}

UnimplementedReportingPluginFactoryServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginFactoryServer) NewReportingPlugin

type UnimplementedReportingPluginServer

type UnimplementedReportingPluginServer struct {
}

UnimplementedReportingPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginServer) Close

func (UnimplementedReportingPluginServer) Observation

func (UnimplementedReportingPluginServer) ObservationQuorum

func (UnimplementedReportingPluginServer) Outcome

func (UnimplementedReportingPluginServer) Query

func (UnimplementedReportingPluginServer) Reports

func (UnimplementedReportingPluginServer) ValidateObservation

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 (*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 (*ValidateObservationRequest) Reset

func (x *ValidateObservationRequest) Reset()

func (*ValidateObservationRequest) String

func (x *ValidateObservationRequest) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL