sql

Documentation

Index

• func GetATXs(db *sql.Database, atxIds []types.ATXID) (map[types.ATXID]*types.VerifiedActivationTx, []types.ATXID)
• func Setup(path string) (db *sql.Database, err error)
• type Client
  • func (c *Client) AccountsSnapshot(db *sql.Database, lid types.LayerID) (rst []*types.Account, err error)
  • func (c *Client) CountAtxsByEpoch(db *sql.Database, epoch int64) (int, error)
  • func (c *Client) GetAllRewards(db *sql.Database) (rst []*types.Reward, err error)
  • func (c *Client) GetAtxById(db *sql.Database, id string) (*types.VerifiedActivationTx, error)
  • func (c *Client) GetAtxsByEpoch(db *sql.Database, epoch int64, fn func(tx *types.VerifiedActivationTx) bool) error
  • func (c *Client) GetAtxsByEpochPaginated(db *sql.Database, epoch, limit, offset int64, ...) error
  • func (c *Client) GetAtxsReceivedAfter(db *sql.Database, ts int64, fn func(tx *types.VerifiedActivationTx) bool) error
  • func (c *Client) GetLayer(db *sql.Database, lid types.LayerID, numLayers uint32) (*pb.Layer, error)
  • func (c *Client) GetLayerRewards(db *sql.Database, lid types.LayerID) (rst []*types.Reward, err error)
• type DatabaseClient

Functions

func GetATXs

func GetATXs(db *sql.Database, atxIds []types.ATXID) (map[types.ATXID]*types.VerifiedActivationTx, []types.ATXID)

func Setup

func Setup(path string) (db *sql.Database, err error)

Types

type Client

type Client struct{}

func (*Client) AccountsSnapshot

func (c *Client) AccountsSnapshot(db *sql.Database, lid types.LayerID) (rst []*types.Account, err error)

func (*Client) CountAtxsByEpoch

func (c *Client) CountAtxsByEpoch(db *sql.Database, epoch int64) (int, error)

func (*Client) GetAllRewards

func (c *Client) GetAllRewards(db *sql.Database) (rst []*types.Reward, err error)

func (*Client) GetAtxById

func (c *Client) GetAtxById(db *sql.Database, id string) (*types.VerifiedActivationTx, error)

func (*Client) GetAtxsByEpoch

func (c *Client) GetAtxsByEpoch(db *sql.Database, epoch int64, fn func(tx *types.VerifiedActivationTx) bool) error

func (*Client) GetAtxsByEpochPaginated

func (c *Client) GetAtxsByEpochPaginated(db *sql.Database, epoch, limit, offset int64, fn func(tx *types.VerifiedActivationTx) bool) error

func (*Client) GetAtxsReceivedAfter

func (c *Client) GetAtxsReceivedAfter(db *sql.Database, ts int64, fn func(tx *types.VerifiedActivationTx) bool) error

func (*Client) GetLayer

func (c *Client) GetLayer(db *sql.Database, lid types.LayerID, numLayers uint32) (*pb.Layer, error)

func (*Client) GetLayerRewards

func (c *Client) GetLayerRewards(db *sql.Database, lid types.LayerID) (rst []*types.Reward, err error)

type DatabaseClient

type DatabaseClient interface {
	GetLayer(db *sql.Database, lid types.LayerID, numLayers uint32) (*pb.Layer, error)
	GetLayerRewards(db *sql.Database, lid types.LayerID) (rst []*types.Reward, err error)
	GetAllRewards(db *sql.Database) (rst []*types.Reward, err error)
	AccountsSnapshot(db *sql.Database, lid types.LayerID) (rst []*types.Account, err error)
	GetAtxsReceivedAfter(db *sql.Database, ts int64, fn func(tx *types.VerifiedActivationTx) bool) error
	GetAtxsByEpoch(db *sql.Database, epoch int64, fn func(tx *types.VerifiedActivationTx) bool) error
	CountAtxsByEpoch(db *sql.Database, epoch int64) (int, error)
	GetAtxsByEpochPaginated(db *sql.Database, epoch, limit, offset int64, fn func(tx *types.VerifiedActivationTx) bool) error
	GetAtxById(db *sql.Database, id string) (*types.VerifiedActivationTx, error)
}