contentmgr

Documentation

Index

• type IManager
  • func NewManager(db *gorm.DB, fc *filclient.FilClient, tbs *util.TrackingBlockstore, ...) IManager

Types

type IManager

type IManager interface {
	GarbageCollect(ctx context.Context) error
	RemoveContent(ctx context.Context, contID uint, now bool) error
	RefreshContent(ctx context.Context, cont uint64) error
	OffloadContents(ctx context.Context, conts []uint64) (int, error)
	ClearUnused(ctx context.Context, spaceRequest int64, loc string, users []uint, dryrun bool) (*collectionResult, error)
	GetRemovalCandidates(ctx context.Context, all bool, loc string, users []uint) ([]removalCandidateInfo, error)
	UnpinContent(ctx context.Context, contid uint) error
	GetContent(id uint64) (*util.Content, error)
	TryRetrieve(ctx context.Context, maddr address.Address, c cid.Cid, ask *retrievalmarket.QueryResponse) error
	RecordRetrievalFailure(rfr *util.RetrievalFailureRecord) error
	RefreshContentForCid(ctx context.Context, c cid.Cid) (blocks.Block, error)
}

func NewManager

func NewManager(
	db *gorm.DB,
	fc *filclient.FilClient,
	tbs *util.TrackingBlockstore,
	nd *node.Node,
	cfg *config.Estuary,
	log *zap.SugaredLogger,
	shuttleMgr shuttle.IManager,
) IManager