clustersynchro

Documentation

Index

• Constants
• type ClusterStatusUpdater
• type ClusterSyncConfig
• type ClusterSynchro
  • func New(name string, config *rest.Config, storage storage.StorageFactory, ...) (*ClusterSynchro, error)
  • func (s *ClusterSynchro) GetMetricsWriterList() (writers metricsstore.MetricsWriterList)
  • func (s *ClusterSynchro) Run(shutdown <-chan struct{})
  • func (s *ClusterSynchro) SetResources(syncResources []clusterv1alpha2.ClusterGroupResources, ...)
  • func (s *ClusterSynchro) Shutdown(updateStatus bool)
• type GVRSet
  • func NewGVRSet(gvrs ...schema.GroupVersionResource) GVRSet
  • func (set GVRSet) Insert(gvrs ...schema.GroupVersionResource)
• type GroupResourceStatus
  • func NewGroupResourceStatus() *GroupResourceStatus
  • func (s *GroupResourceStatus) DeleteVersion(gvr schema.GroupVersionResource)
  • func (s *GroupResourceStatus) DisableConcurrent()
  • func (s *GroupResourceStatus) EnableConcurrent()
  • func (s *GroupResourceStatus) GetStorageGVRToSyncGVRs() map[schema.GroupVersionResource]GVRSet
  • func (s *GroupResourceStatus) LoadGroupResourcesStatuses() []clusterv1alpha2.ClusterGroupResourcesStatus
  • func (s *GroupResourceStatus) Merge(other *GroupResourceStatus) GVRSet
  • func (s *GroupResourceStatus) UpdateSyncCondition(gvr schema.GroupVersionResource, status, reason, message string)
• type ResourceNegotiator
  • func (negotiator *ResourceNegotiator) NegotiateSyncResources(syncResources []clusterv1alpha2.ClusterGroupResources) (*GroupResourceStatus, map[schema.GroupVersionResource]syncConfig)
  • func (negotiator *ResourceNegotiator) SetSyncAllCustomResources(sync bool)
• type ResourceSynchro
  • func (synchro *ResourceSynchro) Close() <-chan struct{}
  • func (synchro *ResourceSynchro) ErrorHandler(r *informer.Reflector, err error)
  • func (synchro *ResourceSynchro) OnAdd(obj interface{}, isInInitialList bool)
  • func (synchro *ResourceSynchro) OnDelete(obj interface{})
  • func (synchro *ResourceSynchro) OnSync(obj interface{})
  • func (synchro *ResourceSynchro) OnUpdate(_, obj interface{})
  • func (synchro *ResourceSynchro) Run(shutdown <-chan struct{})
  • func (synchro *ResourceSynchro) Start(stopCh <-chan struct{})
  • func (synchro *ResourceSynchro) Status() clusterv1alpha2.ClusterResourceSyncCondition
• type ResourceSynchroConfig
  • func (c ResourceSynchroConfig) GroupVersionKind() schema.GroupVersionKind
• type RetryableError

Constants

const LastAppliedConfigurationAnnotation = "kubectl.kubernetes.io/last-applied-configuration"

Types

type ClusterStatusUpdater

type ClusterStatusUpdater interface {
	UpdateClusterStatus(ctx context.Context, name string, status *clusterv1alpha2.ClusterStatus) error
}

type ClusterSyncConfig

type ClusterSyncConfig struct {
	MetricsStoreBuilder     *kubestatemetrics.MetricsStoreBuilder
	PageSizeForResourceSync int64
}

type ClusterSynchro

type ClusterSynchro struct {
	RESTConfig           *rest.Config
	ClusterStatusUpdater ClusterStatusUpdater
	// contains filtered or unexported fields
}

func New

func New(name string, config *rest.Config, storage storage.StorageFactory, updater ClusterStatusUpdater, syncConfig ClusterSyncConfig) (*ClusterSynchro, error)

func (*ClusterSynchro) GetMetricsWriterList

func (s *ClusterSynchro) GetMetricsWriterList() (writers metricsstore.MetricsWriterList)

func (*ClusterSynchro) Run

func (s *ClusterSynchro) Run(shutdown <-chan struct{})

func (*ClusterSynchro) SetResources

func (s *ClusterSynchro) SetResources(syncResources []clusterv1alpha2.ClusterGroupResources, syncAllCustomResources bool)

func (*ClusterSynchro) Shutdown

func (s *ClusterSynchro) Shutdown(updateStatus bool)

type GVRSet

type GVRSet map[schema.GroupVersionResource]struct{}

func NewGVRSet

func NewGVRSet(gvrs ...schema.GroupVersionResource) GVRSet

func (GVRSet) Insert

func (set GVRSet) Insert(gvrs ...schema.GroupVersionResource)

type GroupResourceStatus

type GroupResourceStatus struct {
	// contains filtered or unexported fields
}

GroupResourceStatus manages the status of synchronized resources TODO: change to a more appropriate name

func NewGroupResourceStatus

func NewGroupResourceStatus() *GroupResourceStatus

func (*GroupResourceStatus) DeleteVersion

func (s *GroupResourceStatus) DeleteVersion(gvr schema.GroupVersionResource)

func (*GroupResourceStatus) DisableConcurrent

func (s *GroupResourceStatus) DisableConcurrent()

func (*GroupResourceStatus) EnableConcurrent

func (s *GroupResourceStatus) EnableConcurrent()

func (*GroupResourceStatus) GetStorageGVRToSyncGVRs

func (s *GroupResourceStatus) GetStorageGVRToSyncGVRs() map[schema.GroupVersionResource]GVRSet

func (*GroupResourceStatus) LoadGroupResourcesStatuses

func (s *GroupResourceStatus) LoadGroupResourcesStatuses() []clusterv1alpha2.ClusterGroupResourcesStatus

func (*GroupResourceStatus) Merge

func (s *GroupResourceStatus) Merge(other *GroupResourceStatus) GVRSet

func (*GroupResourceStatus) UpdateSyncCondition

func (s *GroupResourceStatus) UpdateSyncCondition(gvr schema.GroupVersionResource, status, reason, message string)

type ResourceNegotiator

type ResourceNegotiator struct {
	// contains filtered or unexported fields
}

func (*ResourceNegotiator) NegotiateSyncResources

func (negotiator *ResourceNegotiator) NegotiateSyncResources(syncResources []clusterv1alpha2.ClusterGroupResources) (*GroupResourceStatus, map[schema.GroupVersionResource]syncConfig)

func (*ResourceNegotiator) SetSyncAllCustomResources

func (negotiator *ResourceNegotiator) SetSyncAllCustomResources(sync bool)

type ResourceSynchro

type ResourceSynchro struct {
	// contains filtered or unexported fields
}

func (*ResourceSynchro) Close

func (synchro *ResourceSynchro) Close() <-chan struct{}

func (*ResourceSynchro) ErrorHandler

func (synchro *ResourceSynchro) ErrorHandler(r *informer.Reflector, err error)

func (*ResourceSynchro) OnAdd

func (synchro *ResourceSynchro) OnAdd(obj interface{}, isInInitialList bool)

func (*ResourceSynchro) OnDelete

func (synchro *ResourceSynchro) OnDelete(obj interface{})

func (*ResourceSynchro) OnSync

func (synchro *ResourceSynchro) OnSync(obj interface{})

func (*ResourceSynchro) OnUpdate

func (synchro *ResourceSynchro) OnUpdate(_, obj interface{})

func (*ResourceSynchro) Run

func (synchro *ResourceSynchro) Run(shutdown <-chan struct{})

func (*ResourceSynchro) Start

func (synchro *ResourceSynchro) Start(stopCh <-chan struct{})

func (*ResourceSynchro) Status

func (synchro *ResourceSynchro) Status() clusterv1alpha2.ClusterResourceSyncCondition

type ResourceSynchroConfig

type ResourceSynchroConfig struct {
	schema.GroupVersionResource
	Kind string

	cache.ListerWatcher
	runtime.ObjectConvertor
	storage.ResourceStorage

	*kubestatemetrics.MetricsStore

	ResourceVersions    map[string]interface{}
	PageSizeForInformer int64
}

func (ResourceSynchroConfig) GroupVersionKind

func (c ResourceSynchroConfig) GroupVersionKind() schema.GroupVersionKind

type RetryableError

type RetryableError error