util

package

Go to main page

Versions in this module

v0

v0.0.6

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

v0.0.5

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

v0.0.4

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)

v0.0.3

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{}

v0.0.2

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

v0.0.2-rc.1

Sep 24, 2018

v0.0.1

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)

v0.0.1-test-fake

Jul 11, 2018

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL