statusaggregator

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 17, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StatusAggregatorControllerName = "status-aggregator-controller"

	EventReasonUpdateSourceObjectStatus = "UpdateSourceObjectStatus"
)

Variables

This section is empty.

Functions

This section is empty.

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL