synchromanager

Documentation

Index

• Constants
• type Manager
  • func NewManager(kubeclient clientset.Interface, client crdclientset.Interface, ...) *Manager
  • func (manager *Manager) Run(workers int, stopCh <-chan struct{})
  • func (manager *Manager) UpdateClusterStatus(ctx context.Context, name string, status *clusterv1alpha2.ClusterStatus) error
  • func (manager *Manager) UpdateClusterSynchroCondition(name, reason, message string, status metav1.ConditionStatus)

Constants

const ClusterSynchroControllerFinalizer = "clusterpedia.io/cluster-synchro-controller"

Types

type Manager

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

func NewManager

func NewManager(kubeclient clientset.Interface, client crdclientset.Interface, storage storage.StorageFactory) *Manager

func (*Manager) Run

func (manager *Manager) Run(workers int, stopCh <-chan struct{})

func (*Manager) UpdateClusterStatus

func (manager *Manager) UpdateClusterStatus(ctx context.Context, name string, status *clusterv1alpha2.ClusterStatus) error

func (*Manager) UpdateClusterSynchroCondition

func (manager *Manager) UpdateClusterSynchroCondition(name, reason, message string, status metav1.ConditionStatus)