statusaggregator

Documentation

Index

• Constants
• type StatusAggregator
  • func NewStatusAggregatorController(kubeClient kubeclient.Interface, dynamicClient dynamicclient.Interface, ...) (*StatusAggregator, error)
  • func (a *StatusAggregator) HasSynced() bool
  • func (a *StatusAggregator) IsControllerReady() bool
  • func (a *StatusAggregator) Run(ctx context.Context)

Constants

const (
	StatusAggregatorControllerName = "status-aggregator-controller"

	EventReasonUpdateSourceObjectStatus = "UpdateSourceObjectStatus"
)

Types

type StatusAggregator

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

StatusAggregator aggregates statuses of target objects in member clusters to status of source object

func NewStatusAggregatorController

func NewStatusAggregatorController(
	kubeClient kubeclient.Interface,
	dynamicClient dynamicclient.Interface,
	fedClient fedclient.Interface,
	fedObjectInformer fedcorev1a1informers.FederatedObjectInformer,
	clusterFedObjectInformer fedcorev1a1informers.ClusterFederatedObjectInformer,
	federatedInformer informermanager.FederatedInformerManager,
	informerManager informermanager.InformerManager,
	metrics stats.Metrics,
	logger klog.Logger,
	workerCount int,
	clusterAvailableDelay, clusterUnavailableDelay time.Duration,
) (*StatusAggregator, error)

func (*StatusAggregator) HasSynced

func (a *StatusAggregator) HasSynced() bool

func (*StatusAggregator) IsControllerReady

func (a *StatusAggregator) IsControllerReady() bool

func (*StatusAggregator) Run

func (a *StatusAggregator) Run(ctx context.Context)