Documentation
¶
Index ¶
- Constants
- type 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 ¶
View Source
const SectorMetadataRefreshInterval = 15 * time.Minute
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 {
ChainHead(ctx context.Context) (*types.TipSet, error)
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)
}
Source Files
Click to show internal directories.
Click to hide internal directories.