entitysources

type CatalogdEntitySource ¶ added in v0.3.0

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

CatalogdEntitySource is a source for(/collection of) deppy defined input.Entity, built from content made accessible on-cluster by https://github.com/operator-framework/catalogd. It is an implementation of deppy defined input.EntitySource

func NewCatalogdEntitySource(client client.Client) *CatalogdEntitySource

func (es *CatalogdEntitySource) Filter(ctx context.Context, filter input.Predicate) (input.EntityList, error)

func (es *CatalogdEntitySource) Get(_ context.Context, _ deppy.Identifier) (*input.Entity, error)

func (es *CatalogdEntitySource) GroupBy(ctx context.Context, fn input.GroupByFunction) (input.EntityListMap, error)

func (es *CatalogdEntitySource) Iterate(ctx context.Context, fn input.IteratorFunction) error