update

Documentation

Index

• Constants
• func UpdateBlockRange(ctx context.Context, fromBlock int64, toBlock int64, ...) (int, error)
• func UpdateCometTxsRange(ctx context.Context, fromBlock int64, toBlock int64, ...) (int, error)
• type UpdateService
  • func NewUpdateService(readService *read.ReadService, storeService *services.StoreService, ...) (*UpdateService, error)
  • func (us *UpdateService) UpdateAssetPoolBalances(ctx context.Context, ethConfig, arbitrumConfig config.EthereumConfig) error
  • func (us *UpdateService) UpdateAssetPrices(ctx context.Context) error
  • func (us *UpdateService) UpdateBlockSigners(ctx context.Context, fromBlock int64, toBlock int64) error
  • func (us *UpdateService) UpdateBlockSignersAllNew(ctx context.Context) error
  • func (us *UpdateService) UpdateCometTxs(ctx context.Context, fromBlock int64, toBlock int64) error
  • func (us *UpdateService) UpdateCometTxsAllNew(ctx context.Context) error
  • func (us *UpdateService) UpdateNetworkHistorySegments(ctx context.Context, apiURLs []string) error
  • func (us *UpdateService) UpdatePartiesTotalBalances(ctx context.Context) error
  • func (us *UpdateService) UpdateUnfinalizedDepositsBalances(ctx context.Context) error
  • func (us *UpdateService) UpdateUnrealisedWithdrawalsBalances(ctx context.Context) error

Constants

const (
	BLOCK_NUM_IN_24h int64 = 123500 // 24[h/day] * 60[min/h] * 60[sec/h] / 0.7[block/sec]
)

const UpdaterType = "updater"

Functions

func UpdateBlockRange

func UpdateBlockRange(
	ctx context.Context,
	fromBlock int64,
	toBlock int64,
	readService *read.ReadService,
	blockSignerStore *sqlstore.BlockSigner,
	logger *logging.Logger,
) (int, error)

func UpdateCometTxsRange

func UpdateCometTxsRange(
	ctx context.Context,
	fromBlock int64,
	toBlock int64,
	readService *read.ReadService,
	serviceStore *sqlstore.CometTxs,
	logger *logging.Logger,
) (int, error)

Types

type UpdateService

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

func NewUpdateService

func NewUpdateService(
	readService *read.ReadService,
	storeService *services.StoreService,
	log *logging.Logger,
) (*UpdateService, error)

func (*UpdateService) UpdateAssetPoolBalances

func (us *UpdateService) UpdateAssetPoolBalances(ctx context.Context, ethConfig, arbitrumConfig config.EthereumConfig) error

func (*UpdateService) UpdateAssetPrices

func (us *UpdateService) UpdateAssetPrices(ctx context.Context) error

func (*UpdateService) UpdateBlockSigners

func (us *UpdateService) UpdateBlockSigners(ctx context.Context, fromBlock int64, toBlock int64) error

func (*UpdateService) UpdateBlockSignersAllNew

func (us *UpdateService) UpdateBlockSignersAllNew(ctx context.Context) error

func (*UpdateService) UpdateCometTxs

func (us *UpdateService) UpdateCometTxs(ctx context.Context, fromBlock int64, toBlock int64) error

func (*UpdateService) UpdateCometTxsAllNew

func (us *UpdateService) UpdateCometTxsAllNew(ctx context.Context) error

func (*UpdateService) UpdateNetworkHistorySegments

func (us *UpdateService) UpdateNetworkHistorySegments(ctx context.Context, apiURLs []string) error

func (*UpdateService) UpdatePartiesTotalBalances

func (us *UpdateService) UpdatePartiesTotalBalances(ctx context.Context) error

func (*UpdateService) UpdateUnfinalizedDepositsBalances

func (us *UpdateService) UpdateUnfinalizedDepositsBalances(ctx context.Context) error

func (*UpdateService) UpdateUnrealisedWithdrawalsBalances

func (us *UpdateService) UpdateUnrealisedWithdrawalsBalances(ctx context.Context) error