Versions in this module Expand all Collapse all v1 v1.24.10 Oct 24, 2017 v1.24.9 Oct 24, 2017 Changes in this version + const KubeAPIBurst + const KubeAPIQPS + const KubeconfigSecretDataKey + const OperationTypeAdd + const OperationTypeDelete + const OperationTypeUpdate + var KubeconfigGetterForSecret = func(secret *api.Secret) clientcmd.KubeconfigGetter + func BuildClusterConfig(c *federation_v1beta1.Cluster) (*restclient.Config, error) + func ConfigMapEquivalent(s1, s2 *api_v1.ConfigMap) bool + func DeepCopyDeployment(a *extensions_v1.Deployment) *extensions_v1.Deployment + func DeepCopyDeploymentObjectMeta(meta metav1.ObjectMeta) metav1.ObjectMeta + func DeepCopyRelevantObjectMeta(obj metav1.ObjectMeta) metav1.ObjectMeta + func DeploymentEquivalent(a, b *extensions_v1.Deployment) bool + func NewTriggerOnAllChanges(triggerFunc func(pkgruntime.Object)) *cache.ResourceEventHandlerFuncs + func NewTriggerOnMetaAndFieldChanges(field string, triggerFunc func(pkgruntime.Object)) *cache.ResourceEventHandlerFuncs + func NewTriggerOnMetaAndSpecChanges(triggerFunc func(pkgruntime.Object)) *cache.ResourceEventHandlerFuncs + func ObjectMetaAndSpecEquivalent(a, b runtime.Object) bool + func ObjectMetaEquivalent(a, b metav1.ObjectMeta) bool + func SecretEquivalent(s1, s2 api_v1.Secret) bool + func StartBackoffGC(backoff *flowcontrol.Backoff, stopCh <-chan struct{}) + type ClusterLifecycleHandlerFuncs struct + ClusterAvailable func(*federationapi.Cluster) + ClusterUnavailable func(*federationapi.Cluster, []interface{}) + type DelayingDeliverer struct + func NewDelayingDeliverer() *DelayingDeliverer + func NewDelayingDelivererWithChannel(targetChannel chan *DelayingDelivererItem) *DelayingDeliverer + func (d *DelayingDeliverer) DeliverAfter(key string, value interface{}, delay time.Duration) + func (d *DelayingDeliverer) DeliverAt(key string, value interface{}, deliveryTime time.Time) + func (d *DelayingDeliverer) GetTargetChannel() chan *DelayingDelivererItem + func (d *DelayingDeliverer) Start() + func (d *DelayingDeliverer) StartWithHandler(handler func(*DelayingDelivererItem)) + func (d *DelayingDeliverer) Stop() + type DelayingDelivererItem struct + DeliveryTime time.Time + Key string + Value interface{} + type FederatedInformer interface + GetTargetStore func() FederatedReadOnlyStore + Start func() + Stop func() + func NewFederatedInformer(federationClient federationclientset.Interface, ...) FederatedInformer + type FederatedInformerForTestOnly interface + SetClientFactory func(func(*federationapi.Cluster) (kubeclientset.Interface, error)) + type FederatedObject struct + ClusterName string + Object interface{} + type FederatedOperation struct + ClusterName string + Key string + Obj pkgruntime.Object + Type FederatedOperationType + type FederatedOperationHandler func(kubeclientset.Interface, pkgruntime.Object) error + type FederatedOperationType string + type FederatedReadOnlyStore interface + ClustersSynced func(clusters []*federationapi.Cluster) bool + GetByKey func(clusterName string, key string) (interface{}, bool, error) + GetFromAllClusters func(key string) ([]FederatedObject, error) + GetKeyFor func(item interface{}) string + List func() ([]FederatedObject, error) + ListFromCluster func(clusterName string) ([]interface{}, error) + type FederatedUpdater interface + Update func([]FederatedOperation) error + func NewFederatedUpdater(federation FederationView, kind string, timeout time.Duration, ...) FederatedUpdater + type FederationView interface + ClustersSynced func() bool + GetClientsetForCluster func(clusterName string) (kubeclientset.Interface, error) + GetReadyCluster func(name string) (*federationapi.Cluster, bool, error) + GetReadyClusters func() ([]*federationapi.Cluster, error) + GetUnreadyClusters func() ([]*federationapi.Cluster, error) + type TargetInformerFactory func(*federationapi.Cluster, kubeclientset.Interface) (cache.Store, cache.Controller)