metadata

Documentation

Index

• Constants
• type SectorMetadata
  • func NewSectorMetadataTask(db *harmonydb.DB, bstore curiochain.CurioBlockstore, api SectorMetadataNodeAPI) *SectorMetadata
  • func (s *SectorMetadata) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (s *SectorMetadata) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (s *SectorMetadata) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (s *SectorMetadata) TypeDetails() harmonytask.TaskTypeDetails
• type SectorMetadataNodeAPI

Constants

const SectorMetadataRefreshInterval = 191 * time.Minute

Types

type SectorMetadata

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

func NewSectorMetadataTask

func NewSectorMetadataTask(db *harmonydb.DB, bstore curiochain.CurioBlockstore, api SectorMetadataNodeAPI) *SectorMetadata

func (*SectorMetadata) Adder

func (s *SectorMetadata) Adder(taskFunc harmonytask.AddTaskFunc)

func (*SectorMetadata) CanAccept

func (s *SectorMetadata) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*SectorMetadata) Do

func (s *SectorMetadata) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*SectorMetadata) TypeDetails

func (s *SectorMetadata) TypeDetails() harmonytask.TaskTypeDetails

type SectorMetadataNodeAPI

type SectorMetadataNodeAPI interface {
	StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)
	StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tok types.TipSetKey) (*miner.SectorLocation, error)
}