types

type AggregationOutcome struct {
	EncodableOutcome *pb.Map                `protobuf:"bytes,1,opt,name=encodableOutcome,proto3" json:"encodableOutcome,omitempty"` // passed to encoders
	Metadata         []byte                 `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`                 // internal to the aggregator
	ShouldReport     bool                   `protobuf:"varint,3,opt,name=shouldReport,proto3" json:"shouldReport,omitempty"`
	LastSeenAt       uint64                 `protobuf:"varint,4,opt,name=lastSeenAt,proto3" json:"lastSeenAt,omitempty"`      // this is the equivalent of a SeqNr
	Timestamp        *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`         // current time of the node
	EncoderName      string                 `protobuf:"bytes,6,opt,name=encoderName,proto3" json:"encoderName,omitempty"`     // optional dynamic encoder override
	EncoderConfig    *pb.Map                `protobuf:"bytes,7,opt,name=encoderConfig,proto3" json:"encoderConfig,omitempty"` // optional dynamic encoder config
	// contains filtered or unexported fields
}

type Aggregator interface {
	// Called by the Outcome() phase of OCR reporting.
	// The inner array of observations corresponds to elements listed in "inputs.observations" section.
	Aggregate(lggr logger.Logger, previousOutcome *AggregationOutcome, observations map[ocrcommon.OracleID][]values.Value, f int) (*AggregationOutcome, error)
}

type AggregatorFactory func(name string, config values.Map, lggr logger.Logger) (Aggregator, error)

type Encoder interface {
	Encode(ctx context.Context, input values.Map) ([]byte, error)
}

type EncoderFactory func(name string, config *values.Map, lggr logger.Logger) (Encoder, error)

type Id struct {
	WorkflowExecutionId      string `protobuf:"bytes,1,opt,name=workflowExecutionId,proto3" json:"workflowExecutionId,omitempty"`
	WorkflowId               string `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`
	WorkflowOwner            string `protobuf:"bytes,3,opt,name=workflowOwner,proto3" json:"workflowOwner,omitempty"`
	WorkflowName             string `protobuf:"bytes,4,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	ReportId                 string `protobuf:"bytes,6,opt,name=reportId,proto3" json:"reportId,omitempty"`
	WorkflowDonId            uint32 `protobuf:"varint,7,opt,name=workflowDonId,proto3" json:"workflowDonId,omitempty"`
	WorkflowDonConfigVersion uint32 `protobuf:"varint,8,opt,name=workflowDonConfigVersion,proto3" json:"workflowDonConfigVersion,omitempty"`
	KeyId                    string `protobuf:"bytes,9,opt,name=keyId,proto3" json:"keyId,omitempty"`
	// contains filtered or unexported fields
}

type Metadata struct {
	Version          uint32 //  1 byte
	ExecutionID      string // 32 hex bytes (string len  = 64)
	Timestamp        uint32 //  4 bytes
	DONID            uint32 //  4 bytes
	DONConfigVersion uint32 //  4 bytes
	WorkflowID       string // 32 hex bytes (string len = 64)
	WorkflowName     string // 10 hex bytes (string len = 20)
	WorkflowOwner    string // 20 hex bytes (string len = 40)
	ReportID         string //  2 hex bytes (string len = 4)
}

type Observation struct {
	Id *Id `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// list of observations defined in inputs.observations
	Observations            *pb.List `protobuf:"bytes,4,opt,name=observations,proto3" json:"observations,omitempty"`
	OverriddenEncoderName   string   `protobuf:"bytes,5,opt,name=overriddenEncoderName,proto3" json:"overriddenEncoderName,omitempty"`
	OverriddenEncoderConfig *pb.Map  `protobuf:"bytes,6,opt,name=overriddenEncoderConfig,proto3" json:"overriddenEncoderConfig,omitempty"`
	// contains filtered or unexported fields
}

type Observations struct {

	// batched observations for multiple workflow execution IDs
	Observations []*Observation `protobuf:"bytes,1,rep,name=observations,proto3" json:"observations,omitempty"`
	// the workflow IDs that are registered in the node
	RegisteredWorkflowIds []string `protobuf:"bytes,2,rep,name=registeredWorkflowIds,proto3" json:"registeredWorkflowIds,omitempty"`
	// the node's current current time
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Outcome struct {
	Outcomes       map[string]*AggregationOutcome `` /* 143-byte string literal not displayed */
	CurrentReports []*Report                      `protobuf:"bytes,2,rep,name=current_reports,json=currentReports,proto3" json:"current_reports,omitempty"`
	// contains filtered or unexported fields
}

type Query struct {

	// the requests to get consensus on.
	Ids []*Id `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

type Report struct {
	Id      *Id                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Outcome *AggregationOutcome `protobuf:"bytes,2,opt,name=outcome,proto3" json:"outcome,omitempty"`
	// contains filtered or unexported fields
}

type ReportInfo struct {
	Id           *Id  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ShouldReport bool `protobuf:"varint,2,opt,name=should_report,json=shouldReport,proto3" json:"should_report,omitempty"`
	// contains filtered or unexported fields
}

type ReportingPluginConfig struct {

	// These fields are shadowing the `ReportingPluginLimits` fields.
	// See: https://github.com/smartcontractkit/libocr/blob/master/offchainreporting2plus/ocr3types/plugin.go#L296
	MaxQueryLengthBytes       uint32               `protobuf:"varint,1,opt,name=maxQueryLengthBytes,proto3" json:"maxQueryLengthBytes,omitempty"`
	MaxObservationLengthBytes uint32               `protobuf:"varint,2,opt,name=maxObservationLengthBytes,proto3" json:"maxObservationLengthBytes,omitempty"`
	MaxOutcomeLengthBytes     uint32               `protobuf:"varint,3,opt,name=maxOutcomeLengthBytes,proto3" json:"maxOutcomeLengthBytes,omitempty"`
	MaxReportLengthBytes      uint32               `protobuf:"varint,4,opt,name=maxReportLengthBytes,proto3" json:"maxReportLengthBytes,omitempty"`
	MaxReportCount            uint32               `protobuf:"varint,5,opt,name=maxReportCount,proto3" json:"maxReportCount,omitempty"`
	MaxBatchSize              uint32               `protobuf:"varint,6,opt,name=maxBatchSize,proto3" json:"maxBatchSize,omitempty"`
	OutcomePruningThreshold   uint64               `protobuf:"varint,7,opt,name=outcomePruningThreshold,proto3" json:"outcomePruningThreshold,omitempty"`
	RequestTimeout            *durationpb.Duration `protobuf:"bytes,8,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
	// contains filtered or unexported fields
}

type SignedReport struct {
	Report []byte
	// Report context is appended to the report before signing by libOCR.
	// It contains config digest + round/epoch/sequence numbers (currently 96 bytes).
	// Has to be appended to the report before validating signatures.
	Context []byte
	// Always exactly F+1 signatures.
	Signatures [][]byte
	// Report ID defined in the workflow spec (2 bytes).
	ID []byte
}