Help us shape the future of Go! Take the 2026 Go Developer Survey

resolver

package
v0.20.0 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2022 License: Apache-2.0 Imports: 41 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 EnsurePackageProperty added in v0.19.0 

func EnsurePackageProperty(o *cache.Entry, 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.Entry) (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
Code generated by counterfeiter.
 Code generated by counterfeiter.

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.