resolver

package
v0.19.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 8, 2021 License: Apache-2.0 Imports: 40 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	BundleLookupConditionPacked v1alpha1.BundleLookupConditionType = "BundleLookupNotPersisted"
)
View Source 
const (
	BundleSecretKind = "BundleSecret"
)

Variables

This section is empty.

Functions

func DependencyPredicates added in v0.19.0 

func DependencyPredicates(properties []*api.Property) ([]cache.OperatorPredicate, error)

func EnsurePackageProperty added in v0.19.0 

func EnsurePackageProperty(o *cache.Operator, name, version string)

func NewInvalidSubscriptionInstallable added in v0.18.0 

func NewInvalidSubscriptionInstallable(name string, reason string) solver.Installable

func NewServiceAccountStepResources 

func NewServiceAccountStepResources(csv *v1alpha1.ClusterServiceVersion, catalogSourceName, catalogSourceNamespace string) ([]v1alpha1.StepResource, error)

NewServiceAccountStepResources returns a list of step resources required to satisfy the RBAC requirements of the given CSV's InstallStrategy

func NewSingleAPIProviderInstallable added in v0.18.0 

func NewSingleAPIProviderInstallable(group, version, kind string, providers []solver.Identifier) solver.Installable

func NewSinglePackageInstanceInstallable added in v0.18.0 

func NewSinglePackageInstanceInstallable(pkg string, providers []solver.Identifier) solver.Installable

func NewStepResourceFromBundle 

func NewStepResourceFromBundle(bundle *api.Bundle, namespace, replaces, catalogSourceName, catalogSourceNamespace string) ([]v1alpha1.StepResource, error)

func NewStepResourceFromObject 

func NewStepResourceFromObject(obj runtime.Object, catalogSourceName, catalogSourceNamespace string) (v1alpha1.StepResource, error)

NewStepResourceForObject returns a new StepResource for the provided object

func NewStepsFromBundle 

func NewStepsFromBundle(bundle *api.Bundle, namespace, replaces, catalogSourceName, catalogSourceNamespace string) ([]*v1alpha1.Step, error)

func NewSubscriptionInstallable 

func NewSubscriptionInstallable(name string, dependencies []solver.Identifier) solver.Installable

func NewSubscriptionStepResource 

func NewSubscriptionStepResource(namespace string, info cache.OperatorSourceInfo) (v1alpha1.StepResource, error)

func PrettyConstraint added in v0.18.0 

func PrettyConstraint(c solver.Constraint, msg string) solver.Constraint

func RBACForClusterServiceVersion 

func RBACForClusterServiceVersion(csv *v1alpha1.ClusterServiceVersion) (map[string]*OperatorPermissions, error)

func SourceProviderFromRegistryClientProvider added in v0.19.0 

func SourceProviderFromRegistryClientProvider(rcp RegistryClientProvider, logger logrus.StdLogger) cache.SourceProvider

func V1alpha1CSVFromBundle 

func V1alpha1CSVFromBundle(bundle *api.Bundle) (*v1alpha1.ClusterServiceVersion, error)

Types

type BundleInstallable 

type BundleInstallable struct {
	Replaces string
	// contains filtered or unexported fields
}

func NewBundleInstallableFromOperator added in v0.18.2 

func NewBundleInstallableFromOperator(o *cache.Operator) (BundleInstallable, error)

func (*BundleInstallable) AddConflict 

func (i *BundleInstallable) AddConflict(id solver.Identifier)

func (*BundleInstallable) AddConstraint added in v0.19.0 

func (i *BundleInstallable) AddConstraint(c solver.Constraint)

func (*BundleInstallable) BundleSourceInfo 

func (i *BundleInstallable) BundleSourceInfo() (string, string, cache.SourceKey, error)

func (BundleInstallable) Constraints 

func (i BundleInstallable) Constraints() []solver.Constraint

func (BundleInstallable) Identifier 

func (i BundleInstallable) Identifier() solver.Identifier

