cms

package
v1.6.5-prerelease.1 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RHCSConnection = createConnectionWithToken(RHCSOCMToken)
)

Regular users in the organization 'Red Hat-Service Delivery-tester'

View Source 
var (
	RHCSOCMToken = os.Getenv(CON.TokenENVName)
)

Functions

func CreateClusterAutoscaler added in v1.6.3 

func CreateClusterAutoscaler(connection *client.Connection, clusterID string, body *cmv1.ClusterAutoscaler) (*cmv1.AutoscalerPostResponse, error)

func CreateClusterIDP added in v1.5.1 

func CreateClusterIDP(connection *client.Connection, clusterID string, body *cmv1.IdentityProvider) (*cmv1.IdentityProvidersAddResponse, error)

func DeleteCluster added in v1.6.3 

func DeleteCluster(connection *client.Connection, clusterID string, params ...map[string]interface{}) (*cmv1.ClusterDeleteResponse, error)

Delete cluster

func DeleteClusterAutoscaler added in v1.6.3 

func DeleteClusterAutoscaler(connection *client.Connection, clusterID string) (*cmv1.AutoscalerDeleteResponse, error)

func DeleteIDP added in v1.5.0 

func DeleteIDP(connection *client.Connection, clusterID string, idpID string) (*cmv1.IdentityProviderDeleteResponse, error)

func DeleteMachinePool added in v1.5.1 

func DeleteMachinePool(connection *client.Connection, clusterID string, mpID string) (*cmv1.MachinePoolDeleteResponse, error)

func FindAnUpgradeVersion added in v1.4.0 

func FindAnUpgradeVersion(connection *client.Connection) string

func GetDefaultVersion added in v1.4.0 

func GetDefaultVersion(connection *client.Connection) *v1.Version

GetGreaterVersions will return a version list which is euqal or greater than the version provided as throttleVersion

func GetGreaterOrEqualVersions added in v1.4.0 

func GetGreaterOrEqualVersions(connection *client.Connection, throttleVersion string, channel string, onlyRosa bool, upgradeRequired bool) (versions []string)

func GetGreaterVersions added in v1.4.0 

func GetGreaterVersions(connection *client.Connection, throttleVersion string, channel string, onlyRosa bool, upgradeRequired bool) (versions []string)

GetGreaterVersions will return a version list which is euqal or greater than the version provided as throttleVersion

func GetLowerOrEqualVersions added in v1.4.0 

func GetLowerOrEqualVersions(connection *client.Connection, throttleVersion string, channel string, onlyRosa bool, upgradeRequired bool) (versions []string)

func GetLowerVersions added in v1.4.0 

func GetLowerVersions(connection *client.Connection, throttleVersion string, channel string, onlyRosa bool, upgradeRequired bool) (versions []string)

func GetRawVersionList added in v1.5.1 

func GetRawVersionList(imageVersions []*ImageVersion) []string

func GetUpgradePolicyState added in v1.5.1 

func GetUpgradePolicyState(connection *client.Connection, clusterID string, upgradepolicyID string) (*cmv1.UpgradePolicyStateGetResponse, error)

func GetVersionUpgradeTarget added in v1.4.0 

func GetVersionUpgradeTarget(orginalVersion string, stream string, availableUpgrades []string) (targetV string, err error)

It will return a list of versions which have available upgrades in both y and z Streams

func IsStreamUpgrade added in v1.4.0 

func IsStreamUpgrade(version string, upgradeVersion string, stream string) (isStreamUpgrade bool, err error)

checks if upgradeVersion is a 'stream' upgrade for version

func ListAvailableRegions 

func ListAvailableRegions(connection *client.Connection, providerID string, body *cmv1.AWS) (
	*cmv1.AvailableRegionsSearchResponse, error)

func ListCloudProviders 

func ListCloudProviders(connection *client.Connection, params ...map[string]interface{}) (*cmv1.CloudProvidersListResponse, error)

func ListClusterExternalConfiguration 

func ListClusterExternalConfiguration(connection *client.Connection, clusterID string) (*cmv1.ExternalConfigurationGetResponse, error)

Cluster labels

func ListClusterGroupUsers 

func ListClusterGroupUsers(connection *client.Connection, clusterID string, groupID string) (*cmv1.UsersListResponse, error)

func ListClusterGroups 

func ListClusterGroups(connection *client.Connection, clusterID string) (*cmv1.GroupsListResponse, error)

ListClusterGroups will return cluster groups

func ListClusterIDPs 

func ListClusterIDPs(connection *client.Connection, clusterID string) (*cmv1.IdentityProvidersListResponse, error)

func ListClusterLabels 

