chaineconomics

Documentation

Index

• func ExtractChainEconomicsModel(ctx context.Context, node ChainEconomicsLens, ts *types.TipSet) (*chainmodel.ChainEconomics, error)
• type ChainEconomicsLens
• type EconomicsStorage
• type Task
  • func NewTask(node tasks.DataSource) *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)

Types

type ChainEconomicsLens

type ChainEconomicsLens interface {
	CirculatingSupply(context.Context, *types.TipSet) (api.CirculatingSupply, 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) *Task

func (*Task) ProcessTipSet

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