utils

package
v0.0.0-...-86260ac Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 1, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterUpgradeManifestName     = "-cluster-upgrade"
	OperatorUpgradeManifestName    = "-operators-upgrade"
	OperatorUpgradeSucceededState  = "succeeded"
	OperatorUpgradeActiveState     = "active"
	OperatorUpgradeFailedState     = "failed"
	OperatorUpgradeValidStateValue = 1
	OseCliDefaultImage             = "registry.redhat.io/openshift4/ose-cli:latest"
	//
	MCGWork_Label   = "managedClusterGroupWork"
	StateCreated    = "ManifestWorkCreated"
	StateNotCreated = "NotCreated"
)
View Source 
const (
	TypeSelected       = "Selected"
	TypeApplied        = "Applied"
	TypeInProgress     = "InProgress"
	TypeComplete       = "Complete"
	TypeFailed         = "Failed"
	TypeCanaryComplete = "CanaryComplete"
	TypeCanaryFailed   = "CanaryFailed"
	TypeCreated        = "Created"
	//
	ReasonApplied               = "ManagedClustersResourcesApplied"
	ReasonNotSelected           = "ManagedClustersNotSelected"
	ReasonSelected              = "ManagedClustersSelected"
	ReasonUpgradeInProgress     = "ManagedClustersUpgradeInProgress"
	ReasonUpgradeFailed         = "ManagedClustersUpgradeFailed"
	ReasonUpgradeCanaryFailed   = "ManagedClustersCanaryUpgradeFailed"
	ReasonUpgradeComplete       = "ManagedClustersUpgradeComplete"
	ReasonUpgradeCanaryComplete = "ManagedClustersCanaryUpgradeComplete"
	ReasonActionsDone           = "ActionsDone"
	ReasonCreated               = "ManifestWorkCreated"
	//
	StateApplied           = "Applied"
	StateNotingApplied     = "NotingApplied"
	StateActionDone        = "ActionsDone"
	StateActionFailed      = "ActionsFailed"
	StateViewProcessing    = "ViewProcessing"
	StateViewNotProcessing = "ViewNotProcessing"
	StatusNotFound         = "StatusNotFound"
	//
	MCGAct_Label   = "managedClusterGroupAct"
	ViewName_Label = "viewName"
)
View Source 
const ClusterRole = `` /* 262-byte string literal not displayed */
View Source 
const ClusterRoleBinding = `` /* 308-byte string literal not displayed */
View Source 
const JobScript = `` /* 1808-byte string literal not displayed */
View Source 
const NS = `
apiVersion: v1
kind: Namespace
metadata:
  name: installplan-approver
`
View Source 
const ServiceAccount = `
apiVersion: v1
kind: ServiceAccount
metadata:
  name: installplan-approver
  namespace: installplan-approver
`

Variables

This section is empty.

Functions

func ConvertLabels 

func ConvertLabels(labelSelector *metav1.LabelSelector) (labels.Selector, error)

ConvertLabels converts LabelSelectors to Selectors

func CreateAction 

func CreateAction(mcgaName string, namespace string, actionSpec actv1beta1.Action) (*actionv1beta1.ManagedClusterAction, error)

func CreateClusterVersionUpgradeManifestWork 

func CreateClusterVersionUpgradeManifestWork(clusterName string, clusterID string, versionConfig *clusterv1beta1.ClusterVersionSpec) (*workv1.ManifestWork, error)

func CreateManifestWork 

func CreateManifestWork(mcgWork *workv1beta1.ManagedClusterGroupWork, clusterNS string) (*workv1.ManifestWork, error)

func CreateOperatorUpgradeManifestWork 

func CreateOperatorUpgradeManifestWork(clusterName string, operatorConfig *clusterv1beta1.OcpOperatorsSpec, timeout string, image string) (*workv1.ManifestWork, error)

func CreateView 

func CreateView(mcgaName string, namespace string, viewSpec actv1beta1.View) (*viewv1beta1.ManagedClusterView, error)

func DeleteMangedClusterView 

func DeleteMangedClusterView(kubeclient client.Client, name string, namespace string) error

func DeleteMangedClusterViews 

func DeleteMangedClusterViews(kubeclient client.Client, mcgAct *actv1beta1.ManagedClusterGroupAct, all bool) error

func DeleteManifestWork 

func DeleteManifestWork(kubeclient client.Client, name string, namespace string) error

func DeleteManifestWorks 

func DeleteManifestWorks(kubeclient client.Client, mcgWorkLabel string) error

func EqualManifestWorkSpec 

func EqualManifestWorkSpec(firstManifestSpec workv1.ManifestWorkSpec, secondManifestSpec workv1.ManifestWorkSpec) bool

func GetActions 

func GetActions(appliedActions string, newActions []actv1beta1.Action) (sets.String, sets.String, map[string]actv1beta1.Action, string)

func GetActionsCompleteCondition 

func GetActionsCompleteCondition(status metav1.ConditionStatus) metav1.Condition

func GetAppliedCondition 

func GetAppliedCondition(status metav1.ConditionStatus) metav1.Condition

func GetAvailableCondition 

func GetAvailableCondition(status metav1.ConditionStatus) metav1.Condition

func GetCanaryCompleteCondition 

func GetCanaryCompleteCondition() metav1.Condition

func GetCanaryFailedCondition 

func GetCanaryFailedCondition(failedCount int) metav1.Condition

func GetClusterUpgradeManifestStatus 

func GetClusterUpgradeManifestStatus(kubeclient client.Client, name string, ns string, timeOut string) (string, string, bool, string, bool, error)

Get the clusterVersion Upgrade status (value); state, version, verified

func GetClusters 

func GetClusters(kubeclient client.Client, placement *clusterv1beta1.Placement, existingClusters sets.String) (sets.String, sets.String, error)

func GetCompleteCondition 

func GetCompleteCondition() metav1.Condition

func GetCreatedCondition 

func GetCreatedCondition(status metav1.ConditionStatus) metav1.Condition

func GetFailedCondition 

func GetFailedCondition(failedCount int) metav1.Condition

func GetFailedConditionMessage 

func GetFailedConditionMessage(failedCount int) string

func GetInProgressCondition 

func GetInProgressCondition() metav1.Condition

func GetManagedClusterActionStatus 

func GetManagedClusterActionStatus(mClusteAction *actionv1beta1.ManagedClusterAction) (bool, string, error)

func GetManagedClusterList 

func GetManagedClusterList(kubeclient client.Client, placement common.GenericPlacementFields, existingClusters sets.String) (map[string]*clusterv1.ManagedCluster, sets.String, sets.String, error)

Get ManagedCluster list based on the given label selector

func GetManagedClusterViewStatus 

func GetManagedClusterViewStatus(mClusteView *viewv1beta1.ManagedClusterView) (bool, string, error)

func GetMangedClusterActions 

func GetMangedClusterActions(kubeclient client.Client, mcgaName string, namespace string) (map[string]*actionv1beta1.ManagedClusterAction, error)

func GetMangedClusterViews 

func GetMangedClusterViews(kubeclient client.Client, mcgaName string, namespace string) (map[string]*viewv1beta1.ManagedClusterView, error)

func GetManifestWorkStatus 

func GetManifestWorkStatus(manifestWork *workv1.ManifestWork) string

func GetManifestWorks 

func GetManifestWorks(kubeclient client.Client, name string, namespace string) (map[string]*workv1.ManifestWork, error)

func GetOperatorUpgradeManifestStatus 

func GetOperatorUpgradeManifestStatus(kubeclient client.Client, name string, ns string, timeOut string) (string, int, bool, error)

Get the Operator Upgrade Job status (name, value); active, succeeded or failed

func GetPlacement 

func GetPlacement(kubeclient client.Client, name string, ns string) (*clusterv1beta1.Placement, error)

func GetProcessingCondition 

func GetProcessingCondition(status metav1.ConditionStatus) metav1.Condition

func GetSelectedCondition 

func GetSelectedCondition(numClusters int) metav1.Condition

func IsManifestWorkResourcesAvailable 

func IsManifestWorkResourcesAvailable(kubeclient client.Client, name string, ns string, timeOut string) (bool, bool, error)

Types

type PlacementDecisionGetter 

type PlacementDecisionGetter struct {
	Client client.Client
}

func (PlacementDecisionGetter) List 

func (pdl PlacementDecisionGetter) List(selector labels.Selector, namespace string) ([]*clusterv1beta1.PlacementDecision, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.