synchromanager

Documentation

Index

• Constants
• func NewItemExponentialFailureAndJitterSlowRateLimter(fastBaseDelay, fastMaxDelay, slowBaseDeploy time.Duration, ...) workqueue.RateLimiter
• type ItemExponentialFailureAndJitterSlowRateLimter
  • func (r *ItemExponentialFailureAndJitterSlowRateLimter) Forget(item interface{})
  • func (r *ItemExponentialFailureAndJitterSlowRateLimter) NumRequeues(item interface{}) int
  • func (r *ItemExponentialFailureAndJitterSlowRateLimter) When(item interface{}) time.Duration
• type Manager
  • func NewManager(client crdclientset.Interface, storage storage.StorageFactory) *Manager
  • func (manager *Manager) Run(workers int, stopCh <-chan struct{})
  • func (manager *Manager) UpdateClusterAPIServerAndValidatedCondition(name string, apiServerEndpoint string, synchro *clustersynchro.ClusterSynchro, ...)
  • func (manager *Manager) UpdateClusterStatus(ctx context.Context, name string, status *clusterv1alpha2.ClusterStatus) error

Constants

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

Functions

func NewItemExponentialFailureAndJitterSlowRateLimter

func NewItemExponentialFailureAndJitterSlowRateLimter(fastBaseDelay, fastMaxDelay, slowBaseDeploy time.Duration, slowMaxFactor float64, maxFastAttempts int) workqueue.RateLimiter

Types

type ItemExponentialFailureAndJitterSlowRateLimter

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

func (*ItemExponentialFailureAndJitterSlowRateLimter) Forget

func (r *ItemExponentialFailureAndJitterSlowRateLimter) Forget(item interface{})

func (*ItemExponentialFailureAndJitterSlowRateLimter) NumRequeues

func (r *ItemExponentialFailureAndJitterSlowRateLimter) NumRequeues(item interface{}) int

func (*ItemExponentialFailureAndJitterSlowRateLimter) When

func (r *ItemExponentialFailureAndJitterSlowRateLimter) When(item interface{}) time.Duration

type Manager

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

func NewManager

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

func (*Manager) Run

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

func (*Manager) UpdateClusterAPIServerAndValidatedCondition

func (manager *Manager) UpdateClusterAPIServerAndValidatedCondition(name string, apiServerEndpoint string, synchro *clustersynchro.ClusterSynchro, reason, message string, status metav1.ConditionStatus)

func (*Manager) UpdateClusterStatus

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