util

May 6, 2019

Changes in this version

type ControllerConfig

+ SkipAdoptingResources bool

type FederationView

+ GetClusters func() ([]*fedv1a1.FederatedCluster, error)

Apr 29, 2019

Changes in this version

+ const DefaultClusterHealthCheckFailureThreshold

+ const DefaultClusterHealthCheckPeriod

+ const DefaultClusterHealthCheckSuccessThreshold

+ const DefaultClusterHealthCheckTimeout

+ const DefaultLeaderElectionResourceLock

+ const ManagedByFederationLabelKey

+ const ManagedByFederationLabelValue

+ func AddManagedLabel(obj *unstructured.Unstructured)

+ func HasManagedLabel(obj *unstructured.Unstructured) bool

+ func NewManagedResourceInformer(client ResourceClient, namespace string, triggerFunc func(pkgruntime.Object)) (cache.Store, cache.Controller)

+ func RemoveManagedLabel(obj *unstructured.Unstructured)

+ type ClusterHealthCheckConfig struct

+ FailureThreshold int

+ PeriodSeconds int

+ SuccessThreshold int

+ TimeoutSeconds int

Apr 10, 2019

Changes in this version

+ const FederationConfigName

type SafeMap

+ func (s *SafeMap) DeleteAll()

+ func (s *SafeMap) Size() int

Mar 22, 2019

Changes in this version

+ const DefaultLeaderElectionLeaseDuration

+ const DefaultLeaderElectionRenewDeadline

+ const DefaultLeaderElectionRetryPeriod

+ const MatchLabelsField

+ const MetadataField

+ const ReplicasField

+ const RetainReplicasField

+ func NewGenericInformerWithEventHandler(config *rest.Config, namespace string, obj pkgruntime.Object, ...) (cache.Store, cache.Controller, error)

+ type LeaderElectionConfiguration struct

+ LeaseDuration time.Duration

+ RenewDeadline time.Duration

+ ResourceLock string

+ RetryPeriod time.Duration

+ type SafeMap struct

+ func NewSafeMap() *SafeMap

+ func (s *SafeMap) Delete(key string)

+ func (s *SafeMap) Get(key string) (interface{}, bool)

+ func (s *SafeMap) GetAll() []interface{}

+ func (s *SafeMap) Store(key string, value interface{})

Feb 21, 2019

Changes in this version

+ const PlacementField

+ const SecretsField

+ const ServiceAccountKind

+ const TemplateField

+ func NewGenericInformer(config *rest.Config, namespace string, obj pkgruntime.Object, ...) (cache.Store, cache.Controller, error)

+ func ObjectNeedsUpdate(desiredObj, clusterObj *unstructured.Unstructured, recordedVersion string) bool

+ func ObjectVersion(clusterObj *unstructured.Unstructured) string

+ func UnstructuredToInterface(rawObj *unstructured.Unstructured, obj interface{}) error

type ControllerConfig

+ func (c *ControllerConfig) LimitedScope() bool

+ type GenericPlacementFields struct

+ ClusterNames []string

+ ClusterSelector *metav1.LabelSelector

type GenericPlacementSpec

+ Placement GenericPlacementFields

Feb 15, 2019

Changes in this version

+ const ClusterSelectorField

+ func ObjFromCache(store cache.Store, kind, key string) (*unstructured.Unstructured, error)

type ClusterOverride

+ Value interface{}

+ type GenericOverride struct

+ Spec *GenericOverrideSpec

+ type GenericOverrideItem struct

+ ClusterName string

+ ClusterOverrides []ClusterOverride

+ type GenericOverrideSpec struct

+ Overrides []GenericOverrideItem

type ResourceClient

+ Kind func() string

Dec 10, 2018

Changes in this version

+ const ClusterOverridesField

+ const NamespaceName

+ const OverridesField

+ const PathField

+ const SpecField

+ const ValueField

+ func SetOverrides(override *unstructured.Unstructured, overridesMap OverridesMap) error

+ type ClusterOverridesMap map[string]interface

+ type GenericPlacement struct

