indexprovider

Documentation

Index

• func NewWrapper(cfg lotus_config.DAGStoreConfig) func(lc fx.Lifecycle, r repo.LockedRepo, dealsDB *db.DealsDB, ...) *Wrapper
• type DisabledIndexProvider
  • func NewDisabledIndexProvider() *DisabledIndexProvider
  • func (d DisabledIndexProvider) GetAdv(ctx context.Context, cid cid.Cid) (*schema.Advertisement, error)
  • func (d DisabledIndexProvider) GetLatestAdv(ctx context.Context) (cid.Cid, *schema.Advertisement, error)
  • func (d DisabledIndexProvider) NotifyPut(ctx context.Context, contextID []byte, md metadata.Metadata) (cid.Cid, error)
  • func (d DisabledIndexProvider) NotifyRemove(ctx context.Context, contextID []byte) (cid.Cid, error)
  • func (d DisabledIndexProvider) Publish(ctx context.Context, advertisement schema.Advertisement) (cid.Cid, error)
  • func (d DisabledIndexProvider) PublishLocal(ctx context.Context, advertisement schema.Advertisement) (cid.Cid, error)
  • func (d DisabledIndexProvider) RegisterMultihashLister(lister provider.MultihashLister)
  • func (d DisabledIndexProvider) Shutdown() error
• 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) Enabled() bool
  • 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 DisabledIndexProvider

type DisabledIndexProvider struct {
}

func NewDisabledIndexProvider

func NewDisabledIndexProvider() *DisabledIndexProvider

func (DisabledIndexProvider) GetAdv

func (d DisabledIndexProvider) GetAdv(ctx context.Context, cid cid.Cid) (*schema.Advertisement, error)

func (DisabledIndexProvider) GetLatestAdv

func (d DisabledIndexProvider) GetLatestAdv(ctx context.Context) (cid.Cid, *schema.Advertisement, error)

func (DisabledIndexProvider) NotifyPut

func (d DisabledIndexProvider) NotifyPut(ctx context.Context, contextID []byte, md metadata.Metadata) (cid.Cid, error)

func (DisabledIndexProvider) NotifyRemove

func (d DisabledIndexProvider) NotifyRemove(ctx context.Context, contextID []byte) (cid.Cid, error)

func (DisabledIndexProvider) Publish

func (d DisabledIndexProvider) Publish(ctx context.Context, advertisement schema.Advertisement) (cid.Cid, error)

func (DisabledIndexProvider) PublishLocal

func (d DisabledIndexProvider) PublishLocal(ctx context.Context, advertisement schema.Advertisement) (cid.Cid, error)

func (DisabledIndexProvider) RegisterMultihashLister

func (d DisabledIndexProvider) RegisterMultihashLister(lister provider.MultihashLister)

func (DisabledIndexProvider) Shutdown

func (d DisabledIndexProvider) Shutdown() error

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) Enabled

func (w *Wrapper) Enabled() bool

func (*Wrapper) IndexerAnnounceAllDeals

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

func (*Wrapper) Start

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