validator

Documentation

Index

• Constants
• Variables
• type AttentionStatusRules
• type Config
  • func ConfigFromInterface(data interface{}) (Config, error)
• type MaxCommissionRateChange
• type MaxEditQuota
• type Validator
  • func NewValidator(logger applogger.Logger, rdbConn rdb.Conn, conNodeAddressPrefix string, ...) *Validator
  • func (_ *Validator) GetEventsToListen() []string
  • func (projection *Validator) HandleEvents(height int64, events []event_entity.Event) error
  • func (projection *Validator) OnInit() error

Constants

const DO_NOT_MODIFY = "[do-not-modify]"

Variables

var (
	NewValidators                     = view.NewValidatorsView
	NewValidatorActivities            = view.NewValidatorActivitiesView
	NewValidatorActivitiesTotal       = view.NewValidatorActivitiesTotalView
	NewValidatorBlockCommitments      = view.NewValidatorBlockCommitments
	NewValidatorBlockCommitmentsTotal = view.NewValidatorBlockCommitmentsTotal
	NewValidatorActiveBlocks          = view.NewValidatorActiveBlocksView
	UpdateLastHandledEventHeight      = (*Validator).UpdateLastHandledEventHeight
)

Types

type AttentionStatusRules

type AttentionStatusRules struct {
	MaxCommissionRateChange MaxCommissionRateChange `mapstructure:"max_commission_rate_change"`
	MaxEditQuota            MaxEditQuota            `mapstructure:"max_edit_quota"`
}

type Config

type Config struct {
	AttentionStatusRules       AttentionStatusRules `mapstructure:"attention_status_rules"`
	MaxActiveBlocksPeriodLimit int64                `mapstructure:"max_active_blocks_period_limit"`
}

func ConfigFromInterface

func ConfigFromInterface(data interface{}) (Config, error)

type MaxCommissionRateChange

type MaxCommissionRateChange struct {
	Enable    bool    `mapstructure:"enable"`
	MaxChange float64 `mapstructure:"max_change"`
}

type MaxEditQuota

type MaxEditQuota struct {
	Enable   bool           `mapstructure:"enable"`
	Quota    map[string]int `mapstructure:"quota"`
	Interval string         `mapstructure:"interval"`
	Duration int64
}

type Validator

type Validator struct {
	*rdbprojectionbase.Base
	// contains filtered or unexported fields
}

func NewValidator

func NewValidator(
	logger applogger.Logger,
	rdbConn rdb.Conn,
	conNodeAddressPrefix string,
	migrationHelper migrationhelper.MigrationHelper,
	config *Config,
) *Validator

func (*Validator) GetEventsToListen

func (_ *Validator) GetEventsToListen() []string

func (*Validator) HandleEvents

func (projection *Validator) HandleEvents(height int64, events []event_entity.Event) error

func (*Validator) OnInit

func (projection *Validator) OnInit() error