indexprovider

Documentation

Index

• func NewWrapper(cfg lotus_config.DAGStoreConfig) func(lc fx.Lifecycle, r repo.LockedRepo, dealsDB *db.DealsDB, ...) *Wrapper
• type Wrapper
  • func (w *Wrapper) AnnounceBoostDeal(ctx context.Context, pds *types.ProviderDealState) (cid.Cid, error)
  • func (w *Wrapper) DagstoreReinitBoostDeals(ctx context.Context) (bool, error)
  • func (w *Wrapper) IndexerAnnounceAllDeals(ctx context.Context) error
  • func (w *Wrapper) Start(ctx context.Context)

Functions

func NewWrapper

func NewWrapper(cfg lotus_config.DAGStoreConfig) func(lc fx.Lifecycle, r repo.LockedRepo, dealsDB *db.DealsDB,
	legacyProv lotus_storagemarket.StorageProvider, prov provider.Interface, dagStore *dagstore.Wrapper,
	meshCreator idxprov.MeshCreator) *Wrapper

Types

type Wrapper

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

func (*Wrapper) AnnounceBoostDeal

func (w *Wrapper) AnnounceBoostDeal(ctx context.Context, pds *types.ProviderDealState) (cid.Cid, error)

func (*Wrapper) DagstoreReinitBoostDeals

func (w *Wrapper) DagstoreReinitBoostDeals(ctx context.Context) (bool, error)

func (*Wrapper) IndexerAnnounceAllDeals

func (w *Wrapper) IndexerAnnounceAllDeals(ctx context.Context) error

func (*Wrapper) Start

func (w *Wrapper) Start(ctx context.Context)