sql

Documentation

Index

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

Functions

func GetATXs

func GetATXs(db sql.Executor, atxIds []types.ATXID) (map[types.ATXID]*types.ActivationTx, []types.ATXID)

func Setup

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

Types

type Client

type Client struct{}

func (*Client) AccountsSnapshot

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

func (*Client) CountAtxsByEpoch

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

func (*Client) GetAllRewards

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

func (*Client) GetAtxById

func (c *Client) GetAtxById(db sql.Executor, id string) (*types.ActivationTx, error)

func (*Client) GetAtxsByEpoch

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

func (*Client) GetAtxsByEpochPaginated

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

func (*Client) GetAtxsReceivedAfter

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

func (*Client) GetLayer

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

func (*Client) GetLayerRewards

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

type DatabaseClient

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