gc

Documentation

Index

• Constants
• type SDRPipelineGC
  • func NewSDRPipelineGC(db *harmonydb.DB) *SDRPipelineGC
  • func (s *SDRPipelineGC) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (s *SDRPipelineGC) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (s *SDRPipelineGC) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (s *SDRPipelineGC) TypeDetails() harmonytask.TaskTypeDetails
• type StorageEndpointGC
  • func NewStorageEndpointGC(si paths.SectorIndex, remote *paths.Remote, db *harmonydb.DB) *StorageEndpointGC
  • func (s *StorageEndpointGC) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (s *StorageEndpointGC) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (s *StorageEndpointGC) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (s *StorageEndpointGC) TypeDetails() harmonytask.TaskTypeDetails
• type StorageGCMark
  • func NewStorageGCMark(si paths.SectorIndex, remote *paths.Remote, db *harmonydb.DB, ...) *StorageGCMark
  • func (s *StorageGCMark) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (s *StorageGCMark) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (s *StorageGCMark) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (s *StorageGCMark) TypeDetails() harmonytask.TaskTypeDetails
• type StorageGCMarkNodeAPI
• type StorageGCSweep
  • func NewStorageGCSweep(db *harmonydb.DB, storage *paths.Remote, index paths.SectorIndex) *StorageGCSweep
  • func (s *StorageGCSweep) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (s *StorageGCSweep) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (s *StorageGCSweep) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (s *StorageGCSweep) TypeDetails() harmonytask.TaskTypeDetails

Constants

const MaxParallelEndpointChecks = 32

const SDRPipelineGCInterval = 19 * time.Minute

const StorageEndpointDeadTime = StorageEndpointGCInterval * 6 // ~2h

const StorageEndpointGCInterval = 21 * time.Minute

const StorageGCInterval = 9 * time.Minute

Types

type SDRPipelineGC

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

func NewSDRPipelineGC

func NewSDRPipelineGC(db *harmonydb.DB) *SDRPipelineGC

func (*SDRPipelineGC) Adder

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

func (*SDRPipelineGC) CanAccept

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

func (*SDRPipelineGC) Do

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

func (*SDRPipelineGC) TypeDetails

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

type StorageEndpointGC

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

func NewStorageEndpointGC

func NewStorageEndpointGC(si paths.SectorIndex, remote *paths.Remote, db *harmonydb.DB) *StorageEndpointGC

func (*StorageEndpointGC) Adder

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

func (*StorageEndpointGC) CanAccept

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

func (*StorageEndpointGC) Do

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

func (*StorageEndpointGC) TypeDetails

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

type StorageGCMark

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

func NewStorageGCMark

func NewStorageGCMark(si paths.SectorIndex, remote *paths.Remote, db *harmonydb.DB, bstore curiochain.CurioBlockstore, api StorageGCMarkNodeAPI) *StorageGCMark

func (*StorageGCMark) Adder

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

func (*StorageGCMark) CanAccept

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

func (*StorageGCMark) Do

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

func (*StorageGCMark) TypeDetails

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

type StorageGCMarkNodeAPI

type StorageGCMarkNodeAPI interface {
	StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)
}

type StorageGCSweep

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

func NewStorageGCSweep

func NewStorageGCSweep(db *harmonydb.DB, storage *paths.Remote, index paths.SectorIndex) *StorageGCSweep

func (*StorageGCSweep) Adder

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

func (*StorageGCSweep) CanAccept

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

func (*StorageGCSweep) Do

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

func (*StorageGCSweep) TypeDetails

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