extractor

type BundleCache interface {
	// GetBundle returns a bundle for the given image. An error is
	// returned if the bundle cannot be retrieved or the data is
	// corrupted.
	GetBundle(img string) (*operator.Bundle, error)
	// SetBundle caches a bundle for the given image. An error
	// is returned if the bundle cannot be cached.
	SetBundle(img string, bundle operator.Bundle) error
}

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

type BundleCacheImplConfig struct {
	Store Store
}

type BundleCacheImplOption interface {
	ConfigureBundleCacheImpl(*BundleCacheImplConfig)
}

type BundleExtractor interface {
	Extract(ctx context.Context, bundleImage string) (operator.Bundle, error)
}

type BundleExtractorOpt func(e *DefaultBundleExtractor)

type DefaultBundleExtractor struct {
	Log     logrus.FieldLogger
	Cache   BundleCache
	Timeout time.Duration
}

type DefaultIndexExtractor struct {
	Log   logrus.FieldLogger
	Cache IndexCache
}

type Extractor interface {
	// extract all bundles from indexImage matching pkgName
	ExtractBundles(ctx context.Context, indexImage string, pkgName string) ([]operator.Bundle, error)
	// extract all bundles from indexImage, for all packages
	ExtractAllBundles(ctx context.Context, indexImage string) ([]operator.Bundle, error)
}

type IndexCache interface {
	// GetBundleImages retrieves bundles image names for a particular
	// indexImage and package combination.
	GetBundleImages(indexImage string, pkgName string) ([]string, error)
	// SetBundleImages stores a map from package name to bundle images
	// for a particular indexImage. An error is returned if the data
	// cannot be written.
	SetBundleImages(indexImage string, bundleImagesMap map[string][]string) error
}

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

type IndexCacheImplConfig struct {
	Store Store
}

type IndexCacheImplOption interface {
	ConfigureIndexCacheImpl(*IndexCacheImplConfig)
}

type IndexExtractor interface {
	// extract all bundleImages contained in indexImage, matching pkgName
	ExtractBundleImages(ctx context.Context, indexImage string, pkgName string) ([]string, error)
	// extract all bundleImages contained in the indexImage, for all packages.
	ExtractAllBundleImages(ctx context.Context, indexImage string) ([]string, error)
}

type IndexExtractorOpt func(e *DefaultIndexExtractor)

type MainExtractor struct {
	Log    logrus.FieldLogger
	Index  IndexExtractor
	Bundle BundleExtractor
}

type MainExtractorOpt func(e *MainExtractor)

type Store interface {
	// Read retrieves data with a given id. 'ok'
	// returns false if the id does not exist.
	Read(id interface{}) (data interface{}, ok bool)
	// Write sets the given data for the given id.
	// An error should be returned if the data
	// could not be applied successfully.
	Write(id, data interface{}) error
}

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

type WithStore struct{ Store }