clusters

Documentation

Index

• func AckAllGatesForYStream(cluster *ClusterInfo, yStream string, connection *sdk.Connection, dryRun bool) ([]*csv1.VersionGateAgreement, error)
• func SortClusters(clusters []*ClusterInfo)
• type ClusterInfo
  • func ClusterInfosForOrganization(organizationId string, subscriptionSearchQuery string, withAgreements bool, ...) ([]*ClusterInfo, error)
  • func GetClusterInfoByName(organizationID string, clusterName string, connection *sdk.Connection) (*ClusterInfo, error)
  • func (c *ClusterInfo) AvailableUpgrades(considerBlockedVersions bool, additionalBlockedVersions []*regexp.Regexp) []string
  • func (c *ClusterInfo) MissingGateAgreements(additionalBlockedVersions []*regexp.Regexp, ...) ([]*csv1.VersionGate, error)
  • func (c *ClusterInfo) STSEnabled() bool
  • func (c *ClusterInfo) YStreamUpgrades(considerBlockedVersions bool, additionalBlockedVersions []*regexp.Regexp) []string
  • func (c *ClusterInfo) YStreamsWithMissingSTSGateAgreements(additionalBlockedVersions []*regexp.Regexp, ...) ([]string, error)

Functions

func AckAllGatesForYStream

func AckAllGatesForYStream(cluster *ClusterInfo, yStream string, connection *sdk.Connection, dryRun bool) ([]*csv1.VersionGateAgreement, error)

func SortClusters

func SortClusters(clusters []*ClusterInfo)

Types

type ClusterInfo

type ClusterInfo struct {
	Subscription          *amv1.Subscription
	Cluster               *csv1.Cluster
	VersionGateAgreements *map[string]*csv1.VersionGateAgreement
	Policy                *policy.ClusterUpgradePolicy
}

func ClusterInfosForOrganization

func ClusterInfosForOrganization(organizationId string, subscriptionSearchQuery string, withAgreements bool, connection *sdk.Connection) ([]*ClusterInfo, error)

func GetClusterInfoByName

func GetClusterInfoByName(organizationID string, clusterName string, connection *sdk.Connection) (*ClusterInfo, error)

func (*ClusterInfo) AvailableUpgrades

func (c *ClusterInfo) AvailableUpgrades(considerBlockedVersions bool, additionalBlockedVersions []*regexp.Regexp) []string

func (*ClusterInfo) MissingGateAgreements

func (c *ClusterInfo) MissingGateAgreements(additionalBlockedVersions []*regexp.Regexp, gates map[string][]*csv1.VersionGate) ([]*csv1.VersionGate, error)

func (*ClusterInfo) STSEnabled

func (c *ClusterInfo) STSEnabled() bool

func (*ClusterInfo) YStreamUpgrades

func (c *ClusterInfo) YStreamUpgrades(considerBlockedVersions bool, additionalBlockedVersions []*regexp.Regexp) []string

func (*ClusterInfo) YStreamsWithMissingSTSGateAgreements

func (c *ClusterInfo) YStreamsWithMissingSTSGateAgreements(additionalBlockedVersions []*regexp.Regexp, gates map[string][]*csv1.VersionGate) ([]string, error)