provider

Documentation

Index

• type PackageManifestProvider
• type RegistryProvider
  • func NewRegistryProvider(crClient versioned.Interface, operator *queueinformer.Operator, ...) *RegistryProvider
  • func (p *RegistryProvider) Get(namespace, name string) (*operators.PackageManifest, error)
  • func (p *RegistryProvider) List(namespace string) (*operators.PackageManifestList, error)

Types

type PackageManifestProvider

type PackageManifestProvider interface {
	Get(name, namespace string) (*operators.PackageManifest, error)
	List(namespace string) (*operators.PackageManifestList, error)
}

type RegistryProvider

type RegistryProvider struct {
	*queueinformer.Operator
	// contains filtered or unexported fields
}

RegistryProvider aggregates several `CatalogSources` and establishes gRPC connections to their registry servers.

func NewRegistryProvider

func NewRegistryProvider(crClient versioned.Interface, operator *queueinformer.Operator, wakeupInterval time.Duration, watchedNamespaces []string, globalNamespace string) *RegistryProvider

func (*RegistryProvider) Get

func (p *RegistryProvider) Get(namespace, name string) (*operators.PackageManifest, error)

func (*RegistryProvider) List

func (p *RegistryProvider) List(namespace string) (*operators.PackageManifestList, error)