cache

package

Go to main page

Versions in this module

v0

v0.28.0

May 16, 2024

v0.27.0

Feb 20, 2024

Changes in this version

+ type Deprecations struct

+ Bundle *api.Deprecation

+ Channel *api.Deprecation

+ Package *api.Deprecation

type OperatorSourceInfo

+ Deprecations *Deprecations

v0.26.0

Oct 30, 2023

v0.25.0

Jun 12, 2023

v0.24.0

Mar 8, 2023

v0.23.1

Jan 12, 2023

v0.23.0

Dec 19, 2022

v0.22.0

Aug 10, 2022

v0.21.2

May 11, 2022

v0.21.1

Apr 29, 2022

v0.21.0

Apr 29, 2022

Changes in this version

+ func ValidOnce() <-chan struct

type Option

+ func WithSourcePriorityProvider(spp SourcePriorityProvider) Option

type Snapshot

+ Valid <-chan struct{}

+ type SourcePriorityProvider interface

+ Priority func(SourceKey) int

v0.20.0

Jan 7, 2022

Changes in this version

+ type Entry struct

+ Bundle *api.Bundle

+ BundlePath string

+ Name string

+ Properties []*api.Property

+ ProvidedAPIs APISet

+ Replaces string

+ RequiredAPIs APISet

+ SkipRange semver.Range

+ Skips []string

+ SourceInfo *OperatorSourceInfo

+ Version *semver.Version

+ func (o *Entry) Channel() string

+ func (o *Entry) Package() string

+ type Predicate interface

+ String func() string

+ Test func(*Entry) bool

+ func CreateCelPredicate(env *constraints.CelEnvironment, rule string, message string) (Predicate, error)

+ func Not(p ...Predicate) Predicate

v0.19.1

Sep 24, 2021

v0.19.0

Sep 8, 2021

Changes in this version

+ var ExistingOperator = OperatorSourceInfo

+ var NoCatalog = SourceKey

+ func APIKeyToGVKHash(key opregistry.APIKey) (string, error)

+ func APIKeyToGVKString(key opregistry.APIKey) string

+ func Matches(o *Operator, p ...OperatorPredicate) bool

+ type APIMultiOwnerSet map[opregistry.APIKey]OperatorSet

+ func EmptyAPIMultiOwnerSet() APIMultiOwnerSet

+ func (s APIMultiOwnerSet) PopAPIKey() *opregistry.APIKey

+ func (s APIMultiOwnerSet) PopAPIRequirers() OperatorSet

+ type APIOwnerSet map[opregistry.APIKey]*Operator

+ func EmptyAPIOwnerSet() APIOwnerSet

+ type APISet map[opregistry.APIKey]struct

+ func EmptyAPISet() APISet

+ func GVKStringToProvidedAPISet(gvksStr string) APISet

+ func (s APISet) Difference(set APISet) APISet

+ func (s APISet) Intersection(sets ...APISet) APISet

+ func (s APISet) IsSubset(set APISet) bool

+ func (s APISet) PopAPIKey() *opregistry.APIKey

+ func (s APISet) String() string

+ func (s APISet) StripPlural() APISet

+ func (s APISet) Union(sets ...APISet) APISet

+ type Cache struct

+ func New(sp SourceProvider, options ...Option) *Cache

+ func (c *Cache) Expire(catalog SourceKey)

+ func (c *Cache) Namespaced(namespaces ...string) MultiCatalogOperatorFinder

+ type EmptyOperatorFinder struct

+ func (f EmptyOperatorFinder) Find(...OperatorPredicate) []*Operator

+ type MultiCatalogOperatorFinder interface

+ Catalog func(SourceKey) OperatorFinder

+ Error func() error

+ FindPreferred func(preferred *SourceKey, preferredNamespace string, ...) []*Operator

+ WithExistingOperators func(snapshot *Snapshot, namespace string) MultiCatalogOperatorFinder

+ type NamespacedOperatorCache struct

+ func (c *NamespacedOperatorCache) Catalog(k SourceKey) OperatorFinder

+ func (c *NamespacedOperatorCache) Error() error

+ func (c *NamespacedOperatorCache) Find(p ...OperatorPredicate) []*Operator

+ func (c *NamespacedOperatorCache) FindPreferred(preferred *SourceKey, preferredNamespace string, p ...OperatorPredicate) []*Operator

+ func (c *NamespacedOperatorCache) WithExistingOperators(snapshot *Snapshot, namespace string) MultiCatalogOperatorFinder

+ type Operator struct

+ Bundle *api.Bundle

+ BundlePath string

+ Name string

+ Properties []*api.Property

+ ProvidedAPIs APISet

+ Replaces string

+ RequiredAPIs APISet

+ SkipRange semver.Range

+ Skips []string

+ SourceInfo *OperatorSourceInfo

+ Version *semver.Version

+ func AtLeast(n int, operators []*Operator) ([]*Operator, error)

+ func ExactlyOne(operators []*Operator) (*Operator, error)

+ func Filter(operators []*Operator, p ...OperatorPredicate) []*Operator

+ func (o *Operator) Channel() string

+ func (o *Operator) Package() string

+ type OperatorCacheProvider interface

+ Expire func(catalog SourceKey)

+ Namespaced func(namespaces ...string) MultiCatalogOperatorFinder

+ type OperatorFinder interface

+ Find func(...OperatorPredicate) []*Operator

+ type OperatorPredicate interface

+ String func() string

+ Test func(*Operator) bool

+ func And(p ...OperatorPredicate) OperatorPredicate

+ func BooleanPredicate(result bool) OperatorPredicate

+ func CSVNamePredicate(name string) OperatorPredicate

+ func CatalogPredicate(key SourceKey) OperatorPredicate

+ func ChannelPredicate(channel string) OperatorPredicate

+ func CountingPredicate(p OperatorPredicate, n *int) OperatorPredicate

+ func False() OperatorPredicate

+ func LabelPredicate(label string) OperatorPredicate

+ func Or(p ...OperatorPredicate) OperatorPredicate

+ func PkgPredicate(pkg string) OperatorPredicate

+ func ProvidingAPIPredicate(api opregistry.APIKey) OperatorPredicate

+ func ReplacesPredicate(replaces string) OperatorPredicate

+ func SkipRangeIncludesPredicate(version semver.Version) OperatorPredicate

+ func True() OperatorPredicate

+ func VersionInRangePredicate(r semver.Range, version string) OperatorPredicate

+ type OperatorSet map[string]*Operator

+ func EmptyOperatorSet() OperatorSet

+ func (o OperatorSet) Snapshot() OperatorSet

+ type OperatorSourceInfo struct

+ Catalog SourceKey

+ Channel string

+ DefaultChannel bool

+ Package string

+ StartingCSV string

+ Subscription *v1alpha1.Subscription

+ func (i *OperatorSourceInfo) String() string

+ type Option func(*Cache)

+ func WithCatalogSourceLister(catalogSourceLister v1alpha1.CatalogSourceLister) Option

+ func WithLogger(logger logrus.StdLogger) Option

+ type Snapshot struct

+ Entries []*Operator

+ func (s *Snapshot) Snapshot(context.Context) (*Snapshot, error)

+ type Source interface

+ Snapshot func(context.Context) (*Snapshot, error)

+ type SourceKey struct

+ Name string

+ Namespace string

+ func NewVirtualSourceKey(namespace string) SourceKey

+ func (k *SourceKey) Empty() bool

+ func (k *SourceKey) Equal(compare SourceKey) bool

+ func (k *SourceKey) String() string

+ func (k *SourceKey) Virtual() bool

+ type SourceProvider interface

+ Sources func(namespaces ...string) map[SourceKey]Source

+ type StaticSourceProvider map[SourceKey]Source

+ func (p StaticSourceProvider) Sources(namespaces ...string) map[SourceKey]Source

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL