Documentation ¶
Index ¶
- Constants
- type ClusterStatusUpdater
- type ClusterSynchro
- type ResourceSynchro
- func (synchro *ResourceSynchro) Close()
- func (synchro *ResourceSynchro) Closed() <-chan struct{}
- func (synchro *ResourceSynchro) OnAdd(obj interface{})
- func (synchro *ResourceSynchro) OnDelete(obj interface{})
- func (synchro *ResourceSynchro) OnSync(obj interface{})
- func (synchro *ResourceSynchro) OnUpdate(_, obj interface{})
- func (synchro *ResourceSynchro) Run(stopCh <-chan struct{})
- func (synchro *ResourceSynchro) Status() clusterv1alpha2.ClusterResourceSyncCondition
Constants ¶
View Source
const LastAppliedConfigurationAnnotation = "kubectl.kubernetes.io/last-applied-configuration"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterStatusUpdater ¶
type ClusterStatusUpdater interface {
UpdateClusterStatus(ctx context.Context, name string, status *clusterv1alpha2.ClusterStatus) error
}
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) (*ClusterSynchro, error)
func (*ClusterSynchro) Monitor ¶
func (synchro *ClusterSynchro) Monitor()
func (*ClusterSynchro) Run ¶ added in v0.1.0
func (s *ClusterSynchro) Run(shutdown <-chan struct{})
func (*ClusterSynchro) SetResources ¶
func (s *ClusterSynchro) SetResources(syncResources []clusterv1alpha2.ClusterGroupResources)
func (*ClusterSynchro) Shutdown ¶
func (s *ClusterSynchro) Shutdown(updateReadyCondition, waitResourceSynchro bool)
type ResourceSynchro ¶
type ResourceSynchro struct {
// contains filtered or unexported fields
}
func (*ResourceSynchro) Close ¶
func (synchro *ResourceSynchro) Close()
func (*ResourceSynchro) Closed ¶ added in v0.1.0
func (synchro *ResourceSynchro) Closed() <-chan struct{}
func (*ResourceSynchro) OnAdd ¶
func (synchro *ResourceSynchro) OnAdd(obj interface{})
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(stopCh <-chan struct{})
func (*ResourceSynchro) Status ¶
func (synchro *ResourceSynchro) Status() clusterv1alpha2.ClusterResourceSyncCondition
Click to show internal directories.
Click to hide internal directories.