ethservice

Documentation

Index

• type EthService
  • func NewEthService() *EthService
  • func (e *EthService) BatchCheckRegisteredValidators(validators []phase0.BLSPubKey) (map[string]contracts.BlsPublicKeyToProposerResult, error)
  • func (e *EthService) BatchK2CheckClaimableRewards(nodeOperators []common.Address) (map[common.Address]uint64, error)
  • func (e *EthService) BatchK2CheckRegisteredValidators(validators []phase0.BLSPubKey) (map[string]string, error)
  • func (e *EthService) BatchK2ClaimRewards(rewardClaims []k2common.K2Claim) (tx *types.Transaction, err error)
  • func (e *EthService) BatchRegisterValidators(validatorRegistrations []k2common.K2ValidatorRegistration) (tx *types.Transaction, err error)
  • func (e *EthService) Configure(cfg config.EthServiceConfig, logger *logrus.Entry) error
  • func (e *EthService) ConnectedChainId() *big.Int
  • func (e *EthService) FetchProposerRegistryAddressFromK2Lending() (string, error)
  • func (e *EthService) FetchProposerRegistryAddressFromK2NodeOperator() (string, error)
  • func (e *EthService) GetBlock(number *big.Int) (*types.Block, error)
  • func (e *EthService) GetTotalNativeDelegationCapacityConsumed() (*big.Int, error)
  • func (e *EthService) GlobalMaxNativeDelegation() (*big.Int, error)
  • func (e *EthService) IndividualMaxNativeDelegation() (*big.Int, error)
  • func (e *EthService) K2BatchNativeDelegation(validatorRegistrations []k2common.K2ValidatorRegistration) (tx *types.Transaction, err error)
  • func (e *EthService) K2CheckInclusionList(nodeOperatorRepresentative common.Address) (bool, error)
  • func (e *EthService) K2CheckInclusionListKeysCount(nodeOperatorRepresentative common.Address) (*big.Int, error)
  • func (e *EthService) K2Exit(validatorExit k2common.K2Exit) (tx *types.Transaction, err error)
  • func (e *EthService) K2NodeOperatorToPayoutRecipient(nodeOperatorAddresses []common.Address) (map[string]common.Address, error)
  • func (e *EthService) SetMaxGasPrice(maxGasPrice uint64)
  • func (e *EthService) Status() (*ethereum.SyncProgress, error)

Types

type EthService

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

func NewEthService

func NewEthService() *EthService

func (*EthService) BatchCheckRegisteredValidators

func (e *EthService) BatchCheckRegisteredValidators(validators []phase0.BLSPubKey) (map[string]contracts.BlsPublicKeyToProposerResult, error)

func (*EthService) BatchK2CheckClaimableRewards

func (e *EthService) BatchK2CheckClaimableRewards(nodeOperators []common.Address) (map[common.Address]uint64, error)

func (*EthService) BatchK2CheckRegisteredValidators

func (e *EthService) BatchK2CheckRegisteredValidators(validators []phase0.BLSPubKey) (map[string]string, error)

func (*EthService) BatchK2ClaimRewards

func (e *EthService) BatchK2ClaimRewards(rewardClaims []k2common.K2Claim) (tx *types.Transaction, err error)

func (*EthService) BatchRegisterValidators

func (e *EthService) BatchRegisterValidators(validatorRegistrations []k2common.K2ValidatorRegistration) (tx *types.Transaction, err error)

func (*EthService) Configure

func (e *EthService) Configure(cfg config.EthServiceConfig, logger *logrus.Entry) error

func (*EthService) ConnectedChainId

func (e *EthService) ConnectedChainId() *big.Int

func (*EthService) FetchProposerRegistryAddressFromK2Lending

func (e *EthService) FetchProposerRegistryAddressFromK2Lending() (string, error)

func (*EthService) FetchProposerRegistryAddressFromK2NodeOperator

func (e *EthService) FetchProposerRegistryAddressFromK2NodeOperator() (string, error)

func (*EthService) GetBlock

func (e *EthService) GetBlock(number *big.Int) (*types.Block, error)

func (*EthService) GetTotalNativeDelegationCapacityConsumed

func (e *EthService) GetTotalNativeDelegationCapacityConsumed() (*big.Int, error)

func (*EthService) GlobalMaxNativeDelegation

func (e *EthService) GlobalMaxNativeDelegation() (*big.Int, error)

func (*EthService) IndividualMaxNativeDelegation

func (e *EthService) IndividualMaxNativeDelegation() (*big.Int, error)

func (*EthService) K2BatchNativeDelegation

func (e *EthService) K2BatchNativeDelegation(validatorRegistrations []k2common.K2ValidatorRegistration) (tx *types.Transaction, err error)

func (*EthService) K2CheckInclusionList

func (e *EthService) K2CheckInclusionList(nodeOperatorRepresentative common.Address) (bool, error)

K2 Capacity, Limits & Node Operator Inclusion list

func (*EthService) K2CheckInclusionListKeysCount

func (e *EthService) K2CheckInclusionListKeysCount(nodeOperatorRepresentative common.Address) (*big.Int, error)

func (*EthService) K2Exit

func (e *EthService) K2Exit(validatorExit k2common.K2Exit) (tx *types.Transaction, err error)

func (*EthService) K2NodeOperatorToPayoutRecipient

func (e *EthService) K2NodeOperatorToPayoutRecipient(nodeOperatorAddresses []common.Address) (map[string]common.Address, error)

func (*EthService) SetMaxGasPrice

func (e *EthService) SetMaxGasPrice(maxGasPrice uint64)

func (*EthService) Status

func (e *EthService) Status() (*ethereum.SyncProgress, error)