status

Documentation

Index

• Constants
• type StatusController
  • func NewStatusController(kubeClient kubernetes.Interface, fedClient fedclient.Interface, ...) (*StatusController, error)
  • func (s *StatusController) HasSynced() bool
  • func (s *StatusController) IsControllerReady() bool
  • func (s *StatusController) Run(ctx context.Context)

Constants

const (
	EventReasonGetObjectStatusError = "GetObjectStatusError"
)

const (
	StatusControllerName = "status-controller"
)

Types

type StatusController

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

StatusController collects the status of resources in member clusters.

func NewStatusController

func NewStatusController(
	kubeClient kubernetes.Interface,
	fedClient fedclient.Interface,

	fedObjectInformer fedcorev1a1informers.FederatedObjectInformer,
	clusterFedObjectInformer fedcorev1a1informers.ClusterFederatedObjectInformer,
	collectedStatusInformer fedcorev1a1informers.CollectedStatusInformer,
	clusterCollectedStatusInformer fedcorev1a1informers.ClusterCollectedStatusInformer,

	ftcManager informermanager.FederatedTypeConfigManager,
	fedInformerManager informermanager.FederatedInformerManager,

	clusterAvailableDelay, clusterUnavailableDelay, memberObjectEnqueueDelay time.Duration,

	logger klog.Logger,
	workerCount int,
	metrics stats.Metrics,
) (*StatusController, error)

NewStatusController returns a new status controller for the configuration

func (*StatusController) HasSynced

func (s *StatusController) HasSynced() bool

Check whether all data stores are in sync. False is returned if any of the informer/stores is not yet synced with the corresponding api server.

func (*StatusController) IsControllerReady

func (s *StatusController) IsControllerReady() bool

func (*StatusController) Run

func (s *StatusController) Run(ctx context.Context)

Run runs the status controller