Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetFilteredCache ¶
func GetFilteredCache(namespace string, podSelector labels.Selector, syncPeriod *time.Duration) cache.NewCacheFunc
GetFilteredCache creates a cache that slims down resources to the minimum that is needed for processing and also acts as a sinkhole for deployment/statefulsets/pods that are not going to be processed but that cannot be filtered by labels to limit what items end up in the cache. The following is removed/clear from the resources: - pods -> managed fields, status (we care for spec to find out containers, the rests are set to empty) - deploy/sts -> template.spec, status, managedfields (we only care about template/metadata except for injector deployment)
func NewPodMetadataCache ¶ added in v1.18.2
func NewPodMetadataCache(podOpts PodMetadataCacheOptions) (ctrlcache.Cache, error)
NewPodMetadataCache returns a cache that watches only pod metadata (no spec or status), retaining just the dapr.io/* annotations of Dapr annotated pods and sinkholing everything else. It is used to resolve, server side, which configuration is assigned to a connecting sidecar from its pod's dapr.io/config annotation, without holding full pod objects in memory.
func PodMetadataPodGVKObject ¶ added in v1.18.2
func PodMetadataPodGVKObject() *metav1.PartialObjectMetadata
PodMetadataPodGVKObject returns a typed object identifying the Pod resource for a metadata-only informer.
Types ¶
type PodMetadataCacheOptions ¶ added in v1.18.2
type PodMetadataCacheOptions struct {
RestConfig *rest.Config
Namespace string
SyncPeriod *time.Duration
// HTTPClient and Mapper are reused from the operator manager to avoid a second
// round of API discovery (an expensive REST mapper build) per operator.
HTTPClient *http.Client
Mapper meta.RESTMapper
}
PodMetadataCacheOptions are the options for NewPodMetadataCache.
Source Files