+ Spec GenericPlacementSpec

+ type GenericPlacementSpec struct

+ ClusterNames []string

+ ClusterSelector *metav1.LabelSelector

+ type OverridesMap map[string]ClusterOverridesMap

+ func GetOverrides(override *unstructured.Unstructured) (OverridesMap, error)

+ func (m OverridesMap) ToUnstructuredSlice() []interface{}

+ type PlacementDirective struct

+ ClusterNames []string

+ ClusterSelector labels.Selector

+ func GetPlacementDirective(rawPlacement *unstructured.Unstructured) (*PlacementDirective, error)

Nov 13, 2018

Changes in this version

+ const DefaultClusterAvailableDelay

+ const DefaultClusterUnavailableDelay

+ func GetUnstructured(resource interface{}) (*unstructured.Unstructured, error)

+ type ClusterOverride struct

+ FieldValue interface{}

+ Path []string

type ClusterOverrides

+ func GetClusterOverrides(typeConfig typeconfig.Interface, override *unstructured.Unstructured) (ClusterOverrides, error)

+ type ControllerConfig struct

+ ClusterAvailableDelay time.Duration

+ ClusterUnavailableDelay time.Duration

+ KubeConfig *restclient.Config

+ MinimizeLatency bool

+ func (c *ControllerConfig) AllClients(userAgent string) (fedclientset.Interface, kubeclientset.Interface, crclientset.Interface)

+ type FederatedResource struct

+ ClusterStatus []ResourceClusterStatus

+ type FederationNamespaces struct

+ ClusterNamespace string

+ FederationNamespace string

+ TargetNamespace string

+ type ResourceClusterStatus struct

+ ClusterName string

+ Status map[string]interface{}

Oct 19, 2018

Changes in this version

+ const ClusterNameField

+ const ClusterNamesField

+ const DefaultFederationSystemNamespace

+ func IsClusterReady(cluster *fedv1a1.FederatedCluster) bool

+ type ClusterOverrides struct

+ Overrides map[string]interface{}

+ Path []string

+ func NewClusterOverrides(typeConfig typeconfig.Interface, override *unstructured.Unstructured) (*ClusterOverrides, error)

+ type ReconcileFunc func(qualifiedName QualifiedName) ReconciliationStatus

+ type ReconcileWorker interface

+ Enqueue func(qualifiedName QualifiedName)

+ EnqueueForClusterSync func(qualifiedName QualifiedName)

+ EnqueueForError func(qualifiedName QualifiedName)

+ EnqueueForRetry func(qualifiedName QualifiedName)

+ EnqueueObject func(obj pkgruntime.Object)

+ EnqueueWithDelay func(qualifiedName QualifiedName, delay time.Duration)

+ Run func(stopChan <-chan struct{})

+ SetDelay func(retryDelay, clusterSyncDelay time.Duration)

+ func NewReconcileWorker(reconcile ReconcileFunc, timing WorkerTiming) ReconcileWorker

+ type WorkerTiming struct

+ ClusterSyncDelay time.Duration

+ InitialBackoff time.Duration

+ Interval time.Duration

+ MaxBackoff time.Duration

+ RetryDelay time.Duration

Jul 13, 2018

Changes in this version

+ const FederationSystemNamespace

+ const KubeAPIBurst

+ const KubeAPIQPS

+ const KubeconfigSecretDataKey

+ const MulticlusterPublicNamespace

+ const NamespaceKind

+ const NoResyncPeriod

+ const OperationTypeAdd

+ const OperationTypeDelete

+ const OperationTypeUpdate

+ const ServiceKind

+ var KubeconfigGetterForSecret = func(secret *apiv1.Secret) clientcmd.KubeconfigGetter

+ func BuildClusterConfig(fedCluster *fedv1a1.FederatedCluster, kubeClient kubeclientset.Interface, ...) (*restclient.Config, error)

+ func ConfigMapEquivalent(s1, s2 *api_v1.ConfigMap) bool

+ func DeepCopyRelevantObjectMeta(obj metav1.ObjectMeta) metav1.ObjectMeta

