utils

Documentation

Overview

Copyright Contributors to the Open Cluster Management project.

Index

• Constants
• Variables
• func CheckError(err error)
• func ConvertMap(m interface{}) interface{}
• func DeleteClusterNamespace(client kubernetes.Interface, clusterName string) error
• func GetClient() (clientv1.Client, error)
• func GetClusterCurator(client clientv1.Client, clusterName string, clusterNamespace string) (*clustercuratorv1.ClusterCurator, error)
• func GetClusterType(hiveset hiveclient.Interface, dc dynamic.Interface, clusterName string, ...) (string, error)
• func GetCurrentVersionInfo(curator *clustercuratorv1.ClusterCurator) string
• func GetDynset(dynset dynamic.Interface) (dynamic.Interface, error)
• func GetKubeset() (kubernetes.Interface, error)
• func GetMonitorAttempts(jobType string, curator *clustercuratorv1.ClusterCurator) int
• func GetRetryTimes(timeout, defaultTimeout int, interval time.Duration) int
• func InitKlog(logLevel int)
• func LogError(err error) error
• func LogWarning(err error)
• func NeedToUpgrade(curator clustercuratorv1.ClusterCurator) (bool, error)
• func PathSplitterFromEnv(path string) (namespace string, resource string, err error)
• func RecordAnsibleJobStatusUrlCondition(client clientv1.Client, clusterName string, clusterNamespace string, ...) error
• func RecordCuratorJob(clusterName, containerName string) error
• func RecordCuratorJobName(client clientv1.Client, clusterName string, clusterNamespace string, ...) error
• func RecordCurrentStatusCondition(client clientv1.Client, clusterName string, clusterNamespace string, ...) error
• func RecordFailedCuratorStatusCondition(client clientv1.Client, clusterName string, clusterNamespace string, ...) error
• type PatchStringValue

Constants

const CurrentAnsibleJob = "active-ansible-job"

const CurrentCuratorContainer = "curating-with-container"

const CurrentCuratorJob = "curatorJob"

const CurrentHiveJob = "hive-provisioning-job"

const DefaultImageURI = "registry.ci.openshift.org/open-cluster-management/cluster-curator-controller:latest"

const Destroying = "uninstall"

const HypershiftClusterType = "hypershift"

const Installing = "provision"

const JobFailed = "Job_failed"

const JobHasFinished = "Job_has_finished"

const LogVerbosity = 2

const PauseFiveSeconds = PauseTenSeconds / 2

const PauseSixtySeconds = 60 * time.Second

const PauseTenSeconds = PauseTwoSeconds * 5

const PauseTwoSeconds = 2 * time.Second

const StandaloneClusterType = "standalone"

Variables

var CCGVR = schema.GroupVersionResource{
	Group:    "cluster.open-cluster-management.io",
	Version:  "v1beta1",
	Resource: "clustercurators",
}

var HCGVR = schema.GroupVersionResource{
	Group:    "hypershift.openshift.io",
	Version:  "v1beta1",
	Resource: "hostedclusters",
}

var NPGVR = schema.GroupVersionResource{
	Group:    "hypershift.openshift.io",
	Version:  "v1beta1",
	Resource: "nodepools",
}

Functions

func CheckError

func CheckError(err error)

Simple error function

func ConvertMap

func ConvertMap(m interface{}) interface{}

Because Unmarshal for map[string]interface{}, uses map[interface{}]interface{} above the root leaf, runtime client does not support it.

func DeleteClusterNamespace

func DeleteClusterNamespace(client kubernetes.Interface, clusterName string) error

func GetClient

func GetClient() (clientv1.Client, error)

func GetClusterCurator

func GetClusterCurator(
	client clientv1.Client,
	clusterName string,
	clusterNamespace string) (*clustercuratorv1.ClusterCurator, error)

func GetClusterType

func GetClusterType(
	hiveset hiveclient.Interface,
	dc dynamic.Interface,
	clusterName string,
	clusterNamespace string,
	isUpgrade bool) (string, error)

func GetCurrentVersionInfo

func GetCurrentVersionInfo(curator *clustercuratorv1.ClusterCurator) string

func GetDynset

func GetDynset(dynset dynamic.Interface) (dynamic.Interface, error)

func GetKubeset

func GetKubeset() (kubernetes.Interface, error)

func GetMonitorAttempts

func GetMonitorAttempts(jobType string, curator *clustercuratorv1.ClusterCurator) int

func GetRetryTimes

func GetRetryTimes(timeout, defaultTimeout int, interval time.Duration) int

func InitKlog

func InitKlog(logLevel int)

func LogError

func LogError(err error) error

func LogWarning

func LogWarning(err error)

func NeedToUpgrade

func NeedToUpgrade(curator clustercuratorv1.ClusterCurator) (bool, error)

func PathSplitterFromEnv

func PathSplitterFromEnv(path string) (namespace string, resource string, err error)

Path splitter NAMSPACE/RESOURCE_NAME

func RecordAnsibleJobStatusUrlCondition

func RecordAnsibleJobStatusUrlCondition(
	client clientv1.Client,
	clusterName string,
	clusterNamespace string,
	containerName string,
	conditionStatus v1.ConditionStatus,
	url string) error

func RecordCuratorJob

func RecordCuratorJob(clusterName, containerName string) error

func RecordCuratorJobName

func RecordCuratorJobName(
	client clientv1.Client,
	clusterName string,
	clusterNamespace string,
	curatorJobName string) error

func RecordCurrentStatusCondition

func RecordCurrentStatusCondition(
	client clientv1.Client,
	clusterName string,
	clusterNamespace string,
	containerName string,
	conditionStatus v1.ConditionStatus,
	message string) error

func RecordFailedCuratorStatusCondition

func RecordFailedCuratorStatusCondition(
	client clientv1.Client,
	clusterName string,
	clusterNamespace string,
	containerName string,
	conditionStatus v1.ConditionStatus,
	message string) error

Types

type PatchStringValue

type PatchStringValue struct {
	Op    string `json:"op"`
	Path  string `json:"path"`
	Value string `json:"value"`
}