target

Documentation

Overview

Package target provides a functions to match bundles and clusters and to list the bundledeployments for that match. (fleetcontroller)

Index

• func IsPartitionUnavailable(status *fleet.PartitionStatus, targets []*Target) bool
• func IsUnavailable(target *fleet.BundleDeployment) bool
• func MaxUnavailable(targets []*Target) (int, error)
• func MaxUnavailablePartitions(partitions []Partition, targets []*Target) (int, error)
• func Summary(targets []*Target) fleet.BundleSummary
• func Unavailable(targets []*Target) (count int)
• type BundleMapping
  • func NewBundleMapping(mapping *fleet.BundleNamespaceMapping, ...) (*BundleMapping, error)
  • func (b *BundleMapping) Bundles() ([]*fleet.Bundle, error)
  • func (b *BundleMapping) Matches(fleetBundle *fleet.Bundle) bool
  • func (b *BundleMapping) MatchesNamespace(namespace string) bool
  • func (b *BundleMapping) Namespaces() ([]*corev1.Namespace, error)
• type Manager
  • func New(clusters fleetcontrollers.ClusterCache, ...) *Manager
  • func (m *Manager) BundleFromDeployment(bd *fleet.BundleDeployment) (string, string)
  • func (m *Manager) BundlesForCluster(cluster *fleet.Cluster) (bundlesToRefresh, bundlesToCleanup []*fleet.Bundle, err error)
  • func (m *Manager) GetBundleDeploymentsForBundleInCluster(app *fleet.Bundle, cluster *fleet.Cluster) (result []*fleet.BundleDeployment, err error)
  • func (m *Manager) Targets(fleetBundle *fleet.Bundle) (result []*Target, _ error)
• type Partition
  • func Partitions(targets []*Target) ([]Partition, error)
• type Target
  • func (t *Target) AssignNewDeployment()
  • func (t *Target) IsPaused() bool

Functions

func IsPartitionUnavailable

func IsPartitionUnavailable(status *fleet.PartitionStatus, targets []*Target) bool

func IsUnavailable

func IsUnavailable(target *fleet.BundleDeployment) bool

func MaxUnavailable

func MaxUnavailable(targets []*Target) (int, error)

func MaxUnavailablePartitions

func MaxUnavailablePartitions(partitions []Partition, targets []*Target) (int, error)

func Summary

func Summary(targets []*Target) fleet.BundleSummary

func Unavailable

func Unavailable(targets []*Target) (count int)

Types

type BundleMapping

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

func NewBundleMapping

func NewBundleMapping(mapping *fleet.BundleNamespaceMapping,
	namespaces corecontrollers.NamespaceCache,
	bundles fleetcontrollers.BundleCache) (*BundleMapping, error)

func (*BundleMapping) Bundles

func (b *BundleMapping) Bundles() ([]*fleet.Bundle, error)

func (*BundleMapping) Matches

func (b *BundleMapping) Matches(fleetBundle *fleet.Bundle) bool

func (*BundleMapping) MatchesNamespace

func (b *BundleMapping) MatchesNamespace(namespace string) bool

func (*BundleMapping) Namespaces

func (b *BundleMapping) Namespaces() ([]*corev1.Namespace, error)

type Manager

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

func New

func New(
	clusters fleetcontrollers.ClusterCache,
	clusterGroups fleetcontrollers.ClusterGroupCache,
	bundles fleetcontrollers.BundleCache,
	bundleNamespaceMappingCache fleetcontrollers.BundleNamespaceMappingCache,
	namespaceCache corecontrollers.NamespaceCache,
	contentStore manifest.Store,
	bundleDeployments fleetcontrollers.BundleDeploymentCache) *Manager

func (*Manager) BundleFromDeployment

func (m *Manager) BundleFromDeployment(bd *fleet.BundleDeployment) (string, string)

func (*Manager) BundlesForCluster

func (m *Manager) BundlesForCluster(cluster *fleet.Cluster) (bundlesToRefresh, bundlesToCleanup []*fleet.Bundle, err error)

func (*Manager) GetBundleDeploymentsForBundleInCluster

func (m *Manager) GetBundleDeploymentsForBundleInCluster(app *fleet.Bundle, cluster *fleet.Cluster) (result []*fleet.BundleDeployment, err error)

func (*Manager) Targets

func (m *Manager) Targets(fleetBundle *fleet.Bundle) (result []*Target, _ error)

Targets returns all targets for a bundle, so we can create bundledeployments for each

type Partition

type Partition struct {
	Status  fleet.PartitionStatus
	Targets []*Target
}

func Partitions

func Partitions(targets []*Target) ([]Partition, error)

type Target

type Target struct {
	Deployment    *fleet.BundleDeployment
	ClusterGroups []*fleet.ClusterGroup
	Cluster       *fleet.Cluster
	Bundle        *fleet.Bundle
	Target        *fleet.BundleTarget
	Options       fleet.BundleDeploymentOptions
	DeploymentID  string
}

func (*Target) AssignNewDeployment

func (t *Target) AssignNewDeployment()

func (*Target) IsPaused

func (t *Target) IsPaused() bool