clouddatastore

package
v0.0.0-...-1196ed7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 3, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Store

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

func NewStore

func NewStore(ctx context.Context) (*Store, error)

func (*Store) GetAccountRewards

func (s *Store) GetAccountRewards(ctx context.Context, account common.Address, limit int, cursor string) ([]*types.AccountRewardHistory, string, error)

func (*Store) GetAccountRewardsAt

func (s *Store) GetAccountRewardsAt(ctx context.Context, account common.Address, at time.Time) (*types.AccountRewardHistory, error)

GetAccountRewardsAt implements store.Store

func (*Store) GetAccountRewardsBetween

func (s *Store) GetAccountRewardsBetween(ctx context.Context, account common.Address, start, end time.Time) ([]*types.AccountRewardHistory, error)

func (*Store) GetAllAccountRewardsAt

func (s *Store) GetAllAccountRewardsAt(ctx context.Context, at time.Time) ([]*types.AccountRewardHistory, error)

GetAllAccountRewardsAt implements store.Store

func (*Store) GetGatewayRewards

func (s *Store) GetGatewayRewards(ctx context.Context, gatewayID types.ID, limit int, cursor string) ([]*types.GatewayRewardHistory, string, error)

func (*Store) GetGatewayRewardsAt

func (*Store) GetGatewayRewardsAt(ctx context.Context, gatewayID types.ID, at time.Time) (*types.GatewayRewardHistory, error)

GetGatewayRewardsAt implements store.Store

func (*Store) GetGatewayRewardsBetween

func (s *Store) GetGatewayRewardsBetween(ctx context.Context, gatewayID types.ID, start, end time.Time) ([]*types.GatewayRewardHistory, error)

func (*Store) GetLatestRewardsDate

func (s *Store) GetLatestRewardsDate(ctx context.Context) (time.Time, error)

GetLatestRewardsDate implements store.Store

func (*Store) GetLatestRewardsDateCached

func (s *Store) GetLatestRewardsDateCached(ctx context.Context) (time.Time, error)

func (*Store) GetLatestSignedAccountReward

func (s *Store) GetLatestSignedAccountReward(ctx context.Context, account common.Address) (*types.AccountRewardHistory, error)

GetLatestSignedAccountReward implements store.Store

func (*Store) GetMapperRewards

func (s *Store) GetMapperRewards(ctx context.Context, mapperID types.ID, limit int, cursor string) ([]*types.MapperRewardHistory, string, error)

func (*Store) GetMapperRewardsAt

func (*Store) GetMapperRewardsAt(ctx context.Context, mapperID types.ID, at time.Time) (*types.MapperRewardHistory, error)

GetMapperRewardsAt implements store.Store

func (*Store) GetMapperRewardsBetween

func (s *Store) GetMapperRewardsBetween(ctx context.Context, mapperID types.ID, start, end time.Time) ([]*types.MapperRewardHistory, error)

func (*Store) GetMinMaxRewardsDates

func (s *Store) GetMinMaxRewardsDates(ctx context.Context) (time.Time, time.Time, error)

func (*Store) StoreAccountRewards

func (s *Store) StoreAccountRewards(ctx context.Context, accountRewardHistories []*types.AccountRewardHistory) error

StoreAccountRewards implements store.Store

func (*Store) StoreGatewayRewards

func (s *Store) StoreGatewayRewards(ctx context.Context, gatewayRewardHistories []*types.GatewayRewardHistory) error

StoreGatewayRewards implements store.Store

func (*Store) StoreMapperRewards

func (s *Store) StoreMapperRewards(ctx context.Context, mapperRewardHistories []*types.MapperRewardHistory) error

StoreMapperRewards implements store.Store

func (*Store) StoreRewardHistory

func (s *Store) StoreRewardHistory(ctx context.Context, rewardHistory *types.RewardHistory) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL