indexers

Documentation

Index

• Constants
• func APIBindingBoundResourceValue(clusterName logicalcluster.Name, group, resource string) string
• func AddIfNotPresentOrDie(indexer cache.Indexer, toAdd cache.Indexers)
• func Append(indexers ...cache.Indexers) (cache.Indexers, error)
• func AppendOrDie(indexers ...cache.Indexers) cache.Indexers
• func ByIndex[T runtime.Object](indexer cache.Indexer, indexName, indexValue string) ([]T, error)
• func ByPathAndName[T runtime.Object](groupResource schema.GroupResource, indexer cache.Indexer, ...) (ret T, err error)
• func ClusterAndGroupResourceValue(clusterName logicalcluster.Name, groupResource schema.GroupResource) string
• func IndexAPIBindingByAPIExport(obj interface{}) ([]string, error)
• func IndexAPIBindingByBoundResourceUID(obj interface{}) ([]string, error)
• func IndexAPIBindingByBoundResources(obj interface{}) ([]string, error)
• func IndexAPIBindingByClusterAndAcceptedClaimedGroupResources(obj interface{}) ([]string, error)
• func IndexAPIExportByClaimedIdentities(obj interface{}) ([]string, error)
• func IndexAPIExportByIdentity(obj interface{}) ([]string, error)
• func IndexAPIExportBySecret(obj interface{}) ([]string, error)
• func IndexByClusterResourceStateLabelKey(obj interface{}) ([]string, error)
• func IndexByLogicalClusterPath(obj interface{}) ([]string, error)
• func IndexByLogicalClusterPathAndName(obj interface{}) ([]string, error)
• func IndexBySyncerFinalizerKey(obj interface{}) ([]string, error)
• func IndexSyncTargetsBySyncTargetKey(obj interface{}) ([]string, error)

Constants

const (
	// APIExportByIdentity is the indexer name for retrieving APIExports by identity hash.
	APIExportByIdentity = "APIExportByIdentity"
	// APIExportBySecret is the indexer name for retrieving APIExports by secret.
	APIExportBySecret = "APIExportSecret"
	// APIExportByClaimedIdentities is the indexer name for retrieving APIExports that have a permission claim for a
	// particular identity hash.
	APIExportByClaimedIdentities = "APIExportByClaimedIdentities"
)

const (
	// BySyncerFinalizerKey is the name for the index that indexes by syncer finalizer label keys.
	BySyncerFinalizerKey = "bySyncerFinalizerKey"
	// APIBindingByClusterAndAcceptedClaimedGroupResources is the name for the index that indexes an APIBinding by its
	// cluster name and accepted claimed group resources.
	APIBindingByClusterAndAcceptedClaimedGroupResources = "byClusterAndAcceptedClaimedGroupResources"
	// ByClusterResourceStateLabelKey indexes resources based on the cluster state label key.
	ByClusterResourceStateLabelKey = "ByClusterResourceStateLabelKey"
	// ByLogicalClusterPath indexes by logical cluster path, if the annotation exists.
	ByLogicalClusterPath = "ByLogicalClusterPath"
	// ByLogicalClusterPathAndName indexes by logical cluster path and object name, if the annotation exists.
	ByLogicalClusterPathAndName = "ByLogicalClusterPathAndName"
)

const APIBindingByBoundResourceUID = "byBoundResourceUID"

const APIBindingByBoundResources = "byBoundResources"

const APIBindingsByAPIExport = "APIBindingByAPIExport"

const (
	SyncTargetsBySyncTargetKey = "SyncTargetsBySyncTargetKey"
)

Functions

func APIBindingBoundResourceValue

func APIBindingBoundResourceValue(clusterName logicalcluster.Name, group, resource string) string

func AddIfNotPresentOrDie

func AddIfNotPresentOrDie(indexer cache.Indexer, toAdd cache.Indexers)

AddIfNotPresentOrDie tries to add everything from toAdd to indexer's indexers that does not already exist. It panics if it encounters an error.

func Append

func Append(indexers ...cache.Indexers) (cache.Indexers, error)

Append is a helper function that merged a set of indexers.

func AppendOrDie

func AppendOrDie(indexers ...cache.Indexers) cache.Indexers

func ByIndex

func ByIndex[T runtime.Object](indexer cache.Indexer, indexName, indexValue string) ([]T, error)

ByIndex returns all instances of T that match indexValue in indexName in indexer.

func ByPathAndName

func ByPathAndName[T runtime.Object](groupResource schema.GroupResource, indexer cache.Indexer, path logicalcluster.Path, name string) (ret T, err error)

ByPathAndName returns the instance of T from the indexer with the matching path and name. Path may be a canonical path or a cluster name. Note: this depends on the presence of the optional "kcp.io/path" annotation.

func ClusterAndGroupResourceValue

func ClusterAndGroupResourceValue(clusterName logicalcluster.Name, groupResource schema.GroupResource) string

ClusterAndGroupResourceValue returns the index value for use with IndexAPIBindingByClusterAndAcceptedClaimedGroupResources from clusterName and groupResource.

func IndexAPIBindingByAPIExport

func IndexAPIBindingByAPIExport(obj interface{}) ([]string, error)

IndexAPIBindingByAPIExport indexes the APIBindings by their APIExport's Reference Path and Name.

func IndexAPIBindingByBoundResourceUID

func IndexAPIBindingByBoundResourceUID(obj interface{}) ([]string, error)

func IndexAPIBindingByBoundResources

func IndexAPIBindingByBoundResources(obj interface{}) ([]string, error)

func IndexAPIBindingByClusterAndAcceptedClaimedGroupResources

func IndexAPIBindingByClusterAndAcceptedClaimedGroupResources(obj interface{}) ([]string, error)

IndexAPIBindingByClusterAndAcceptedClaimedGroupResources is an index function that indexes an APIBinding by its accepted permission claims' group resources.

func IndexAPIExportByClaimedIdentities

func IndexAPIExportByClaimedIdentities(obj interface{}) ([]string, error)

IndexAPIExportByClaimedIdentities is an index function that indexes an APIExport by its permission claims' identity hashes.

func IndexAPIExportByIdentity

func IndexAPIExportByIdentity(obj interface{}) ([]string, error)

IndexAPIExportByIdentity is an index function that indexes an APIExport by its identity hash.

func IndexAPIExportBySecret

func IndexAPIExportBySecret(obj interface{}) ([]string, error)

IndexAPIExportBySecret is an index function that indexes an APIExport by its identity secret references. Index values are of the form <cluster name>|<secret reference namespace>/<secret reference name> (cache keys).

func IndexByClusterResourceStateLabelKey

func IndexByClusterResourceStateLabelKey(obj interface{}) ([]string, error)

IndexByClusterResourceStateLabelKey indexes resources based on the cluster state key label.

func IndexByLogicalClusterPath

func IndexByLogicalClusterPath(obj interface{}) ([]string, error)

IndexByLogicalClusterPath indexes by logical cluster path, if the annotation exists.

func IndexByLogicalClusterPathAndName

func IndexByLogicalClusterPathAndName(obj interface{}) ([]string, error)

IndexByLogicalClusterPathAndName indexes by logical cluster path and object name, if the annotation exists.

func IndexBySyncerFinalizerKey

func IndexBySyncerFinalizerKey(obj interface{}) ([]string, error)

IndexBySyncerFinalizerKey indexes by syncer finalizer label keys.

func IndexSyncTargetsBySyncTargetKey

func IndexSyncTargetsBySyncTargetKey(obj interface{}) ([]string, error)