func ListClusterLabels(connection *client.Connection, clusterID string, parameter ...map[string]interface{}) (*cmv1.LabelsListResponse, error)

func ListClusterResources added in v1.5.1 

func ListClusterResources(connection *client.Connection, clusterID string) (*cmv1.ClusterResourcesGetResponse, error)

ListClusterResources will retrieve cluster detailed information about its resources based on the clusterID

func ListClusters 

func ListClusters(connection *client.Connection, parameters ...map[string]interface{}) (response *cmv1.ClustersListResponse, err error)

ListClusters will list the clusters

func ListControlPlaneUpgradePolicies added in v1.6.3 

func ListControlPlaneUpgradePolicies(connection *client.Connection, clusterID string, params ...map[string]interface{}) (*cmv1.ControlPlaneUpgradePoliciesListResponse, error)

ControlPlane Upgrade policies related

func ListHCPKubeletConfigs added in v1.6.3 

func ListHCPKubeletConfigs(connection *client.Connection, clusterID string) ([]*cmv1.KubeletConfig, error)

ListHCPKubeletConfig returns the kubeletconfig

func ListHtpasswdUsers 

func ListHtpasswdUsers(connection *client.Connection, clusterID string, IDPID string) (*cmv1.HTPasswdUsersListResponse, error)

func ListIDPs 

func ListIDPs(connection *client.Connection, clusterID string) (*cmv1.IdentityProvidersListResponse, error)

func ListMachinePool 

func ListMachinePool(connection *client.Connection, clusterID string, params ...map[string]interface{}) (*cmv1.MachinePoolsListResponse, error)

Machine Pool related

func ListMachineTypes 

func ListMachineTypes(connection *client.Connection, params ...map[string]interface{}) (*cmv1.MachineTypesListResponse, error)

ListMachineTypes will list the machine types

func ListNodePoolUpgradePolicies added in v1.6.3 

func ListNodePoolUpgradePolicies(connection *client.Connection, clusterID string, npID string, params ...map[string]interface{}) (*cmv1.NodePoolUpgradePoliciesListResponse, error)

NodePool Upgrade policies related

func ListNodePools added in v1.6.3 

func ListNodePools(connection *client.Connection, clusterID string, parameter ...map[string]interface{}) ([]*cmv1.NodePool, error)

RetrieveNodePool returns the nodePool detail of HCP

func ListRegions 

func ListRegions(connection *client.Connection, providerID string, params ...map[string]interface{}) (*cmv1.CloudRegionsListResponse, error)

ListRegions list the regions of specified cloud providers If params passed, will add parameter to the request

func ListRegistryAllowlists added in v1.6.5 

func ListRegistryAllowlists(connection *client.Connection) (*cmv1.RegistryAllowlistsListResponse, error)

func ListTuningConfigs added in v1.6.3 

func ListTuningConfigs(connection *client.Connection, clusterID string) (*cmv1.TuningConfigsListResponse, error)

func ListUpgradePolicies 

func ListUpgradePolicies(connection *client.Connection, clusterID string, params ...map[string]interface{}) (*cmv1.UpgradePoliciesListResponse, error)

Upgrade policies related

func ListVersions 

func ListVersions(connection *client.Connection, parameter ...map[string]interface{}) (resp *cmv1.VersionsListResponse, err error)

version

func PatchClusterAutoscaler added in v1.6.3 

func PatchClusterAutoscaler(connection *client.Connection, clusterID string, body *cmv1.ClusterAutoscaler) (*cmv1.AutoscalerUpdateResponse, error)

func PatchIDP added in v1.5.1 

func PatchIDP(connection *client.Connection, clusterID string, idpID string, patchBody *cmv1.IdentityProvider) (*cmv1.IdentityProviderUpdateResponse, error)

func RetrieveCloudProviderDetail 

func RetrieveCloudProviderDetail(connection *client.Connection, providerID string) (*cmv1.CloudProviderGetResponse, error)

func RetrieveClusterAutoscaler added in v1.6.3 

func RetrieveClusterAutoscaler(connection *client.Connection, clusterID string) (*cmv1.AutoscalerGetResponse, error)

func RetrieveClusterCPUTotalByNodeRolesOS 

func RetrieveClusterCPUTotalByNodeRolesOS(connection *client.Connection, clusterID string) (*cmv1.CPUTotalByNodeRolesOSMetricQueryGetResponse, error)

RetrieveClusterCPUTotalByNodeRolesOS will return the physical cpu_total of the compute nodes of the cluster

func RetrieveClusterCredentials 

func RetrieveClusterCredentials(connection *client.Connection, clusterID string) (*cmv1.CredentialsGetResponse, error)

