provider

Documentation

Index

• Constants
• func PackageManifestKeyFunc(obj interface{}) (string, error)
• func SplitPackageManifestKey(key string) (catsrcname, namespace, name string, err error)
• type PackageManifestProvider
• type RegistryProvider
  • func NewRegistryProvider(ctx context.Context, crClient versioned.Interface, ...) (*RegistryProvider, error)
  • func (p *RegistryProvider) Get(namespace, name string) (*operators.PackageManifest, error)
  • func (p *RegistryProvider) List(namespace string, selector labels.Selector) (*operators.PackageManifestList, error)
  • func (p *RegistryProvider) Run(ctx context.Context)

Constants

const (
	OsLabelPrefix    = "operatorframework.io/os"
	ArchLabelPrefix  = "operatorframework.io/arch"
	DefaultOsLabel   = "operatorframework.io/os.linux"
	DefaultArchLabel = "operatorframework.io/arch.amd64"
	Supported        = "supported"
)

Functions

func PackageManifestKeyFunc

func PackageManifestKeyFunc(obj interface{}) (string, error)

func SplitPackageManifestKey

func SplitPackageManifestKey(key string) (catsrcname, namespace, name string, err error)

Types

type PackageManifestProvider

type PackageManifestProvider interface {
	Get(namespace, name string) (*operators.PackageManifest, error)
	List(namespace string, selector labels.Selector) (*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(ctx context.Context, crClient versioned.Interface, operator queueinformer.Operator, wakeupInterval time.Duration, globalNamespace string) (*RegistryProvider, error)

func (*RegistryProvider) Get

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

func (*RegistryProvider) List

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

func (*RegistryProvider) Run

func (p *RegistryProvider) Run(ctx context.Context)

Run starts the provider's source connection management and catalog informers without blocking.