chaineconomics

Documentation

Index

• func ExtractChainEconomicsModel(ctx context.Context, node ChainEconomicsLens, ts *types.TipSet) (*chainmodel.ChainEconomics, error)
• func ExtractChainEconomicsV2Model(ctx context.Context, node ChainEconomicsLens, ts *types.TipSet) (*chainmodel.ChainEconomicsV2, error)
• type ChainEconomicsLens
• type EconomicsStorage
• type Task
  • func NewTask(node tasks.DataSource, version int) *Task
  • func (p *Task) ProcessTipSet(ctx context.Context, ts *types.TipSet) (model.Persistable, *visormodel.ProcessingReport, error)

Functions

func ExtractChainEconomicsModel

func ExtractChainEconomicsModel(ctx context.Context, node ChainEconomicsLens, ts *types.TipSet) (*chainmodel.ChainEconomics, error)

func ExtractChainEconomicsV2Model

func ExtractChainEconomicsV2Model(ctx context.Context, node ChainEconomicsLens, ts *types.TipSet) (*chainmodel.ChainEconomicsV2, error)

Types

type ChainEconomicsLens

type ChainEconomicsLens interface {
	CirculatingSupply(context.Context, *types.TipSet) (api.CirculatingSupply, error)
	Actor(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*types.Actor, error)
	Store() adt.Store
	MinerLoad(store adt.Store, act *types.Actor) (miner.State, error)
}

type EconomicsStorage

type EconomicsStorage interface {
	PersistBatch(ctx context.Context, ps ...model.Persistable) error
	MarkTipSetEconomicsComplete(ctx context.Context, tipset string, height int64, completedAt time.Time, errorsDetected string) error
}

type Task

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

func NewTask

func NewTask(node tasks.DataSource, version int) *Task

func (*Task) ProcessTipSet

func (p *Task) ProcessTipSet(ctx context.Context, ts *types.TipSet) (model.Persistable, *visormodel.ProcessingReport, error)