target

package

v0.2.0-rc1 Latest Latest Go to latest Published: Apr 15, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rancher/fleet

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
type Partition
- func Partitions(targets []*Target) ([]Partition, error)
type Target

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DeploymentLabels ¶

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

func IsPartitionUnavailable ¶ added in v0.2.0

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

func IsUnavailable ¶

func IsUnavailable(target *fleet.BundleDeployment) bool

func Limit ¶ added in v0.2.0

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

func MaxUnavailable ¶

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

func MaxUnavailablePartitions ¶ added in v0.2.0

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

func Summary ¶ added in v0.2.0

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

func Unavailable ¶

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

func UpToDate ¶ added in v0.2.0

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 ¶ added in v0.2.0

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

func Partitions ¶ added in v0.2.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL