dkg

Documentation

Index

• type DKG
  • func (dkg *DKG) Close() error
  • func (dkg *DKG) Observation(ctx context.Context, repts types.ReportTimestamp, query types.Query) (types.Observation, error)
  • func (dkg *DKG) Query(ctx context.Context, repts types.ReportTimestamp) (types.Query, error)
  • func (dkg *DKG) Report(ctx context.Context, repts types.ReportTimestamp, query types.Query, ...) (bool, types.Report, error)
  • func (dkg *DKG) ShouldAcceptFinalizedReport(ctx context.Context, repts types.ReportTimestamp, report types.Report) (bool, error)
  • func (dkg *DKG) ShouldTransmitAcceptedReport(ctx context.Context, repts types.ReportTimestamp, report types.Report) (bool, error)
• type DKGContainer
  • func NewDKG(l logger.Logger) (*DKGContainer, error)
  • func (d *DKGContainer) GetPluginFactory() (ocr2types.ReportingPluginFactory, error)
  • func (d *DKGContainer) GetServices() ([]job.ServiceCtx, error)
• type DKGFactory
  • func (fac DKGFactory) NewReportingPlugin(configuration types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)
• type ParsedAttributedObservation

Types

type DKG

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

func (*DKG) Close

func (dkg *DKG) Close() error

func (*DKG) Observation

func (dkg *DKG) Observation(ctx context.Context, repts types.ReportTimestamp, query types.Query) (types.Observation, error)

func (*DKG) Query

func (dkg *DKG) Query(ctx context.Context, repts types.ReportTimestamp) (types.Query, error)

func (*DKG) Report

func (dkg *DKG) Report(ctx context.Context, repts types.ReportTimestamp, query types.Query, aos []types.AttributedObservation) (bool, types.Report, error)

func (*DKG) ShouldAcceptFinalizedReport

func (dkg *DKG) ShouldAcceptFinalizedReport(ctx context.Context, repts types.ReportTimestamp, report types.Report) (bool, error)

func (*DKG) ShouldTransmitAcceptedReport

func (dkg *DKG) ShouldTransmitAcceptedReport(ctx context.Context, repts types.ReportTimestamp, report types.Report) (bool, error)

type DKGContainer

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

func NewDKG

func NewDKG(l logger.Logger) (*DKGContainer, error)

func (*DKGContainer) GetPluginFactory

func (d *DKGContainer) GetPluginFactory() (ocr2types.ReportingPluginFactory, error)

func (*DKGContainer) GetServices

func (d *DKGContainer) GetServices() ([]job.ServiceCtx, error)

type DKGFactory

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

func (DKGFactory) NewReportingPlugin

func (fac DKGFactory) NewReportingPlugin(configuration types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)

type ParsedAttributedObservation

type ParsedAttributedObservation struct {
	Timestamp       uint32
	Value           *big.Int
	JuelsPerFeeCoin *big.Int
	Observer        commontypes.OracleID
}