batched

Documentation

Index

• type BatchProvidingSystem
  • func New(provider provideMany, q *queue.Queue, opts ...Option) (*BatchProvidingSystem, error)
  • 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)
• type BatchedProviderStats
• type Option
  • func Datastore(batching datastore.Batching) Option
  • func KeyProvider(fn simple.KeyChanFunc) Option
  • func ReproviderInterval(duration time.Duration) Option

Types

type BatchProvidingSystem

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

func New

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

func (*BatchProvidingSystem) Close

func (s *BatchProvidingSystem) Close() error

func (*BatchProvidingSystem) Provide

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

func (*BatchProvidingSystem) Reprovide

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

func (*BatchProvidingSystem) Run

func (s *BatchProvidingSystem) Run()

func (*BatchProvidingSystem) Stat

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

Stat returns various stats about this provider system

type BatchedProviderStats

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

type Option

type Option func(system *BatchProvidingSystem) error

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

func Datastore

func Datastore(batching datastore.Batching) Option

func KeyProvider

func KeyProvider(fn simple.KeyChanFunc) Option

func ReproviderInterval

func ReproviderInterval(duration time.Duration) Option