batched

package

v0.8.2 Latest Latest Go to latest Published: May 25, 2023 License: Apache-2.0, MIT Imports: 14 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

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

Deprecated: use github.com/ipfs/boxo/provider/batched.BatchProvidingSystem

func New(provider provideMany, q *queue.Queue, opts ...Option) (*BatchProvidingSystem, error)

Deprecated: use github.com/ipfs/boxo/provider/batched.New

func (s *BatchProvidingSystem) Close() error

func (s *BatchProvidingSystem) Provide(cid cid.Cid) error

func (s *BatchProvidingSystem) Reprovide(ctx context.Context) error

func (s *BatchProvidingSystem) Run()

func (s *BatchProvidingSystem) Stat(ctx context.Context) (BatchedProviderStats, error)

Stat returns various stats about this provider system

type BatchedProviderStats struct {
	TotalProvides, LastReprovideBatchSize     int
	AvgProvideDuration, LastReprovideDuration time.Duration
}

Deprecated: use github.com/ipfs/boxo/provider/batched.BatchedProviderStats

type Option func(system *BatchProvidingSystem) error

Option defines the functional option type that can be used to configure BatchProvidingSystem instances

Deprecated: use github.com/ipfs/boxo/provider/batched.Option

func Datastore(batching datastore.Batching) Option

Deprecated: use github.com/ipfs/boxo/provider/batched.Datastore

func KeyProvider(fn simple.KeyChanFunc) Option

Deprecated: use github.com/ipfs/boxo/provider/batched.KeyProvider

func ReproviderInterval(duration time.Duration) Option

Deprecated: use github.com/ipfs/boxo/provider/batched.ReproviderInterval