target

Documentation

Index

• func DeploymentLabels(app *fleet.Bundle) map[string]string
• func IsUnavailable(target *fleet.BundleDeployment) bool
• func MaxUnavailable(targets []*Target) (int, error)
• func Unavailable(targets []*Target) (count int)
• 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 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 IsUnavailable

func IsUnavailable(target *fleet.BundleDeployment) bool

func MaxUnavailable

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

func Unavailable

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

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