placement

Documentation

Index

• type PlacementPlugin
  • func NewNamespacedPlacementPlugin(resourceClient, namespaceClient util.ResourceClient, targetNamespace string, ...) PlacementPlugin
  • func NewResourcePlacementPlugin(client util.ResourceClient, targetNamespace string, ...) PlacementPlugin
• type ResourcePlacementPlugin
  • func (p *ResourcePlacementPlugin) ComputePlacement(qualifiedName util.QualifiedName, clusters []*fedv1a1.FederatedCluster) (selectedClusters, unselectedClusters []string, err error)
  • func (p *ResourcePlacementPlugin) GetPlacement(key string) (*unstructured.Unstructured, error)
  • func (p *ResourcePlacementPlugin) HasSynced() bool
  • func (p *ResourcePlacementPlugin) Run(stopCh <-chan struct{})

Types

type PlacementPlugin

type PlacementPlugin interface {
	Run(stopCh <-chan struct{})
	HasSynced() bool
	ComputePlacement(qualifiedName util.QualifiedName, clusters []*fedv1a1.FederatedCluster) (selectedClusters, unselectedClusters []string, err error)
	GetPlacement(key string) (*unstructured.Unstructured, error)
}

func NewNamespacedPlacementPlugin

func NewNamespacedPlacementPlugin(resourceClient, namespaceClient util.ResourceClient, targetNamespace string, resourceTriggerFunc, namespaceTriggerFunc func(pkgruntime.Object)) PlacementPlugin

func NewResourcePlacementPlugin

func NewResourcePlacementPlugin(client util.ResourceClient, targetNamespace string, triggerFunc func(pkgruntime.Object)) PlacementPlugin

type ResourcePlacementPlugin

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

func (*ResourcePlacementPlugin) ComputePlacement

func (p *ResourcePlacementPlugin) ComputePlacement(qualifiedName util.QualifiedName, clusters []*fedv1a1.FederatedCluster) (selectedClusters, unselectedClusters []string, err error)

func (*ResourcePlacementPlugin) GetPlacement

func (p *ResourcePlacementPlugin) GetPlacement(key string) (*unstructured.Unstructured, error)

func (*ResourcePlacementPlugin) HasSynced

func (p *ResourcePlacementPlugin) HasSynced() bool

func (*ResourcePlacementPlugin) Run

func (p *ResourcePlacementPlugin) Run(stopCh <-chan struct{})