indexer

Documentation

Index

• Constants
• Variables
• type CLBlockIndexer
  • func NewCLBlockIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, ...) (*CLBlockIndexer, error)
  • func (c *CLBlockIndexer) Name() string
  • func (c *CLBlockIndexer) Run()
• type CLStakeChange
• type CLStakingEventIndexer
  • func NewCLStakingEventIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, ...) (*CLStakingEventIndexer, error)
  • func (c *CLStakingEventIndexer) Name() string
  • func (c *CLStakingEventIndexer) Run()
• type CLTotalStakeIndexer
  • func NewCLTotalStakeIndexer(ctx context.Context, dbOperator *gorm.DB, rpcEndpoint string) (*CLTotalStakeIndexer, error)
  • func (c *CLTotalStakeIndexer) Name() string
  • func (c *CLTotalStakeIndexer) Run()
• type CLValidatorVoteIndexer
  • func NewCLValidatorVoteIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, ...) (*CLValidatorVoteIndexer, error)
  • func (c *CLValidatorVoteIndexer) Name() string
  • func (c *CLValidatorVoteIndexer) Run()
• type ELBlockIndexer
  • func NewELBlockIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, ...) (*ELBlockIndexer, error)
  • func (e *ELBlockIndexer) Name() string
  • func (e *ELBlockIndexer) Run()
• type ELRewardIndexer
  • func NewELRewardIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, ...) (*ELRewardIndexer, error)
  • func (e *ELRewardIndexer) Name() string
  • func (e *ELRewardIndexer) Run()
• type ELStakingEventIndexer
  • func NewELStakingEventIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, ...) (*ELStakingEventIndexer, error)
  • func (e *ELStakingEventIndexer) Name() string
  • func (e *ELStakingEventIndexer) Run()
• type Indexer

Constants

const (
	EventTypeSetOperatorFailure               = "set_operator_failure"
	EventTypeUnsetOperatorFailure             = "unset_operator_failure"
	EventTypeSetWithdrawalAddressFailure      = "set_withdrawal_address_failure"
	EventTypeSetRewardAddressFailure          = "set_reward_address_failure"
	EventTypeUpdateValidatorCommissionFailure = "update_validator_commission_failure"
	EventTypeCreateValidatorFailure           = "create_validator_failure"
	EventTypeDelegateFailure                  = "delegate_failure"
	EventTypeRedelegateFailure                = "redelegate_failure"
	EventTypeUndelegateFailure                = "undelegate_failure"
	EventTypeUnjailFailure                    = "unjail_failure"

	EventTypeSetOperatorSuccess               = "set_operator_success"
	EventTypeUnsetOperatorSuccess             = "unset_operator_success"
	EventTypeSetWithdrawalAddressSuccess      = "set_withdrawal_address_success"
	EventTypeSetRewardAddressSuccess          = "set_reward_address_success"
	EventTypeUpdateValidatorCommissionSuccess = "update_validator_commission_success"
	EventTypeCreateValidatorSuccess           = "create_validator_success"
	EventTypeDelegateSuccess                  = "delegate_success"
	EventTypeRedelegateSuccess                = "redelegate_success"
	EventTypeUndelegateSuccess                = "undelegate_success"
	EventTypeUnjailSuccess                    = "unjail_success"

	AttributeKeyErrorCode          = "error_code"
	AttributeKeyTxHash             = "tx_hash"
	AttributeKeyValidatorCmpPubKey = "validator_cmp_pubkey"
	AttributeKeyAmount             = "amount"
	AttributeKeySenderAddress      = "sender_address"
	AttributeKeyDelegatorAddress   = "delegator_addr"
)

const (
	TypeSetOperator               = "SetOperator"
	TypeUnsetOperator             = "UnsetOperator"
	TypeSetWithdrawalAddress      = "SetWithdrawalAddress"
	TypeSetRewardAddress          = "SetRewardAddress"
	TypeUpdateValidatorCommission = "UpdateValidatorCommission"
	TypeCreateValidator           = "CreateValidator"
	TypeStake                     = "Stake"
	TypeStakeOnBehalf             = "StakeOnBehalf"
	TypeRedelegate                = "Redelegate"
	TypeRedelegateOnBehalf        = "RedelegateOnBehalf"
	TypeUnstake                   = "Unstake"
	TypeUnstakeOnBehalf           = "UnstakeOnBehalf"
	TypeUnjail                    = "Unjail"
	TypeUnjailOnBehalf            = "UnjailOnBehalf"
)

const (
	WithdrawalTypeUnstake = 0
	WithdrawalTypeReward  = 1
	WithdrawalTypeUBI     = 2
)

const (
	IndexLag = 10
)

Variables