func (*BundleInstallable) MakeProhibited 

func (i *BundleInstallable) MakeProhibited()

type GenericInstallable added in v0.18.0 

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

func (GenericInstallable) Constraints added in v0.18.0 

func (i GenericInstallable) Constraints() []solver.Constraint

func (GenericInstallable) Identifier added in v0.18.0 

func (i GenericInstallable) Identifier() solver.Identifier

type InstrumentedResolver 

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

func NewInstrumentedResolver 

func NewInstrumentedResolver(resolver StepResolver, successMetricsEmitter, failureMetricsEmitter func(time.Duration)) *InstrumentedResolver

func (*InstrumentedResolver) Expire 

func (ir *InstrumentedResolver) Expire(key cache.SourceKey)

func (*InstrumentedResolver) ResolveSteps 

func (ir *InstrumentedResolver) ResolveSteps(namespace string) ([]*v1alpha1.Step, []v1alpha1.BundleLookup, []*v1alpha1.Subscription, error)

type OperatorPermissions 

type OperatorPermissions struct {
	ServiceAccount      *corev1.ServiceAccount
	Roles               []*rbacv1.Role
	RoleBindings        []*rbacv1.RoleBinding
	ClusterRoles        []*rbacv1.ClusterRole
	ClusterRoleBindings []*rbacv1.ClusterRoleBinding
}

func NewOperatorPermissions 

func NewOperatorPermissions(serviceAccount *corev1.ServiceAccount) *OperatorPermissions

func (*OperatorPermissions) AddClusterRole 

func (o *OperatorPermissions) AddClusterRole(clusterRole *rbacv1.ClusterRole)

func (*OperatorPermissions) AddClusterRoleBinding 

func (o *OperatorPermissions) AddClusterRoleBinding(clusterRoleBinding *rbacv1.ClusterRoleBinding)

func (*OperatorPermissions) AddRole 

func (o *OperatorPermissions) AddRole(role *rbacv1.Role)

func (*OperatorPermissions) AddRoleBinding 

func (o *OperatorPermissions) AddRoleBinding(roleBinding *rbacv1.RoleBinding)

type OperatorResolver 

type OperatorResolver interface {
	SolveOperators(csvs []*v1alpha1.ClusterServiceVersion, subs []*v1alpha1.Subscription, add map[cache.OperatorSourceInfo]struct{}) (cache.OperatorSet, error)
}

type OperatorStepResolver 

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

func NewOperatorStepResolver 

func NewOperatorStepResolver(lister operatorlister.OperatorLister, client versioned.Interface, kubeclient kubernetes.Interface,
	globalCatalogNamespace string, provider RegistryClientProvider, log logrus.FieldLogger) *OperatorStepResolver

func (*OperatorStepResolver) Expire 

func (r *OperatorStepResolver) Expire(key cache.SourceKey)

func (*OperatorStepResolver) ResolveSteps 

func (r *OperatorStepResolver) ResolveSteps(namespace string) ([]*v1alpha1.Step, []v1alpha1.BundleLookup, []*v1alpha1.Subscription, error)

type RegistryClientProvider 

type RegistryClientProvider interface {
	ClientsForNamespaces(namespaces ...string) map[registry.CatalogKey]client.Interface
}

type SatResolver 

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

func NewDefaultSatResolver 

func NewDefaultSatResolver(rcp cache.SourceProvider, catsrcLister v1alpha1listers.CatalogSourceLister, logger logrus.FieldLogger) *SatResolver

func (*SatResolver) SolveOperators 

func (r *SatResolver) SolveOperators(namespaces []string, csvs []*v1alpha1.ClusterServiceVersion, subs []*v1alpha1.Subscription) (cache.OperatorSet, error)

type StepResolver 

type StepResolver interface {
	ResolveSteps(namespace string) ([]*v1alpha1.Step, []v1alpha1.BundleLookup, []*v1alpha1.Subscription, error)
	Expire(key cache.SourceKey)
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