shared

Documentation

Overview

Package shared provides reusable support for shared informer implementations.

Index

• type BuildConfigInformer
• type ClusterPolicyBindingInformer
• type ClusterPolicyInformer
• type ClusterResourceQuotaInformer
• type DefaultListerWatcherOverrides
  • func (o DefaultListerWatcherOverrides) GetListerWatcher(resource unversioned.GroupResource) cache.ListerWatcher
• type DeploymentConfigInformer
• type ImageStreamInformer
• type InformerFactory
  • func NewInformerFactory(kubeClient kclient.Interface, originClient oclient.Interface, ...) InformerFactory
• type LimitRangeInformer
• type ListerWatcherOverrides
• type NamespaceInformer
• type NodeInformer
• type PersistentVolumeClaimInformer
• type PersistentVolumeInformer
• type PodInformer
• type PolicyBindingInformer
• type PolicyInformer
• type ReplicationControllerInformer
• type SecurityContextConstraintsInformer
• type ServiceAccountInformer
• type StoreToLimitRangeLister
  • func (s StoreToLimitRangeLister) LimitRanges(namespace string) storeLimitRangesNamespacer

Types

type BuildConfigInformer

type BuildConfigInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() oscache.StoreToBuildConfigLister
}

type ClusterPolicyBindingInformer

type ClusterPolicyBindingInformer interface {
	Informer() framework.SharedIndexInformer
	// still use an indexer, no telling what someone will want to index on someday
	Indexer() cache.Indexer
	Lister() client.SyncedClusterPolicyBindingsListerInterface
}

type ClusterPolicyInformer

type ClusterPolicyInformer interface {
	Informer() framework.SharedIndexInformer
	// still use an indexer, no telling what someone will want to index on someday
	Indexer() cache.Indexer
	Lister() client.SyncedClusterPoliciesListerInterface
}

type ClusterResourceQuotaInformer

type ClusterResourceQuotaInformer interface {
	Informer() framework.SharedIndexInformer
	// still use an indexer, no telling what someone will want to index on someday
	Indexer() cache.Indexer
	Lister() *ocache.IndexerToClusterResourceQuotaLister
}

type DefaultListerWatcherOverrides

type DefaultListerWatcherOverrides map[unversioned.GroupResource]cache.ListerWatcher

func (DefaultListerWatcherOverrides) GetListerWatcher

func (o DefaultListerWatcherOverrides) GetListerWatcher(resource unversioned.GroupResource) cache.ListerWatcher

type DeploymentConfigInformer

type DeploymentConfigInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *oscache.StoreToDeploymentConfigLister
}

type ImageStreamInformer

type ImageStreamInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *oscache.StoreToImageStreamLister
}

type InformerFactory

type InformerFactory interface {
	// Start starts informers that can start AFTER the API server and controllers have started
	Start(stopCh <-chan struct{})
	// StartCore starts core informers that must initialize in order for the API server to start
	StartCore(stopCh <-chan struct{})

	Pods() PodInformer
	Namespaces() NamespaceInformer
	Nodes() NodeInformer
	PersistentVolumes() PersistentVolumeInformer
	PersistentVolumeClaims() PersistentVolumeClaimInformer
	ReplicationControllers() ReplicationControllerInformer
	LimitRanges() LimitRangeInformer

	ClusterPolicies() ClusterPolicyInformer
	ClusterPolicyBindings() ClusterPolicyBindingInformer
	Policies() PolicyInformer
	PolicyBindings() PolicyBindingInformer

	DeploymentConfigs() DeploymentConfigInformer
	BuildConfigs() BuildConfigInformer
	ImageStreams() ImageStreamInformer
	SecurityContextConstraints() SecurityContextConstraintsInformer
	ClusterResourceQuotas() ClusterResourceQuotaInformer
	ServiceAccounts() ServiceAccountInformer

	KubernetesInformers() informers.SharedInformerFactory
}

func NewInformerFactory

func NewInformerFactory(kubeClient kclient.Interface, originClient oclient.Interface, customListerWatchers ListerWatcherOverrides, defaultResync time.Duration) InformerFactory

type LimitRangeInformer

type LimitRangeInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() StoreToLimitRangeLister
}

type ListerWatcherOverrides

type ListerWatcherOverrides interface {
	// GetListerWatcher returns back a ListerWatcher for a given resource or nil if
	// no particular ListerWatcher was specified for the type
	GetListerWatcher(resource unversioned.GroupResource) cache.ListerWatcher
}

ListerWatcherOverrides allows a caller to specify special behavior for particular ListerWatchers For instance, authentication and authorization types need to go direct to etcd, not through an API server

type NamespaceInformer

type NamespaceInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *cache.IndexerToNamespaceLister
}

type NodeInformer

type NodeInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *cache.StoreToNodeLister
}

type PersistentVolumeClaimInformer

type PersistentVolumeClaimInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *cache.StoreToPVCFetcher
}

type PersistentVolumeInformer

type PersistentVolumeInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *cache.StoreToPVFetcher
}

type PodInformer

type PodInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *cache.StoreToPodLister
}

type PolicyBindingInformer

type PolicyBindingInformer interface {
	Informer() framework.SharedIndexInformer
	// still use an indexer, no telling what someone will want to index on someday
	Indexer() cache.Indexer
	Lister() client.SyncedPolicyBindingsListerNamespacer
}

type PolicyInformer

type PolicyInformer interface {
	Informer() framework.SharedIndexInformer
	// still use an indexer, no telling what someone will want to index on someday
	Indexer() cache.Indexer
	Lister() client.SyncedPoliciesListerNamespacer
}

type ReplicationControllerInformer

type ReplicationControllerInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *cache.StoreToReplicationControllerLister
}

type SecurityContextConstraintsInformer

type SecurityContextConstraintsInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() *oscache.IndexerToSecurityContextConstraintsLister
}

type ServiceAccountInformer

type ServiceAccountInformer interface {
	Informer() framework.SharedIndexInformer
	Indexer() cache.Indexer
	Lister() oscache.StoreToServiceAccountLister
}

type StoreToLimitRangeLister

type StoreToLimitRangeLister struct {
	cache.Indexer
}

StoreToLimitRangeLister gives a store List and Get methods. The store must contain only LimitRanges.

func (StoreToLimitRangeLister) LimitRanges

func (s StoreToLimitRangeLister) LimitRanges(namespace string) storeLimitRangesNamespacer