analysis

Documentation

Index

• Constants
• type Analyzer
  • func NewAnalyzer(logger *zap.Logger, relays []*builder.Client, events <-chan data.Event, ...) *Analyzer
  • func (a *Analyzer) GetFaults(start, end types.Epoch) FaultRecord
  • func (a *Analyzer) Run(ctx context.Context) error
• type FaultRecord
• type FaultStats
• type Faults
• type InvalidBid
• type Meta

Constants

const (
	InvalidBidConsensusType uint = iota
	InvalidBidIgnoredPreferencesType
)

const (
	GasLimitBoundDivisor = 1024
)

Types

type Analyzer

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

func NewAnalyzer

func NewAnalyzer(logger *zap.Logger, relays []*builder.Client, events <-chan data.Event, store store.Storer, consensusClient *consensus.Client, clock *consensus.Clock) *Analyzer

func (*Analyzer) GetFaults

func (a *Analyzer) GetFaults(start, end types.Epoch) FaultRecord

func (*Analyzer) Run

func (a *Analyzer) Run(ctx context.Context) error

type FaultRecord

type FaultRecord = map[types.PublicKey]*Faults

type FaultStats

type FaultStats struct {
	TotalBids uint `json:"total_bids"`

	ConsensusInvalidBids   uint `json:"consensus_invalid_bids"`
	IgnoredPreferencesBids uint `json:"ignored_preferences_bids"`

	PaymentInvalidBids       uint `json:"payment_invalid_bids"`
	MalformedPayloads        uint `json:"malformed_payloads"`
	ConsensusInvalidPayloads uint `json:"consensus_invalid_payloads"`
	UnavailablePayloads      uint `json:"unavailable_payloads"`
}

type Faults

type Faults struct {
	Stats *FaultStats `json:"stats"`
	Meta  *Meta       `json:"meta"`
}

type InvalidBid

type InvalidBid struct {
	Reason  string
	Type    uint
	Context map[string]interface{}
}

type Meta

type Meta struct {
	Endpoint string `json:"endpoint"`
}