var Event2Type = map[string]string{
	EventTypeUpdateValidatorCommissionSuccess: TypeUpdateValidatorCommission,
	EventTypeUpdateValidatorCommissionFailure: TypeUpdateValidatorCommission,
	EventTypeSetWithdrawalAddressSuccess:      TypeSetWithdrawalAddress,
	EventTypeSetWithdrawalAddressFailure:      TypeSetWithdrawalAddress,
	EventTypeSetRewardAddressSuccess:          TypeSetRewardAddress,
	EventTypeSetRewardAddressFailure:          TypeSetRewardAddress,
	EventTypeSetOperatorSuccess:               TypeSetOperator,
	EventTypeSetOperatorFailure:               TypeSetOperator,
	EventTypeUnsetOperatorSuccess:             TypeUnsetOperator,
	EventTypeUnsetOperatorFailure:             TypeUnsetOperator,
	EventTypeCreateValidatorSuccess:           TypeCreateValidator,
	EventTypeCreateValidatorFailure:           TypeCreateValidator,
	EventTypeDelegateSuccess:                  TypeStake,
	EventTypeDelegateFailure:                  TypeStake,
	EventTypeRedelegateSuccess:                TypeRedelegate,
	EventTypeRedelegateFailure:                TypeRedelegate,
	EventTypeUndelegateSuccess:                TypeUnstake,
	EventTypeUndelegateFailure:                TypeUnstake,
	EventTypeUnjailSuccess:                    TypeUnjail,
	EventTypeUnjailFailure:                    TypeUnjail,
}

var EventType2Behalf = map[string]string{
	TypeStake:      TypeStakeOnBehalf,
	TypeRedelegate: TypeRedelegateOnBehalf,
	TypeUnstake:    TypeUnstakeOnBehalf,
	TypeUnjail:     TypeUnjailOnBehalf,
}

Types

type CLBlockIndexer

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

func NewCLBlockIndexer

func NewCLBlockIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, rpcEndpoint string) (*CLBlockIndexer, error)

func (*CLBlockIndexer) Name

func (c *CLBlockIndexer) Name() string

func (*CLBlockIndexer) Run

func (c *CLBlockIndexer) Run()

type CLStakeChange

type CLStakeChange struct {
	BlockHeight       int64
	StakeChangeAmount int64
}

type CLStakingEventIndexer

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

func NewCLStakingEventIndexer

func NewCLStakingEventIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, rpcEndpoint string) (*CLStakingEventIndexer, error)

func (*CLStakingEventIndexer) Name

func (c *CLStakingEventIndexer) Name() string

func (*CLStakingEventIndexer) Run

func (c *CLStakingEventIndexer) Run()

type CLTotalStakeIndexer

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

func NewCLTotalStakeIndexer

func NewCLTotalStakeIndexer(ctx context.Context, dbOperator *gorm.DB, rpcEndpoint string) (*CLTotalStakeIndexer, error)

func (*CLTotalStakeIndexer) Name

func (c *CLTotalStakeIndexer) Name() string

func (*CLTotalStakeIndexer) Run

func (c *CLTotalStakeIndexer) Run()

type CLValidatorVoteIndexer

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

func NewCLValidatorVoteIndexer

func NewCLValidatorVoteIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, rpcEndpoint string) (*CLValidatorVoteIndexer, error)

func (*CLValidatorVoteIndexer) Name

func (c *CLValidatorVoteIndexer) Name() string

func (*CLValidatorVoteIndexer) Run

func (c *CLValidatorVoteIndexer) Run()

type ELBlockIndexer

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

func NewELBlockIndexer

func NewELBlockIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, rpcEndpoint string) (*ELBlockIndexer, error)

func (*ELBlockIndexer) Name

func (e *ELBlockIndexer) Name() string

func (*ELBlockIndexer) Run

func (e *ELBlockIndexer) Run()

type ELRewardIndexer

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

func NewELRewardIndexer

func NewELRewardIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, rpcEndpoint string) (*ELRewardIndexer, error)

func (*ELRewardIndexer) Name

func (e *ELRewardIndexer) Name() string

func (*ELRewardIndexer) Run

func (e *ELRewardIndexer) Run()

type ELStakingEventIndexer

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

func NewELStakingEventIndexer

func NewELStakingEventIndexer(ctx context.Context, dbOperator *gorm.DB, cacheOperator *redis.Client, rpcEndpoint string) (*ELStakingEventIndexer, error)

func (*ELStakingEventIndexer) Name

func (e *ELStakingEventIndexer) Name() string

func (*ELStakingEventIndexer) Run

func (e *ELStakingEventIndexer) Run()

type Indexer

type Indexer interface {
	Run()
	Name() string
}