directrequestocr

package

v0.2.0 Latest Latest Go to latest Published: Jun 22, 2023 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/GoPlugin/pluginV2

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CanAggregate(N int, F int, observations []*ProcessedRequest) bool
type DROracle
- func NewDROracle(jb job.Job, pipelineRunner pipeline.Runner, jobORM job.ORM, ...) (*DROracle, error)
- func (o *DROracle) GetPluginFactory() (ocr2types.ReportingPluginFactory, error)
- func (o *DROracle) GetServices() ([]job.ServiceCtx, error)
type DirectRequestReportingPluginFactory
- func (f DirectRequestReportingPluginFactory) NewReportingPlugin(rpConfig types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)
type Observation
type ProcessedRequest
- func Aggregate(aggMethod config.AggregationMethod, observations []*ProcessedRequest) (*ProcessedRequest, error)
type Query
type ReportCodec
- func NewReportCodec() (*ReportCodec, error)
- func (c *ReportCodec) DecodeReport(raw []byte) ([]*ProcessedRequest, error)
- func (c *ReportCodec) EncodeReport(requests []*ProcessedRequest) ([]byte, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var File_core_services_ocr2_plugins_directrequestocr_types_proto protoreflect.FileDescriptor

Functions ¶

func CanAggregate ¶

func CanAggregate(N int, F int, observations []*ProcessedRequest) bool

Types ¶

type DROracle ¶

type DROracle struct {
	// contains filtered or unexported fields
}

func NewDROracle ¶

func NewDROracle(jb job.Job, pipelineRunner pipeline.Runner, jobORM job.ORM, pluginORM directrequestocr.ORM, chain evm.Chain, lggr logger.Logger, ocrLogger commontypes.Logger, mailMon *utils.MailboxMonitor) (*DROracle, error)

func (*DROracle) GetPluginFactory ¶

func (o *DROracle) GetPluginFactory() (ocr2types.ReportingPluginFactory, error)

func (*DROracle) GetServices ¶

func (o *DROracle) GetServices() ([]job.ServiceCtx, error)

type DirectRequestReportingPluginFactory ¶

type DirectRequestReportingPluginFactory struct {
	Logger    commontypes.Logger
	PluginORM directrequestocr.ORM
	JobID     uuid.UUID
}

func (DirectRequestReportingPluginFactory) NewReportingPlugin ¶

func (f DirectRequestReportingPluginFactory) NewReportingPlugin(rpConfig types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)

NewReportingPlugin complies with ReportingPluginFactory

type Observation ¶

type Observation struct {
	ProcessedRequests []*ProcessedRequest `protobuf:"bytes,1,rep,name=processedRequests,proto3" json:"processedRequests,omitempty"`
	// contains filtered or unexported fields
}

func (*Observation) Descriptor deprecated

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

Deprecated: Use Observation.ProtoReflect.Descriptor instead.

func (*Observation) GetProcessedRequests ¶

func (x *Observation) GetProcessedRequests() []*ProcessedRequest

func (*Observation) ProtoMessage ¶

func (*Observation) ProtoMessage()

func (*Observation) ProtoReflect ¶

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

func (*Observation) Reset ¶

func (x *Observation) Reset()

func (*Observation) String ¶

func (x *Observation) String() string

type ProcessedRequest ¶

type ProcessedRequest struct {
	RequestID []byte `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	Result    []byte `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Error     []byte `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func Aggregate ¶

func Aggregate(aggMethod config.AggregationMethod, observations []*ProcessedRequest) (*ProcessedRequest, error)

func (*ProcessedRequest) Descriptor deprecated

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

Deprecated: Use ProcessedRequest.ProtoReflect.Descriptor instead.

func (*ProcessedRequest) GetError ¶

func (x *ProcessedRequest) GetError() []byte

func (*ProcessedRequest) GetRequestID ¶

func (x *ProcessedRequest) GetRequestID() []byte

func (*ProcessedRequest) GetResult ¶

func (x *ProcessedRequest) GetResult() []byte

func (*ProcessedRequest) ProtoMessage ¶

func (*ProcessedRequest) ProtoMessage()

func (*ProcessedRequest) ProtoReflect ¶

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

func (*ProcessedRequest) Reset ¶

func (x *ProcessedRequest) Reset()

func (*ProcessedRequest) String ¶

func (x *ProcessedRequest) String() string

type Query ¶

type Query struct {
	RequestIDs [][]byte `protobuf:"bytes,1,rep,name=requestIDs,proto3" json:"requestIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetRequestIDs ¶

func (x *Query) GetRequestIDs() [][]byte

func (*Query) ProtoMessage ¶

func (*Query) ProtoMessage()

func (*Query) ProtoReflect ¶

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

func (*Query) Reset ¶

func (x *Query) Reset()

func (*Query) String ¶

func (x *Query) String() string

type ReportCodec ¶

type ReportCodec struct {
	// contains filtered or unexported fields
}

func NewReportCodec ¶

func NewReportCodec() (*ReportCodec, error)

func (*ReportCodec) DecodeReport ¶

func (c *ReportCodec) DecodeReport(raw []byte) ([]*ProcessedRequest, error)

func (*ReportCodec) EncodeReport ¶

func (c *ReportCodec) EncodeReport(requests []*ProcessedRequest) ([]byte, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
config
test
internal

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