entitysources

Documentation

Index

• func MetadataToEntities(catalogName string, channels []declcfg.Channel, bundles []declcfg.Bundle) (input.EntityList, error)
• type CatalogdEntitySource
  • 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

Functions

func MetadataToEntities

func MetadataToEntities(catalogName string, channels []declcfg.Channel, bundles []declcfg.Bundle) (input.EntityList, error)

Types

type CatalogdEntitySource

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

func NewCatalogdEntitySource(client client.Client) *CatalogdEntitySource

func (*CatalogdEntitySource) Filter

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

func (*CatalogdEntitySource) Get

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

func (*CatalogdEntitySource) GroupBy

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

func (*CatalogdEntitySource) Iterate

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