+ func GetClusterNames(placement *unstructured.Unstructured) ([]string, error)

+ func IsPrimaryCluster(obj, clusterObj pkgruntime.Object) bool

+ func MetaAccessor(obj pkgruntime.Object) metav1.Object

+ func NewResourceInformer(client ResourceClient, namespace string, triggerFunc func(pkgruntime.Object)) (cache.Store, cache.Controller)

+ 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 ObjectMetaObjEquivalent(a, b metav1.Object) bool

+ func PropagatedVersionStatusEquivalent(pvs1, pvs2 *fedv1a1.PropagatedVersionStatus) bool

+ func SecretEquivalent(s1, s2 api_v1.Secret) bool

+ func SetClusterNames(placement *unstructured.Unstructured, clusterNames []string) error

+ func SortClusterVersions(versions []fedv1a1.ClusterObjectVersion)

+ func StartBackoffGC(backoff *flowcontrol.Backoff, stopCh <-chan struct{})

+ type ClusterLifecycleHandlerFuncs struct

+ ClusterAvailable func(*fedv1a1.FederatedCluster)

+ ClusterUnavailable func(*fedv1a1.FederatedCluster, []interface{})

+ type ComparisonHelper interface

+ Equivalent func(objMeta1, objectMeta2 metav1.Object) bool

+ GetVersion func(objectMeta metav1.Object) string

+ func NewComparisonHelper(comparisonField common.VersionComparisonField) (ComparisonHelper, error)

+ 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(fedClient fedclientset.Interface, kubeClient kubeclientset.Interface, ...) FederatedInformer

+ type FederatedInformerForTestOnly interface

+ SetClientFactory func(func(*fedv1a1.FederatedCluster) (ResourceClient, error))

+ type FederatedObject struct

+ ClusterName string

+ Object interface{}

+ type FederatedOperation struct

+ ClusterName string

+ Key string

+ Obj pkgruntime.Object

+ Type FederatedOperationType

+ type FederatedOperationHandler func(ResourceClient, pkgruntime.Object) (string, error)

+ type FederatedOperationType string

+ type FederatedReadOnlyStore interface

+ ClustersSynced func(clusters []*fedv1a1.FederatedCluster) 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) (map[string]string, []error)

+ func NewFederatedUpdater(federation FederationView, kind string, timeout time.Duration, ...) FederatedUpdater

+ type FederationView interface

+ ClustersSynced func() bool

+ GetClientForCluster func(clusterName string) (ResourceClient, error)

+ GetReadyCluster func(name string) (*fedv1a1.FederatedCluster, bool, error)

+ GetReadyClusters func() ([]*fedv1a1.FederatedCluster, error)

+ GetUnreadyClusters func() ([]*fedv1a1.FederatedCluster, error)

+ type GenerationHelper struct

+ func (GenerationHelper) Equivalent(obj1Meta, obj2Meta metav1.Object) bool

+ func (GenerationHelper) GetVersion(objectMeta metav1.Object) string

+ type QualifiedName struct

+ Name string

+ Namespace string

+ func NewQualifiedName(obj pkgruntime.Object) QualifiedName

+ func (n QualifiedName) String() string

+ type ReconciliationStatus int

+ const StatusAllOK

+ const StatusError

+ const StatusNeedsRecheck

+ const StatusNotSynced

+ type ResourceClient interface

+ Resources func(namespace string) dynamic.ResourceInterface

+ func NewResourceClient(pool dynamic.ClientPool, apiResource *metav1.APIResource) (ResourceClient, error)

+ func NewResourceClientFromConfig(config *rest.Config, apiResource *metav1.APIResource) (ResourceClient, error)

+ type ResourceHelper struct

+ func (ResourceHelper) Equivalent(obj1Meta, obj2Meta metav1.Object) bool

+ func (ResourceHelper) GetVersion(objectMeta metav1.Object) string

+ type TargetInformerFactory func(*fedv1a1.FederatedCluster, ResourceClient) (cache.Store, cache.Controller)