fetcher

Documentation

Index

• type FetchableItems
• type Fetcher
  • func NewConcurrentFetcher[I FetchableItems[O], O any](ctx context.Context, nWorkers, maxItemsInMemory int, ...) (Fetcher[O], error)

Types

type FetchableItems

type FetchableItems[OutputType any] interface {
	Fetch(ctx context.Context) (OutputType, error)
}

type Fetcher

type Fetcher[OutputType any] interface {
	Err() error
	Start() (<-chan OutputType, context.CancelFunc, error)
}

func NewConcurrentFetcher

func NewConcurrentFetcher[I FetchableItems[O], O any](ctx context.Context, nWorkers, maxItemsInMemory int, inputChan <-chan FetchableItems[O]) (Fetcher[O], error)