actions

Documentation

Index

• type BCGetter
• type Caches
  • func NewCaches() *Caches
• type Call
• type DelegationCalculations
• type IdAmount
• type Manager
  • func NewManager(c Call, dataStore store.DataStore, tr transport.EthereumTransport, ...) *Manager
  • func (m *Manager) AfterEventLog(ctx context.Context, c contract.ContractsContents, ce structs.ContractEvent) (err error)
  • func (m *Manager) GetBlockHeader(ctx context.Context, height big.Int) (h *types.Header, err error)
  • func (m *Manager) GetImplementedContractNames() []string
  • func (m *Manager) SyncForBeginningOfEpoch(ctx context.Context, version string, currentBlock uint64, blockTime time.Time) error
• type NodeAggregationInfo
• type StateError

Types

type BCGetter

type BCGetter interface {
	GetBoundContractCaller(ctx context.Context, addr common.Address, a abi.ABI) *bind.BoundContract
}

type Caches

type Caches struct {
	Account        *lru.Cache
	AccountLock    sync.RWMutex
	Delegation     *lru.Cache
	DelegationLock sync.RWMutex
}

func NewCaches

func NewCaches() *Caches

type Call

type Call interface {
	// Validator
	IsAuthorizedValidator(ctx context.Context, bc *bind.BoundContract, blockNumber uint64, validatorID *big.Int) (isAuthorized bool, err error)
	GetValidator(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, validatorID *big.Int) (v structs.Validator, err error)
	GetValidatorWithInfo(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, validatorID *big.Int) (v structs.Validator, err error)

	// Nodes
	GetValidatorNodes(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, validatorID *big.Int) (nodes []structs.Node, err error)
	GetNode(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, nodeID *big.Int) (n structs.Node, err error)
	GetNodeWithInfo(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, nodeID *big.Int) (n structs.Node, err error)
	GetNodeNextRewardDate(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, nodeID *big.Int) (t time.Time, err error)
	GetNodeAddress(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, nodeID *big.Int) (address common.Address, err error)

	// Distributor
	GetEarnedFeeAmountOf(ctx context.Context, bc *bind.BoundContract, blockNumber uint64, validatorID *big.Int) (earned, endMonth *big.Int, err error)

	// Delegation
	GetPendingDelegationsTokens(ctx context.Context, bc *bind.BoundContract, blockNumber uint64, holderAddress common.Address) (amount *big.Int, err error)
	GetDelegation(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, delegationID *big.Int) (d structs.Delegation, err error)
	GetDelegationWithInfo(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, delegationID *big.Int) (d structs.Delegation, err error)
	GetDelegationState(ctx context.Context, bc *bind.BoundContract, blockNumber uint64, delegationID *big.Int) (ds structs.DelegationState, err error)
	GetValidatorDelegations(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, validatorID *big.Int) (delegations []structs.Delegation, err error)
	GetHolderDelegations(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, holder common.Address) (delegations []structs.Delegation, err error)
	GetValidatorDelegationsIDs(ctx context.Context, bc transport.BoundContractCaller, blockNumber uint64, validatorID *big.Int) (delegationsIDs []uint64, err error)
}

type DelegationCalculations

type DelegationCalculations struct {
	Err        error
	TotalStake map[uint64]*big.Int
}

type IdAmount

type IdAmount struct {
	Id     uint64
	Amount *big.Int
}

type Manager

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

func NewManager

func NewManager(c Call, dataStore store.DataStore, tr transport.EthereumTransport, cm *contract.Manager, l *zap.Logger) *Manager

func (*Manager) AfterEventLog

func (m *Manager) AfterEventLog(ctx context.Context, c contract.ContractsContents, ce structs.ContractEvent) (err error)

func (*Manager) GetBlockHeader

func (m *Manager) GetBlockHeader(ctx context.Context, height big.Int) (h *types.Header, err error)

func (*Manager) GetImplementedContractNames

func (m *Manager) GetImplementedContractNames() []string

func (*Manager) SyncForBeginningOfEpoch

func (m *Manager) SyncForBeginningOfEpoch(ctx context.Context, version string, currentBlock uint64, blockTime time.Time) error

type NodeAggregationInfo

type NodeAggregationInfo struct {
	ActiveNodeCount uint64
	LinkedNodeCount uint64
}

type StateError

type StateError struct {
	State  structs.DelegationState
	Err    error
	Amount *big.Int
}