cache

Documentation

Index

• func NewCoreCacheForConfig(ctx context.Context, cluster string, restConfig *rest.Config) clustercache.ClusterCache
• func NewDeploymentCacheFromConfig(ctx context.Context, cluster string, restConfig *rest.Config) clustercache.ClusterCache
• func NewFromConfigWithOptions(resyncDuration time.Duration, namesapcesToWatch []string) clustercache.NewClusterCacheForConfig
• func NewKubeCoreCache(ctx context.Context, client kubernetes.Interface) (*kubeCoreCaches, error)
• func NewKubeCoreCacheWithOptions(ctx context.Context, client kubernetes.Interface, resyncDuration time.Duration, ...) (*kubeCoreCaches, error)
• func NewKubeDeploymentCache(ctx context.Context, client kubernetes.Interface) (*kubeDeploymentCache, error)
• type Cache
• type ConfigMapLister
• type KubeCoreCache
• type KubeDeploymentCache
• type PodLister
• type SecretLister
• type ServiceLister

Functions

func NewCoreCacheForConfig

func NewCoreCacheForConfig(ctx context.Context, cluster string, restConfig *rest.Config) clustercache.ClusterCache

func NewDeploymentCacheFromConfig

func NewDeploymentCacheFromConfig(ctx context.Context, cluster string, restConfig *rest.Config) clustercache.ClusterCache

func NewFromConfigWithOptions

func NewFromConfigWithOptions(resyncDuration time.Duration, namesapcesToWatch []string) clustercache.NewClusterCacheForConfig

func NewKubeCoreCache

func NewKubeCoreCache(ctx context.Context, client kubernetes.Interface) (*kubeCoreCaches, error)

This context should live as long as the cache is desired. i.e. if the cache is shared across clients, it should get a context that has a longer lifetime than the clients themselves

func NewKubeCoreCacheWithOptions

func NewKubeCoreCacheWithOptions(ctx context.Context, client kubernetes.Interface, resyncDuration time.Duration, namesapcesToWatch []string) (*kubeCoreCaches, error)

func NewKubeDeploymentCache

func NewKubeDeploymentCache(ctx context.Context, client kubernetes.Interface) (*kubeDeploymentCache, error)

This context should live as long as the cache is desired. i.e. if the cache is shared across clients, it should get a context that has a longer lifetime than the clients themselves

Types

type Cache

type Cache interface {
	Subscribe() <-chan struct{}
	Unsubscribe(<-chan struct{})
}

type ConfigMapLister

type ConfigMapLister interface {
	// List lists all ConfigMaps in the indexer.
	List(selector labels.Selector) (ret []*v1.ConfigMap, err error)
}

type KubeCoreCache

type KubeCoreCache interface {
	Cache
	clustercache.ClusterCache

	// Deprecated: Use NamespacedPodLister instead
	PodLister() kubelisters.PodLister
	// Deprecated: Use NamespacedServiceLister instead
	ServiceLister() kubelisters.ServiceLister
	// Deprecated: Use NamespacedConfigMapLister instead
	ConfigMapLister() kubelisters.ConfigMapLister
	// Deprecated: Use NamespacedSecretLister instead
	SecretLister() kubelisters.SecretLister

	NamespaceLister() kubelisters.NamespaceLister

	NamespacedPodLister(ns string) PodLister
	NamespacedServiceLister(ns string) ServiceLister
	NamespacedConfigMapLister(ns string) ConfigMapLister
	NamespacedSecretLister(ns string) SecretLister
}

type KubeDeploymentCache

type KubeDeploymentCache interface {
	clustercache.ClusterCache
	DeploymentLister() kubelisters.DeploymentLister
	Subscribe() <-chan struct{}
	Unsubscribe(<-chan struct{})
}

type PodLister

type PodLister interface {
	// List lists all Pods in the indexer.
	List(selector labels.Selector) (ret []*v1.Pod, err error)
}

type SecretLister

type SecretLister interface {
	// List lists all Secrets in the indexer.
	List(selector labels.Selector) (ret []*v1.Secret, err error)
}

type ServiceLister

type ServiceLister interface {
	// List lists all Services in the indexer.
	List(selector labels.Selector) (ret []*v1.Service, err error)
}