placement

Documentation

Index

• type NamespacePlacementPlugin
  • func (p *NamespacePlacementPlugin) ComputePlacement(qualifiedName util.QualifiedName, clusterNames []string) (selectedClusters, unselectedClusters []string, err error)
  • func (p *NamespacePlacementPlugin) HasSynced() bool
  • func (p *NamespacePlacementPlugin) Run(stopCh <-chan struct{})
• type PlacementPlugin
  • func NewNamespacePlacementPlugin(client util.ResourceClient, targetNamespace string, ...) 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, clusterNames []string) (selectedClusters, unselectedClusters []string, err error)
  • func (p *ResourcePlacementPlugin) HasSynced() bool
  • func (p *ResourcePlacementPlugin) Run(stopCh <-chan struct{})

Types

type NamespacePlacementPlugin

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

func (*NamespacePlacementPlugin) ComputePlacement

func (p *NamespacePlacementPlugin) ComputePlacement(qualifiedName util.QualifiedName, clusterNames []string) (selectedClusters, unselectedClusters []string, err error)

func (*NamespacePlacementPlugin) HasSynced

func (p *NamespacePlacementPlugin) HasSynced() bool

func (*NamespacePlacementPlugin) Run

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

type PlacementPlugin

type PlacementPlugin interface {
	Run(stopCh <-chan struct{})
	HasSynced() bool
	ComputePlacement(qualifiedName util.QualifiedName, clusterNames []string) (selectedClusters, unselectedClusters []string, err error)
}

func NewNamespacePlacementPlugin

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

func NewNamespacedPlacementPlugin

func NewNamespacedPlacementPlugin(resourceClient, namespaceClient util.ResourceClient, targetNamespace string, triggerFunc 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, clusterNames []string) (selectedClusters, unselectedClusters []string, err error)

func (*ResourcePlacementPlugin) HasSynced

func (p *ResourcePlacementPlugin) HasSynced() bool

func (*ResourcePlacementPlugin) Run

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