target

Documentation

Index

• func DeploymentLabels(app *fleet.Bundle) map[string]string
• func IsPartitionUnavailable(status *fleet.PartitionStatus, targets []*Target) bool
• func IsUnavailable(target *fleet.BundleDeployment) bool
• func Limit(count int, val ...*intstr.IntOrString) (int, error)
• 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)
• func UpToDate(target *Target) bool
• type Manager
  • func New(clusters fleetcontrollers.ClusterCache, ...) *Manager
  • func (m *Manager) BundleForDeployment(bd *fleet.BundleDeployment) (string, string)
  • func (m *Manager) BundlesForCluster(cluster *fleet.Cluster) (result []*fleet.Bundle, _ error)
  • func (m *Manager) ClusterGroup(cluster *fleet.Cluster) (*fleet.ClusterGroup, 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
  • func (t *Target) Message() string
  • func (t *Target) State() fleet.BundleState

Functions

func DeploymentLabels

func DeploymentLabels(app *fleet.Bundle) map[string]string

func IsPartitionUnavailable

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

func IsUnavailable

func IsUnavailable(target *fleet.BundleDeployment) bool

func Limit

func Limit(count int, val ...*intstr.IntOrString) (int, error)

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)

func UpToDate

func UpToDate(target *Target) bool

Types

type Manager

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

func New

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

func (*Manager) BundleForDeployment

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

func (*Manager) BundlesForCluster

func (m *Manager) BundlesForCluster(cluster *fleet.Cluster) (result []*fleet.Bundle, _ error)

func (*Manager) ClusterGroup

func (m *Manager) ClusterGroup(cluster *fleet.Cluster) (*fleet.ClusterGroup, error)

func (*Manager) Targets

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

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
	ClusterGroup *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

func (*Target) Message

func (t *Target) Message() string

func (*Target) State

func (t *Target) State() fleet.BundleState