read

Documentation

Index

• type MetaMonitoringStatuses
• type ReadService
  • func NewReadService(coingeckoClient *coingecko.CoingeckoClient, cometClient *comet.CometClient, ...) (*ReadService, error)
  • func (s *ReadService) GetAssetPoolBalanceForToken(tokenAddress string) (*big.Int, error)
  • func (s *ReadService) GetAssetPrices() ([]coingecko.PriceData, error)
  • func (s *ReadService) GetBlockSigners(fromBlock int64, toBlock int64) ([]comet.BlockSignersData, error)
  • func (s *ReadService) GetCometTxs(fromBlock int64, toBlock int64) ([]comet.CometTx, error)
  • func (s *ReadService) GetEarliestBlockHeight(ctx context.Context) (int64, error)
  • func (s *ReadService) GetLatestFlushedSegmentsHeights(ctx context.Context) (map[string]int64, error)
  • func (s *ReadService) GetLatestLocalBlockHeight(ctx context.Context) (int64, error)
  • func (s *ReadService) GetMetaMonitoringStatuses(ctx context.Context) (MetaMonitoringStatuses, error)
  • func (s *ReadService) GetNetworkLatestBlockHeight() (int64, error)
  • func (s *ReadService) GetValidatorForAddressAtBlock(address string, block int64) (*comet.ValidatorData, error)
• type StoreReadService

Types

type MetaMonitoringStatuses

type MetaMonitoringStatuses struct {
	DataNodeData               *int32
	AssetPricesData            *int32
	BlockSignersData           *int32
	CometTxsData               *int32
	NetworkBalancesData        *int32
	NetworkHistorySegmentsData *int32

	UpdateTime time.Time
}

type ReadService

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

func NewReadService

func NewReadService(
	coingeckoClient *coingecko.CoingeckoClient,
	cometClient *comet.CometClient,
	ethClient *ethutils.EthClient,
	storeReadService StoreReadService,
	log *logging.Logger,
) (*ReadService, error)

func (*ReadService) GetAssetPoolBalanceForToken

func (s *ReadService) GetAssetPoolBalanceForToken(tokenAddress string) (*big.Int, error)

func (*ReadService) GetAssetPrices

func (s *ReadService) GetAssetPrices() ([]coingecko.PriceData, error)

func (*ReadService) GetBlockSigners

func (s *ReadService) GetBlockSigners(fromBlock int64, toBlock int64) ([]comet.BlockSignersData, error)

func (*ReadService) GetCometTxs

func (s *ReadService) GetCometTxs(fromBlock int64, toBlock int64) ([]comet.CometTx, error)

func (*ReadService) GetEarliestBlockHeight

func (s *ReadService) GetEarliestBlockHeight(ctx context.Context) (int64, error)

func (*ReadService) GetLatestFlushedSegmentsHeights

func (s *ReadService) GetLatestFlushedSegmentsHeights(ctx context.Context) (map[string]int64, error)

func (*ReadService) GetLatestLocalBlockHeight

func (s *ReadService) GetLatestLocalBlockHeight(ctx context.Context) (int64, error)

func (*ReadService) GetMetaMonitoringStatuses

func (s *ReadService) GetMetaMonitoringStatuses(ctx context.Context) (MetaMonitoringStatuses, error)

func (*ReadService) GetNetworkLatestBlockHeight

func (s *ReadService) GetNetworkLatestBlockHeight() (int64, error)

func (*ReadService) GetValidatorForAddressAtBlock

func (s *ReadService) GetValidatorForAddressAtBlock(address string, block int64) (*comet.ValidatorData, error)

type StoreReadService

type StoreReadService interface {
	NewNetworkHistorySegment() *sqlstore.NetworkHistorySegment
	NewMonitoringStatus() *sqlstore.MonitoringStatus
}