cache

Documentation

Index

• func NewKubeCoreCache(ctx context.Context, client kubernetes.Interface) (*kubeCoreCaches, error)
• func NewKubeDeploymentCache(ctx context.Context, client kubernetes.Interface) (*kubeDeploymentCache, error)
• type Cache
• type KubeCoreCache
• type KubeDeploymentCache

Functions

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 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 KubeCoreCache

type KubeCoreCache interface {
	Cache
	PodLister() kubelisters.PodLister
	ServiceLister() kubelisters.ServiceLister
	ConfigMapLister() kubelisters.ConfigMapLister
	SecretLister() kubelisters.SecretLister
	NamespaceLister() kubelisters.NamespaceLister
}

type KubeDeploymentCache

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