Documentation ¶
Index ¶
- func CreateClusterIDP(connection *client.Connection, clusterID string, body *cmv1.IdentityProvider) (*cmv1.IdentityProvidersAddResponse, error)
- func DeleteIDP(connection *client.Connection, clusterID string, idpID string) (*cmv1.IdentityProviderDeleteResponse, error)
- func DeleteMachinePool(connection *client.Connection, clusterID string, mpID string) (*cmv1.MachinePoolDeleteResponse, error)
- func FindAnUpgradeVersion(connection *client.Connection) string
- func GetDefaultVersion(connection *client.Connection) *v1.Version
- func GetGreaterOrEqualVersions(connection *client.Connection, throttleVersion string, channel string, ...) (versions []string)
- func GetGreaterVersions(connection *client.Connection, throttleVersion string, channel string, ...) (versions []string)
- func GetHcpHigherVersions(connection *client.Connection, throttleVersion string, channel string) (versions []string)
- func GetHcpLowerVersions(connection *client.Connection, throttleVersion string, channel string) (versions []string)
- func GetLowerOrEqualVersions(connection *client.Connection, throttleVersion string, channel string, ...) (versions []string)
- func GetLowerVersions(connection *client.Connection, throttleVersion string, channel string, ...) (versions []string)
- func GetRawVersionList(imageVersions []*ImageVersion) []string
- func GetUpgradePolicyState(connection *client.Connection, clusterID string, upgradepolicyID string) (*cmv1.UpgradePolicyStateGetResponse, error)
- func GetVersionUpgradeTarget(orginalVersion string, stream string, availableUpgrades []string) (targetV string, err error)
- func IsStreamUpgrade(version string, upgradeVersion string, stream string) (isStreamUpgrade bool, err error)
- func ListAvailableRegions(connection *client.Connection, providerID string, body *cmv1.AWS) (*cmv1.AvailableRegionsSearchResponse, error)
- func ListCloudProviders(connection *client.Connection, params ...map[string]interface{}) (*cmv1.CloudProvidersListResponse, error)
- func ListClusterExternalConfiguration(connection *client.Connection, clusterID string) (*cmv1.ExternalConfigurationGetResponse, error)
- func ListClusterGroupUsers(connection *client.Connection, clusterID string, groupID string) (*cmv1.UsersListResponse, error)
- func ListClusterGroups(connection *client.Connection, clusterID string) (*cmv1.GroupsListResponse, error)
- func ListClusterIDPs(connection *client.Connection, clusterID string) (*cmv1.IdentityProvidersListResponse, error)
- func ListClusterLabels(connection *client.Connection, clusterID string, ...) (*cmv1.LabelsListResponse, error)
- func ListClusterResources(connection *client.Connection, clusterID string) (*cmv1.ClusterResourcesGetResponse, error)
- func ListClusters(connection *client.Connection, parameters ...map[string]interface{}) (response *cmv1.ClustersListResponse, err error)
- func ListHtpasswdUsers(connection *client.Connection, clusterID string, IDPID string) (*cmv1.HTPasswdUsersListResponse, error)
- func ListIDPs(connection *client.Connection, clusterID string) (*cmv1.IdentityProvidersListResponse, error)
- func ListMachinePool(connection *client.Connection, clusterID string, ...) (*cmv1.MachinePoolsListResponse, error)
- func ListMachineTypes(connection *client.Connection, params ...map[string]interface{}) (*cmv1.MachineTypesListResponse, error)
- func ListRegions(connection *client.Connection, providerID string, ...) (*cmv1.CloudRegionsListResponse, error)
- func ListUpgradePolicies(connection *client.Connection, clusterID string, ...) (*cmv1.UpgradePoliciesListResponse, error)
- func ListVersions(connection *client.Connection, parameter ...map[string]interface{}) (resp *cmv1.VersionsListResponse, err error)
- func PatchIDP(connection *client.Connection, clusterID string, idpID string, ...) (*cmv1.IdentityProviderUpdateResponse, error)
- func RetrieveCloudProviderDetail(connection *client.Connection, providerID string) (*cmv1.CloudProviderGetResponse, error)
- func RetrieveClusterCPUTotalByNodeRolesOS(connection *client.Connection, clusterID string) (*cmv1.CPUTotalByNodeRolesOSMetricQueryGetResponse, error)
- func RetrieveClusterCredentials(connection *client.Connection, clusterID string) (*cmv1.CredentialsGetResponse, error)
- func RetrieveClusterDetail(connection *client.Connection, clusterID string) (*cmv1.ClusterGetResponse, error)
- func RetrieveClusterGroupDetail(connection *client.Connection, clusterID string, groupID string) (*cmv1.GroupGetResponse, error)
- func RetrieveClusterGroupUserDetail(connection *client.Connection, clusterID string, groupID string, userID string) (*cmv1.UserGetResponse, error)
- func RetrieveClusterIDPDetail(connection *client.Connection, clusterID string, IDPID string) (*cmv1.IdentityProviderGetResponse, error)
- func RetrieveClusterInstallLogDetail(connection *client.Connection, clusterID string, ...) (*cmv1.LogGetResponse, error)
- func RetrieveClusterMachinePool(connection *client.Connection, clusterID string, machinePoolID string) (*cmv1.MachinePool, error)
- func RetrieveClusterSocketTotalByNodeRolesOS(connection *client.Connection, clusterID string) (*cmv1.SocketTotalByNodeRolesOSMetricQueryGetResponse, error)
- func RetrieveClusterStatus(connection *client.Connection, clusterID string) (*cmv1.ClusterStatusGetResponse, error)
- func RetrieveClusterUninstallLogDetail(connection *client.Connection, clusterID string, ...) (*cmv1.LogGetResponse, error)
- func RetrieveCurrentAccount(connection *client.Connection, params ...map[string]interface{}) (resp *v1.CurrentAccountGetResponse, err error)
- func RetrieveDetailedIngressOfCluster(connection *client.Connection, clusterID string, ingressID string) (*cmv1.IngressGetResponse, error)
- func RetrieveDetailedLabelOfCluster(connection *client.Connection, clusterID string, labelID string) (*cmv1.LabelGetResponse, error)
- func RetrieveIDP(connection *client.Connection, clusterID string, idpID string) (*cmv1.IdentityProviderGetResponse, error)
- func RetrieveKubeletConfig(connection *client.Connection, clusterID string) (*cmv1.KubeletConfig, error)
- func RetrieveMachineTypeDetail(connection *client.Connection, machineTypeID string) (*client.Response, error)
- func RetrieveRegionDetail(connection *client.Connection, providerID string, regionID string) (*cmv1.CloudRegionGetResponse, error)
- func RetrieveUpgradePolicies(connection *client.Connection, clusterID string, upgradepolicyID string) (*cmv1.UpgradePolicyGetResponse, error)
- func RetrieveVersionDetail(connection *client.Connection, versionID string) (*cmv1.VersionGetResponse, error)
- func SortRawVersions(versionList []string) []string
- type ImageVersion
- func EnabledVersions(connection *client.Connection, channel string, throttleVersion string, ...) []*ImageVersion
- func GetOneSpecifiedVersion(versionList []*ImageVersion, index string) *ImageVersion
- func GetVersionsWithUpgrades(connection *client.Connection, channel string, stream string, rosaEnabled bool, ...) (imageVersionList []*ImageVersion, err error)
- func HCPEnabledVersions(connection *client.Connection, channel string, upgradeAvailable ...bool) []*ImageVersion
- func SortVersions(versionList []*ImageVersion) []*ImageVersion
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateClusterIDP ¶ added in v1.5.1
func CreateClusterIDP(connection *client.Connection, clusterID string, body *cmv1.IdentityProvider) (*cmv1.IdentityProvidersAddResponse, 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 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 GetHcpHigherVersions ¶ added in v1.4.0
func GetHcpHigherVersions(connection *client.Connection, throttleVersion string, channel string) (versions []string)
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 []string)
It will return all the versions lower that throttle version for the specified channel
func GetLowerOrEqualVersions ¶ added in v1.4.0
func GetLowerVersions ¶ added in v1.4.0
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 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 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 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 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 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 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 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 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 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 RetrieveMachineTypeDetail ¶
func RetrieveMachineTypeDetail(connection *client.Connection, machineTypeID string) (*client.Response, error)
RetrieveMachineTypeDetail will return the retrieve result of machine type detailed information
func RetrieveRegionDetail ¶
func RetrieveRegionDetail(connection *client.Connection, providerID string, regionID string) (*cmv1.CloudRegionGetResponse, 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
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 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 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.