RetrieveClusterCredentials will return the response of cluster credentials

func RetrieveClusterDetail 

func RetrieveClusterDetail(connection *client.Connection, clusterID string) (*cmv1.ClusterGetResponse, error)

RetrieveClusterDetail will retrieve cluster detailed information based on the clusterID

func RetrieveClusterGroupDetail 

func RetrieveClusterGroupDetail(connection *client.Connection, clusterID string, groupID string) (*cmv1.GroupGetResponse, error)

RetrieveClusterGroupDetail will return cluster specified group information

func RetrieveClusterGroupUserDetail 

func RetrieveClusterGroupUserDetail(connection *client.Connection, clusterID string, groupID string, userID string) (*cmv1.UserGetResponse, error)

func RetrieveClusterIDPDetail 

func RetrieveClusterIDPDetail(connection *client.Connection, clusterID string, IDPID string) (*cmv1.IdentityProviderGetResponse, error)

func RetrieveClusterIngress added in v1.6.3 

func RetrieveClusterIngress(connection *client.Connection, clusterID string) (*cmv1.Ingress, error)

RetrieveClusterIngress will retrieve default ingress detail information based on the clusterID

func RetrieveClusterInstallLogDetail 

func RetrieveClusterInstallLogDetail(connection *client.Connection, clusterID string,
	parameter ...map[string]interface{}) (*cmv1.LogGetResponse, error)

RetrieveClusterLogDetail return the log response based on parameter

func RetrieveClusterMachinePool 

func RetrieveClusterMachinePool(connection *client.Connection, clusterID string, machinePoolID string) (*cmv1.MachinePool, error)

func RetrieveClusterNodePool added in v1.6.3 

func RetrieveClusterNodePool(connection *client.Connection, clusterID string, machinePoolID string) (*cmv1.NodePool, error)

func RetrieveClusterSocketTotalByNodeRolesOS 

func RetrieveClusterSocketTotalByNodeRolesOS(connection *client.Connection, clusterID string) (*cmv1.SocketTotalByNodeRolesOSMetricQueryGetResponse, error)

RetrieveClusterSocketTotalByNodeRolesOS will return the physical socket_total of the compute nodes of the cluster

func RetrieveClusterStatus 

func RetrieveClusterStatus(connection *client.Connection, clusterID string) (*cmv1.ClusterStatusGetResponse, error)

func RetrieveClusterUninstallLogDetail 

func RetrieveClusterUninstallLogDetail(connection *client.Connection, clusterID string,
	parameter ...map[string]interface{}) (*cmv1.LogGetResponse, error)

RetrieveClusterUninstallLogDetail return the uninstall log response based on parameter

func RetrieveControlPlaneUpgradePolicy added in v1.6.3 

func RetrieveControlPlaneUpgradePolicy(connection *client.Connection, clusterID string, upgradepolicyID string) (*cmv1.ControlPlaneUpgradePolicyGetResponse, error)

func RetrieveCurrentAccount added in v1.5.0 

func RetrieveCurrentAccount(connection *client.Connection, params ...map[string]interface{}) (resp *v1.CurrentAccountGetResponse, err error)

RetrieveCurrentAccount return the response of retrieve current account

func RetrieveDetailedIngressOfCluster 

func RetrieveDetailedIngressOfCluster(connection *client.Connection, clusterID string, ingressID string) (*cmv1.IngressGetResponse, error)

func RetrieveDetailedLabelOfCluster 

func RetrieveDetailedLabelOfCluster(connection *client.Connection, clusterID string, labelID string) (*cmv1.LabelGetResponse, error)

func RetrieveHCPKubeletConfig added in v1.6.3 

func RetrieveHCPKubeletConfig(connection *client.Connection, clusterID string, kubeConfigID string) (*cmv1.KubeletConfig, error)

RetrieveHCPKubeletConfig returns the kubeletconfig

func RetrieveIDP 

func RetrieveIDP(connection *client.Connection, clusterID string, idpID string) (*cmv1.IdentityProviderGetResponse, error)

func RetrieveKubeletConfig added in v1.5.1 

func RetrieveKubeletConfig(connection *client.Connection, clusterID string) (*cmv1.KubeletConfig, error)

RetrieveKubeletConfig returns the kubeletconfig

func RetrieveNodePool added in v1.6.3 

func RetrieveNodePool(connection *client.Connection, clusterID string, npID string, parameter ...map[string]interface{}) (*cmv1.NodePool, error)

RetrieveNodePool returns the nodePool detail of HCP

func RetrieveNodePoolUpgradePolicy added in v1.6.3 

func RetrieveNodePoolUpgradePolicy(connection *client.Connection, clusterID string, npID string, upgradepolicyID string) (*cmv1.NodePoolUpgradePolicyGetResponse, error)

func RetrieveRegionDetail 

func RetrieveRegionDetail(connection *client.Connection, providerID string, regionID string) (*cmv1.CloudRegionGetResponse, error)

func RetrieveRegistryAllowlist added in v1.6.5 

func RetrieveRegistryAllowlist(connection *client.Connection, allowlistID string) (*cmv1.RegistryAllowlistGetResponse, error)

func RetrieveTuningConfig added in v1.6.3 

func RetrieveTuningConfig(connection *client.Connection, clusterID string, tcName string) (*cmv1.TuningConfigGetResponse, error)

func RetrieveUpgradePolicies 

func RetrieveUpgradePolicies(connection *client.Connection, clusterID string, upgradepolicyID string) (*cmv1.UpgradePolicyGetResponse, error)

func RetrieveVersionDetail 

func RetrieveVersionDetail(connection *client.Connection, versionID string) (*cmv1.VersionGetResponse, error)

func SortRawVersions added in v1.4.0 

func SortRawVersions(versionList []string) []string

func WaitClusterDeleted added in v1.6.3 

func WaitClusterDeleted(connection *client.Connection, clusterID string, timeoutMinute ...int) error

Wait for cluster deleted via OCM

Types

type ImageVersion added in v1.4.0 

type ImageVersion struct {
	ID           string `json:"id,omitempty"`
	RawID        string `json:"raw_id,omitempty"`
	ChannelGroup string `json:"channel_group,omitempty"`
	Enabled      bool   `json:"enabled,omitempty"`
	Default      bool   `json:"default,omitempty"`
	RosaEnabled  bool   `json:"rosa_enabled,omitempty"`
}

ImageVersion

func EnabledVersions added in v1.4.0 

func EnabledVersions(connection *client.Connection, channel string, throttleVersion string, onlyRosa bool, upgradeAvailable ...bool) []*ImageVersion

func GetHcpHigherVersions added in v1.4.0 

func GetHcpHigherVersions(connection *client.Connection, throttleVersion string, channel string) (versions []*ImageVersion)

It will return all the versions higher that throttle version for the specified channel

func GetHcpLowerVersions added in v1.4.0 

func GetHcpLowerVersions(connection *client.Connection, throttleVersion string, channel string) (versions []*ImageVersion)

It will return all the versions lower that throttle version for the specified channel

func GetOneSpecifiedVersion added in v1.4.0 

func GetOneSpecifiedVersion(versionList []*ImageVersion, index string) *ImageVersion

GetOneSpecifiedVersion returns a version with the specified index. The supported index string are one of ['latest', 'mid', 'oldest'], if the index string is an empty string or not belonged to the above list, the index will be a random value. If the version list is empty, will return nil directly.

func GetVersionsWithUpgrades added in v1.4.0 

func GetVersionsWithUpgrades(connection *client.Connection, channel string, stream string, rosaEnabled bool, hcpEnableRequired bool, step int) (imageVersionList []*ImageVersion, err error)

It will return a list of versions which have available upgrades in the specified stream (x,y,z) channel mean channel group you are going to test stream means minor or patch upgrade like 4.x.y if you want x upgrade set stream=x, y upgrade set to stream=y step is a placeholder for future implementation. Only 1 supported now

func GetVersionsWithUpgradesToVersion added in v1.6.3 

func GetVersionsWithUpgradesToVersion(connection *client.Connection, targetVersion string, channel string, stream string, rosaEnabled bool, hcpEnableRequired bool, step int) (imageVersionList []*ImageVersion, err error)

It will return a list of versions which have available upgrades in the specified stream (x,y,z) channel mean channel group you are going to test stream means minor or patch upgrade like 4.x.y if you want x upgrade set stream=x, y upgrade set to stream=y step is a placeholder for future implementation. Only 1 supported now

func HCPEnabledVersions added in v1.4.0 

func HCPEnabledVersions(connection *client.Connection, channel string, upgradeAvailable ...bool) []*ImageVersion

func SortVersions added in v1.4.0 

func SortVersions(versionList []*ImageVersion) []*ImageVersion

SortVersions sort the version list from lower to higher.

type Response added in v1.6.5 

type Response struct {
	StatusCode int
	Body       []byte
}

func (*Response) Bytes added in v1.6.5 

func (r *Response) Bytes() []byte

func (*Response) Status added in v1.6.5 

func (r *Response) Status() int

func (*Response) String added in v1.6.5 

func (r *Response) String() string

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.