minerprotocols

Documentation

Index

• type API
• type Task
  • func NewTask(api API) *Task
  • func (t *Task) Close() error
  • func (t *Task) Process(ctx context.Context) (model.Persistable, error)

Types

type API

type API interface {
	Host() host.Host
	ChainHead(context.Context) (*types.TipSet, error)
	StateMinerInfo(ctx context.Context, addr address.Address, tsk types.TipSetKey) (lapi.MinerInfo, error)
	StateListMiners(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)
	StateMinerPower(context.Context, address.Address, types.TipSetKey) (*lapi.MinerPower, error)
}

type Task

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

func NewTask

func NewTask(api API) *Task

func (*Task) Close

func (t *Task) Close() error

func (*Task) Process

func (t *Task) Process(ctx context.Context) (model.Persistable, error)