rosacli

package
v1.2.41-rc3 Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const VersionChannelGroupCandidate = "candidate"
View Source 
const VersionChannelGroupNightly = "nightly"
View Source 
const VersionChannelGroupStable = "stable"

Variables

View Source 
var RoleTypeSuffixMap = map[string]string{
	"Installer":     "Installer-Role",
	"Support":       "Support-Role",
	"Control plane": "ControlPlane-Role",
	"Worker":        "Worker-Role",
}

Functions

func Convert 

func Convert(i interface{}) interface{}

func ConvertMapKey 

func ConvertMapKey(m map[string]interface{}) map[string]interface{}

func GenerateReportLog added in v1.2.40 

func GenerateReportLog()

func GenerateReportXMLFile added in v1.2.40 

func GenerateReportXMLFile() (int, int, map[string][]Testcase, map[string][]Testcase)

func GetCommitAuthor added in v1.2.39 

func GetCommitAuthor() (string, error)

func GetCommitFoucs added in v1.2.39 

func GetCommitFoucs() (string, error)

func GetExecutedTestCases added in v1.2.40 

func GetExecutedTestCases(testsuite *Testsuite) ([]Testcase, []Testcase, []Testcase)

func ListFiles added in v1.2.40 

func ListFiles(dir string, subfix string) []string

func MapStructure 

func MapStructure(m map[string]interface{}, i interface{}) error

mapStructure will map the map to the address of the structre *i

func NewRunner 

func NewRunner() *runner

func ReadLines 

func ReadLines(in bytes.Buffer) [][]byte

Read the cmd input and return the []byte array

func RetrieveDesiredComputeNodes 

func RetrieveDesiredComputeNodes(clusterDescription *ClusterDescription) (nodesNb int, err error)

Types

type AccountRole 

type AccountRole struct {
	RoleName         string `json:"ROLE NAME,omitempty"`
	RoleType         string `json:"ROLE TYPE,omitempty"`
	RoleArn          string `json:"ROLE ARN,omitempty"`
	OpenshiftVersion string `json:"OPENSHIFT VERSION,omitempty"`
	AWSManaged       string `json:"AWS Managed,omitempty"`
}

type AccountRoleList 

type AccountRoleList struct {
	AccountRoleList []*AccountRole `json:"AccountRoleList,omitempty"`
}

func (AccountRoleList) AccountRole 

func (arl AccountRoleList) AccountRole(arn string) (accountRole *AccountRole)

Get specified account role by the arn

func (AccountRoleList) AccountRoles 

func (arl AccountRoleList) AccountRoles(prefix string) (accountRoles []*AccountRole)

Get specified account roles by prefix

func (AccountRoleList) DigAccountRoles added in v1.2.39 

func (arl AccountRoleList) DigAccountRoles(prefix string, hcp bool) *AccountRolesUnit

Get all specified account roles by prefix and classic

func (AccountRoleList) InstallerRole 

func (arl AccountRoleList) InstallerRole(prefix string, hostedcp bool) (accountRole *AccountRole)

type AccountRolesUnit added in v1.2.39 

type AccountRolesUnit struct {
	InstallerRole    string `json:"Installer,omitempty"`
	SupportRole      string `json:"Support,omitempty"`
	WorkerRole       string `json:"Worker,omitempty"`
	ControlPlaneRole string `json:"Control plane,omitempty"`
}

type AccountsInfo 

type AccountsInfo struct {
	AWSArn                    string `json:"AWS ARN,omitempty"`
	AWSAccountID              string `json:"AWS Account ID,omitempty"`
	AWSDefaultRegion          string `json:"AWS Default Region,omitempty"`
	OCMApi                    string `json:"OCM API,omitempty"`
	OCMAccountEmail           string `json:"OCM Account Email,omitempty"`
	OCMAccountID              string `json:"OCM Account ID,omitempty"`
	OCMAccountName            string `json:"OCM Account Name,omitempty"`
	OCMAccountUsername        string `json:"OCM Account Username,omitempty"`
	OCMOrganizationExternalID string `json:"OCM Organization External ID,omitempty"`
	OCMOrganizationID         string `json:"OCM Organization ID,omitempty"`
	OCMOrganizationName       string `json:"OCM Organization Name,omitempty"`
}

type AutoScalerDescription added in v1.2.41 

type AutoScalerDescription struct {
	BalanceSimilarNodeGroups      string                   `yaml:"Balance Similar Node Groups,omitempty"`
	SkipNodesWithLocalStorage     string                   `yaml:"Skip Nodes With Local Storage,omitempty"`
	LogVerbosity                  string                   `yaml:"Log Verbosity,omitempty"`
	LabelsIgnoredForNodeBalancing string                   `yaml:"Labels Ignored For Node Balancing,omitempty"`
	IgnoreDaemonSetsUtilization   string                   `yaml:"Ignore DaemonSets Utilization,omitempty"`
	MaxNodeProvisionTime          string                   `yaml:"Maximum Node Provision Time,omitempty"`
	MaxPodGracePeriod             string                   `yaml:"Max Pod Grace Period,omitempty"`
	PodPriorityThreshold          string                   `yaml:"Pod Priority Threshold,omitempty"`
	ResourceLimits                []map[string]interface{} `yaml:"Resource Limits,omitempty"`
	ScaleDown                     []map[string]interface{} `yaml:"Scale Down,omitempty"`
}

type AutoScalerService added in v1.2.41 

type AutoScalerService interface {
	ResourcesCleaner

	CreateAutoScaler(clusterID string, flags ...string) (bytes.Buffer, error)
	DeleteAutoScaler(clusterID string) (bytes.Buffer, error)
	DescribeAutoScaler(clusterID string) (bytes.Buffer, error)
	EditAutoScaler(clusterID string, flags ...string) (bytes.Buffer, error)
	ReflectAutoScalerDescription(result bytes.Buffer) (asd *AutoScalerDescription, err error)
	DescribeAutoScalerAndReflect(clusterID string) (*AutoScalerDescription, error)

	RetrieveHelpForDescribe() (output bytes.Buffer, err error)
	RetrieveHelpForDelete() (output bytes.Buffer, err error)
}

func NewAutoScalerService added in v1.2.41 

func NewAutoScalerService(client *Client) AutoScalerService

type BreakGlassCredential added in v1.2.39 

type BreakGlassCredential struct {
	ID       string `json:"ID,omitempty"`
	Username string `json:"Username,omitempty"`
	Status   string `json:"Status,omitempty"`
}

type BreakGlassCredentialDescription added in v1.2.39 

type BreakGlassCredentialDescription struct {
	ID       string `yaml:"ID,omitempty"`
	Username string `yaml:"Username,omitempty"`
	ExpireAt string `yaml:"Expire at,omitempty"`
	Status   string `yaml:"Status,omitempty"`
}

type BreakGlassCredentialList added in v1.2.39 

type BreakGlassCredentialList struct {
	BreakGlassCredentials []BreakGlassCredential `json:"BreakGlassCredentials,omitempty"`
}

func (BreakGlassCredentialList) IsPresent added in v1.2.39 

func (breakglassCredList BreakGlassCredentialList) IsPresent(userName string) (existed bool, breakGlassCredential *BreakGlassCredential)

Check the breakGlassCredential with the userName exists in the breakGlassCredentialsList

type BreakGlassCredentialService added in v1.2.39 

type BreakGlassCredentialService interface {
	ResourcesCleaner

	CreateBreakGlassCredential(clusterID string, flags ...string) (bytes.Buffer, error)
	DeleteBreakGlassCredential(clusterID string) (bytes.Buffer, error)
	ListBreakGlassCredentials(clusterID string) (bytes.Buffer, error)
	ReflectBreakGlassCredentialLists(result bytes.Buffer) (bgcl *BreakGlassCredentialList, err error)
	DescribeBreakGlassCredential(clusterID string, bgcID string) (bytes.Buffer, error)
	ReflectBreakGlassCredentialDescription(result bytes.Buffer) (bgcd *BreakGlassCredentialDescription, err error)
	GetIssuedCredential(clusterID string, bgcID string) (bytes.Buffer, error)
	WaitForBreakGlassCredentialToStatus(clusterID string, status string, userName string) wait.ConditionFunc

	ListBreakGlassCredentialsAndReflect(clusterID string) (*BreakGlassCredentialList, error)
	DescribeBreakGlassCredentialsAndReflect(clusterID string, bgcID string) (*BreakGlassCredentialDescription, error)

	RetrieveHelpForCreate() (bytes.Buffer, error)
	RetrieveHelpForList() (bytes.Buffer, error)
	RetrieveHelpForDescribe() (bytes.Buffer, error)
	RetrieveHelpForDelete() (bytes.Buffer, error)
}

func NewBreakGlassCredentialService added in v1.2.39 

func NewBreakGlassCredentialService(client *Client) BreakGlassCredentialService

type CLDNamedResourceService 

type CLDNamedResourceService interface {
	ResourcesCleaner

	List(clusterID string) (bytes.Buffer, error)
	Describe(clusterID string, name string) (bytes.Buffer, error)
	Create(clusterID string, name string, flags ...string) (bytes.Buffer, error)
	Edit(clusterID string, name string, flags ...string) (bytes.Buffer, error)
	Delete(clusterID string, name string) (bytes.Buffer, error)
}

type Client 

type Client struct {
	// Clients
	Runner *runner
	Parser *Parser

	// services
	// Keep in alphabetical order
	Cluster              ClusterService
	IDP                  IDPService
	Ingress              IngressService
	KubeletConfig        KubeletConfigService
	MachinePool          MachinePoolService
	MachinePoolUpgrade   MachinePoolUpgradeService
	NetworkVerifier      NetworkVerifierService
	OCMResource          OCMResourceService
	TuningConfig         TuningConfigService
	User                 UserService
	Version              VersionService
	BreakGlassCredential BreakGlassCredentialService
	ExternalAuthProvider ExternalAuthProviderService
	Policy               PolicyService
	AutoScaler           AutoScalerService
}

func NewClient 

func NewClient() *Client

func (*Client) CleanResources 

func (c *Client) CleanResources(clusterID string) error

type CloudRegion 

type CloudRegion struct {
	ID                  string `json:"ID,omitempty"`
	Name                string `json:"NAME,omitempty"`
	MultiAZSupported    string `json:"MULTI-AZ SUPPORT,omitempty"`
	HypershiftSupported string `json:"HOSTED-CP SUPPORT,omitempty"`
}

Struct for the 'rosa list region' output

type ClusterDescription 

type ClusterDescription struct {
	Name                  string                   `yaml:"Name,omitempty"`
	ID                    string                   `yaml:"ID,omitempty"`
	ExternalID            string                   `yaml:"External ID,omitempty"`
	OpenshiftVersion      string                   `yaml:"OpenShift Version,omitempty"`
	ChannelGroup          string                   `yaml:"Channel Group,omitempty"`
	DNS                   string                   `yaml:"DNS,omitempty"`
	AWSAccount            string                   `yaml:"AWS Account,omitempty"`
	AWSBillingAccount     string                   `yaml:"AWS Billing Account,omitempty"`
	APIURL                string                   `yaml:"API URL,omitempty"`
	ConsoleURL            string                   `yaml:"Console URL,omitempty"`
	Region                string                   `yaml:"Region,omitempty"`
	MultiAZ               string                   `yaml:"Multi-AZ,omitempty"`
	State                 string                   `yaml:"State,omitempty"`
	Private               string                   `yaml:"Private,omitempty"`
	Created               string                   `yaml:"Created,omitempty"`
	DetailsPage           string                   `yaml:"Details Page,omitempty"`
	ControlPlane          string                   `yaml:"Control Plane,omitempty"`
	ScheduledUpgrade      string                   `yaml:"Scheduled Upgrade,omitempty"`
	InfraID               string                   `yaml:"Infra ID,omitempty"`
	AdditionalTrustBundle string                   `yaml:"Additional trust bundle,omitempty"`
	Ec2MetadataHttpTokens string                   `yaml:"Ec2 Metadata Http Tokens,omitempty"`
	Availability          []map[string]string      `yaml:"Availability,omitempty"`
	Nodes                 []map[string]interface{} `yaml:"Nodes,omitempty"`
	Network               []map[string]string      `yaml:"Network,omitempty"`
	Proxy                 []map[string]string      `yaml:"Proxy,omitempty"`
	STSRoleArn            string                   `yaml:"Role (STS) ARN,omitempty"`
	// STSExternalID            string                   `yaml:"STS External ID,omitempty"`
	SupportRoleARN           string              `yaml:"Support Role ARN,omitempty"`
	OperatorIAMRoles         []string            `yaml:"Operator IAM Roles,omitempty"`
	InstanceIAMRoles         []map[string]string `yaml:"Instance IAM Roles,omitempty"`
	ManagedPolicies          string              `yaml:"Managed Policies,omitempty"`
	UserWorkloadMonitoring   string              `yaml:"User Workload Monitoring,omitempty"`
	FIPSMod                  string              `yaml:"FIPS mode,omitempty"`
	OIDCEndpointURL          string              `yaml:"OIDC Endpoint URL,omitempty"`
	PrivateHostedZone        []map[string]string `yaml:"Private Hosted Zone,omitempty"`
	AuditLogForwarding       string              `yaml:"Audit Log Forwarding,omitempty"`
	ProvisioningErrorMessage string              `yaml:"Provisioning Error Message,omitempty"`
	ProvisioningErrorCode    string              `yaml:"Provisioning Error Code,omitempty"`
	LimitedSupport           []map[string]string `yaml:"Limited Support,omitempty"`
	AuditLogRoleARN          string              `yaml:"Audit Log Role ARN,omitempty"`
	FailedInflightChecks     string              `yaml:"Failed Inflight Checks,omitempty"`
	ExternalAuthentication   string              `yaml:"External Authentication,omitempty"`
}

Struct for the 'rosa describe cluster' output

type ClusterService 

type ClusterService interface {
	ResourcesCleaner

	DescribeCluster(clusterID string, flags ...string) (bytes.Buffer, error)
	ReflectClusterDescription(result bytes.Buffer) (*ClusterDescription, error)
	DescribeClusterAndReflect(clusterID string) (*ClusterDescription, error)
	List() (bytes.Buffer, error)
	Create(clusterName string, flags ...string) (bytes.Buffer, error, string)
	DeleteCluster(clusterID string, flags ...string) (bytes.Buffer, error)
	CreateDryRun(clusterName string, flags ...string) (bytes.Buffer, error)
	EditCluster(clusterID string, flags ...string) (bytes.Buffer, error)
	DeleteUpgrade(flags ...string) (bytes.Buffer, error)
	Upgrade(flags ...string) (bytes.Buffer, error)
	InstallLog(clusterID string, flags ...string) (bytes.Buffer, error)
	UnInstallLog(clusterID string, flags ...string) (bytes.Buffer, error)

	IsHostedCPCluster(clusterID string) (bool, error)
	IsSTSCluster(clusterID string) (bool, error)
	IsPrivateCluster(clusterID string) (bool, error)
	IsUsingReusableOIDCConfig(clusterID string) (bool, error)
	GetClusterVersion(clusterID string) (config.Version, error)
	IsBYOVPCCluster(clusterID string) (bool, error)
	IsExternalAuthenticationEnabled(clusterID string) (bool, error)
	GetJSONClusterDescription(clusterID string) (*jsonData, error)
}

func NewClusterService 

func NewClusterService(client *Client) ClusterService

type ErrorMessage added in v1.2.40 

type ErrorMessage struct {
	XMLName  xml.Name `xml:"error"`
	XMLValue string   `xml:",innerxml"`
	Message  string   `xml:"message,attr"`
	Type     string   `xml:"type,attr"`
}

type ExternalAuthProvider added in v1.2.41 

type ExternalAuthProvider struct {
	Name      string `json:"NAME,omitempty"`
	IssuerUrl string `json:"ISSUER URL,omitempty"`
}

type ExternalAuthProviderDescription added in v1.2.41 

type ExternalAuthProviderDescription struct {
	ID                    string   `yaml:"ID,omitempty"`
	ClusterID             string   `yaml:"Cluster ID,omitempty"`
	IssuerAudiences       []string `yaml:"Issuer audiences,omitempty"`
	IssuerUrl             string   `yaml:"Issuer Url,omitempty"`
	ClaimMappingsGroup    string   `yaml:"Claim mappings group,omitempty"`
	ClaimMappingsUserName string   `yaml:"Claim mappings username,omitempty"`
	ClaimValidationRules  []string `yaml:"Claim validation rules,omitempty"`
	ConsoleClientID       string   `yaml:"Console client id,omitempty"`
}

type ExternalAuthProviderList added in v1.2.41 

type ExternalAuthProviderList struct {
	ExternalAuthProviders []ExternalAuthProvider `json:"ExternalAuthProviders,omitempty"`
}

type ExternalAuthProviderService added in v1.2.41 

type ExternalAuthProviderService interface {
	ResourcesCleaner

	CreateExternalAuthProvider(clusterID string, flags ...string) (bytes.Buffer, error)
	DeleteExternalAuthProvider(clusterID string, eapID string) (bytes.Buffer, error)
	ListExternalAuthProvider(clusterID string) (bytes.Buffer, error)
	ReflectExternalAuthProviderLists(result bytes.Buffer) (eapl *ExternalAuthProviderList, err error)
	DescribeExternalAuthProvider(clusterID string, eapID string) (bytes.Buffer, error)
	ReflectExternalAuthProviderDescription(result bytes.Buffer) (eapd *ExternalAuthProviderDescription, err error)

	ListExternalAuthProviderAndReflect(clusterID string) (*ExternalAuthProviderList, error)
	DescribeExternalAuthProviderAndReflect(clusterID string, eapID string) (*ExternalAuthProviderDescription, error)

	RetrieveHelpForList() (output bytes.Buffer, err error)
	RetrieveHelpForDescribe() (output bytes.Buffer, err error)
	RetrieveHelpForDelete() (output bytes.Buffer, err error)
}

func NewExternalAuthProviderService added in v1.2.41 

func NewExternalAuthProviderService(client *Client) ExternalAuthProviderService

type FailureMessage added in v1.2.40 

type FailureMessage struct {
	XMLName  xml.Name `xml:"failure"`
	XMLValue string   `xml:",innerxml"`
	Message  string   `xml:"message,attr"`
	Type     string   `xml:"type,attr"`
}

type GroupUser 

type GroupUser struct {
	ID     string `json:"ID,omitempty"`
	Groups string `json:"GROUPS,omitempty"`
}

Struct for the 'rosa list users' output

type GroupUserList 

type GroupUserList struct {
	GroupUsers []GroupUser `json:"GroupUsers,omitempty"`
}

func (GroupUserList) User 

func (gl GroupUserList) User(userName string) (user GroupUser, err error)

Get specified user by user name

type IDP 

type IDP struct {
	Name    string `json:"NAME,omitempty"`
	Type    string `json:"TYPE,omitempty"`
	AuthURL string `json:"AUTH URL,omitempty"`
}

Struct for the 'rosa list idp' output

type IDPList 

type IDPList struct {
	IDPs []IDP `json:"IDPs,omitempty"`
}

func (IDPList) Idp 

func (idps IDPList) Idp(idpName string) (idp IDP)

Get specified machinepool by IDP NAME

func (IDPList) IsExist 

func (idps IDPList) IsExist(idpName string) (existed bool)

Check the idp with the name exists in the IDPLIST

type IDPService 

type IDPService interface {
	ResourcesCleaner

	ReflectIDPList(result bytes.Buffer) (idplist IDPList, err error)
	CreateIDP(clusterID string, idpName string, idflags ...string) (bytes.Buffer, error)
	ListIDP(clusterID string) (IDPList, bytes.Buffer, error)
	DeleteIDP(clusterID string, idpName string) (bytes.Buffer, error)
}

func NewIDPService 

func NewIDPService(client *Client) IDPService

type Ingress 

type Ingress struct {
	ClusterID                string `yaml:"Cluster ID,omitempty"`
	ID                       string `yaml:"ID,omitempty" json:"ID,omitempty"`
	ApplicationRouter        string `yaml:"APPLICATION ROUTER,omitempty" json:"APPLICATION ROUTER,omitempty"`
	Private                  string `yaml:"Private,omitempty" json:"PRIVATE,omitempty"`
	Default                  string `yaml:"Default,omitempty" json:"DEFAULT,omitempty"`
	RouteSelectors           string `yaml:"ROUTE SELECTORS,omitempty" json:"ROUTE SELECTORS,omitempty"`
	LBType                   string `yaml:"LB-Type,omitempty" json:"LB-TYPE,omitempty"`
	ExcludeNamespace         string `yaml:"Exclude Namespce,omitempty" json:"EXCLUDED NAMESPACE,omitempty"`
	WildcardPolicy           string `yaml:"Wildcard Policy,omitempty" json:"WILDCARD POLICY,omitempty"`
	NamespaceOwnershipPolicy string `yaml:"Namespace Ownership Policy,omitempty" json:"NAMESPACE OWNERSHIP,omitempty"`
}

type IngressList 

type IngressList struct {
	Ingresses []Ingress `json:"Ingresses,omitempty"`
}

Struct for the 'rosa describe ingress' output

func (IngressList) Ingress 

func (inl IngressList) Ingress(id string) (in *Ingress)

Get specified ingress by ingress id

type IngressService 

type IngressService interface {
	ResourcesCleaner

	EditIngress(clusterID string, ingressID string, flags ...string) (bytes.Buffer, error)
	ListIngress(clusterID string, flags ...string) (bytes.Buffer, error)
	DeleteIngress(clusterID string, ingressID string) (bytes.Buffer, error)
	ReflectIngressList(result bytes.Buffer) (res *IngressList, err error)
}

func NewIngressService 

func NewIngressService(client *Client) IngressService

type InstanceTypes added in v1.2.40 

type InstanceTypes struct {
	ID        string `json:"ID,omitempty"`
	CATEGORY  string `json:"CATEGORY,omitempty"`
	CPU_CORES string `json:"CPU_CORES,omitempty"`
	MEMORY    string `json:"MEMORY,omitempty"`
}

Struct for the 'rosa list instance-types' output

type InstanceTypesList added in v1.2.40 

type InstanceTypesList struct {
	InstanceTypesList []InstanceTypes `json:"InstanceTypesList,omitempty"`
}

type KubeletConfig added in v1.2.40 

type KubeletConfig struct {
	ID           string `yaml:"ID,omitempty" json:"ID,omitempty"`
	Name         string `yaml:"Name,omitempty" json:"NAME,omitempty"`
	PodPidsLimit string `yaml:"Pod Pids Limit,omitempty" json:"POD PIDS LIMIT,omitempty"`
}

Struct for the 'rosa describe/list kubeletconfig(s)' output

type KubeletConfigList added in v1.2.40 

type KubeletConfigList struct {
	KubeletConfigs []*KubeletConfig
}

Struct for the 'rosa list kubeletconfigs'

func (*KubeletConfigList) KubeletConfig added in v1.2.40 

func (kl *KubeletConfigList) KubeletConfig(kubeName string) *KubeletConfig

type KubeletConfigService 

type KubeletConfigService interface {
	ResourcesCleaner
	ListKubeletConfigs(clusterID string, flags ...string) (bytes.Buffer, error)
	ListKubeletConfigsAndReflect(clusterID string, flags ...string) (kubes *KubeletConfigList, err error)
	ReflectKubeletConfigs(output bytes.Buffer) (kubes *KubeletConfigList, err error)
	DescribeKubeletConfig(clusterID string, flags ...string) (bytes.Buffer, error)
	ReflectKubeletConfig(result bytes.Buffer) *KubeletConfig
	EditKubeletConfig(clusterID string, flags ...string) (bytes.Buffer, error)
	DeleteKubeletConfig(clusterID string, flags ...string) (bytes.Buffer, error)
	CreateKubeletConfig(clusterID string, flags ...string) (bytes.Buffer, error)
}

func NewKubeletConfigService 

func NewKubeletConfigService(client *Client) KubeletConfigService

type MachinePool 

type MachinePool struct {
	ID               string `json:"ID,omitempty"`
	AutoScaling      string `json:"AUTOSCALING,omitempty"`
	Replicas         string `json:"REPLICAS,omitempty"`
	DiskSize         string `json:"DISK SIZE,omitempty"`
	InstanceType     string `json:"INSTANCE TYPE,omitempty"`
	Labels           string `json:"LABELS,omitempty"`
	Taints           string `json:"TAINTS,omitempty"`
	AvalaiblityZones string `json:"AVAILABILITY ZONES,omitempty"`
	Subnets          string `json:"SUBNETS,omitempty"`
	SpotInstances    string `json:"SPOT INSTANCES,omitempty"`
	SecurityGroupIDs string `json:"SG IDs,omitempty"`
}

Struct for the 'rosa list machinepool' output for non-hosted-cp clusters

type MachinePoolDescription 

type MachinePoolDescription struct {
	AvailablityZones string `yaml:"Availability zones,omitempty"`
	AutoScaling      string `yaml:"Autoscaling,omitempty"`
	ClusterID        string `yaml:"Cluster ID,omitempty"`
	DiskSize         string `yaml:"Disk size,omitempty"`
	ID               string `yaml:"ID,omitempty"`
	InstanceType     string `yaml:"Instance type,omitempty"`
	Labels           string `yaml:"Labels,omitempty"`
	Replicas         string `yaml:"Replicas,omitempty"`
	SecurityGroupIDs string `yaml:"Security Group IDs,omitempty"`
	Subnets          string `yaml:"Subnets,omitempty"`
	SpotInstances    string `yaml:"Spot instances,omitempty"`
	Taints           string `yaml:"Taints,omitempty"`
	Tags             string `yaml:"Tags,omitempty"`
}

Struct for the 'rosa list machinepool' output for non-hosted-cp clusters

type MachinePoolList 

type MachinePoolList struct {
	MachinePools []MachinePool `json:"MachinePools,omitempty"`
}

func (MachinePoolList) Machinepool 

func (mpl MachinePoolList) Machinepool(id string) (mp *MachinePool)

Get specified machinepool by machinepool id

type MachinePoolService 

type MachinePoolService interface {
	ResourcesCleaner

	ListMachinePool(clusterID string) (bytes.Buffer, error)
	DescribeMachinePool(clusterID string, mpID string) (bytes.Buffer, error)
	CreateMachinePool(clusterID string, name string, flags ...string) (bytes.Buffer, error)
	EditMachinePool(clusterID string, machinePoolName string, flags ...string) (bytes.Buffer, error)
	DeleteMachinePool(clusterID string, machinePoolName string) (bytes.Buffer, error)

	ReflectMachinePoolList(result bytes.Buffer) (mpl MachinePoolList, err error)
	ReflectMachinePoolDescription(result bytes.Buffer) (*MachinePoolDescription, error)
	ListAndReflectMachinePools(clusterID string) (mpl MachinePoolList, err error)

	ReflectNodePoolList(result bytes.Buffer) (*NodePoolList, error)
	ListAndReflectNodePools(clusterID string) (*NodePoolList, error)
	ReflectNodePoolDescription(result bytes.Buffer) (npd *NodePoolDescription, err error)
	DescribeAndReflectNodePool(clusterID string, name string) (*NodePoolDescription, error)
	DescribeAndReflectMachinePool(clusterID string, name string) (*MachinePoolDescription, error)

	RetrieveHelpForCreate() (bytes.Buffer, error)
	RetrieveHelpForEdit() (bytes.Buffer, error)
}

func NewMachinePoolService 

func NewMachinePoolService(client *Client) MachinePoolService

type MachinePoolUpgrade 

type MachinePoolUpgrade struct {
	Version string `json:"VERSION,omitempty"`
	Notes   string `json:"NOTES,omitempty"`
}

type MachinePoolUpgradeDescription 

type MachinePoolUpgradeDescription struct {
	ID           string `yaml:"ID,omitempty"`
	ClusterID    string `yaml:"Cluster ID,omitempty"`
	ScheduleType string `yaml:"Schedule Type,omitempty"`
	NextRun      string `yaml:"Next Run,omitempty"`
	UpgradeState string `yaml:"Upgrade State,omitempty"`
	Version      string `yaml:"Version,omitempty"`
}

Struct for the 'rosa describe upgrades' output for non-hosted-cp clusters

type MachinePoolUpgradeList 

type MachinePoolUpgradeList struct {
	MachinePoolUpgrades []MachinePoolUpgrade `json:"MachinePoolUpgrades,omitempty"`
}

type MachinePoolUpgradeService 

type MachinePoolUpgradeService interface {
	ResourcesCleaner

	ListUpgrades(clusterID string, mpID string) (bytes.Buffer, error)
	ReflectUpgradesList(result bytes.Buffer) (*MachinePoolUpgradeList, error)
	ListAndReflectUpgrades(clusterID string, mpID string) (*MachinePoolUpgradeList, error)

	// Create a manual upgrade. `version`, `scheduleDate` and `scheduleTime` are optional. `schedule*` if provided MUST be both at the same time provided.
	CreateManualUpgrade(clusterID string, mpID string, version string, scheduleDate string, scheduleTime string) (bytes.Buffer, error)
	// Create an automatic upgrade based on the given cron.
	CreateAutomaticUpgrade(clusterID string, mpID string, scheduleCron string) (bytes.Buffer, error)

	DescribeUpgrade(clusterID string, mpID string) (bytes.Buffer, error)
	ReflectUpgradeDescription(result bytes.Buffer) (*MachinePoolUpgradeDescription, error)
	DescribeAndReflectUpgrade(clusterID string, mpID string) (*MachinePoolUpgradeDescription, error)

	DeleteUpgrade(clusterID string, mpID string) (bytes.Buffer, error)

	RetrieveHelpForCreate() (bytes.Buffer, error)
	RetrieveHelpForDescribe() (bytes.Buffer, error)
	RetrieveHelpForList() (bytes.Buffer, error)
	RetrieveHelpForDelete() (bytes.Buffer, error)
}

func NewMachinePoolUpgradeService 

func NewMachinePoolUpgradeService(client *Client) MachinePoolUpgradeService

type NetworkVerifierService 

type NetworkVerifierService interface {
	ResourcesCleaner
	CreateNetworkVerifierWithCluster(clusterID string, flags ...string) (bytes.Buffer, error)
	CreateNetworkVerifierWithSubnets(flags ...string) (bytes.Buffer, error)
	GetNetworkVerifierStatus(flags ...string) (bytes.Buffer, error)
}

func NewNetworkVerifierService 

func NewNetworkVerifierService(client *Client) NetworkVerifierService

type NodePool 

type NodePool struct {
	ID               string `json:"ID,omitempty"`
	AutoScaling      string `json:"AUTOSCALING,omitempty"`
	Replicas         string `json:"REPLICAS,omitempty"`
	InstanceType     string `json:"INSTANCE TYPE,omitempty"`
	Labels           string `json:"LABELS,omitempty"`
	Taints           string `json:"TAINTS,omitempty"`
	AvalaiblityZones string `json:"AVAILABILITY ZONES,omitempty"`
	Subnet           string `json:"SUBNET,omitempty"`
	Version          string `json:"VERSION,omitempty"`
	AutoRepair       string `json:"AUTOREPAIR,omitempty"`
	TuningConfigs    string `json:"TUNING CONFIGS,omitempty"`
	Message          string `json:"MESSAGE,omitempty"`
}

Struct for the 'rosa list machinepool' output for hosted-cp clusters

type NodePoolDescription 

type NodePoolDescription struct {
	ID                         string `yaml:"ID,omitempty"`
	ClusterID                  string `yaml:"Cluster ID,omitempty"`
	AutoScaling                string `yaml:"Autoscaling,omitempty"`
	DesiredReplicas            string `yaml:"Desired replicas,omitempty"`
	CurrentReplicas            string `yaml:"Current replicas,omitempty"`
	InstanceType               string `yaml:"Instance type,omitempty"`
	KubeletConfigs             string `yaml:"Kubelet configs,omitempty"`
	Labels                     string `yaml:"Labels,omitempty"`
	Tags                       string `yaml:"Tags,omitempty"`
	Taints                     string `yaml:"Taints,omitempty"`
	AvalaiblityZones           string `yaml:"Availability zone,omitempty"`
	Subnet                     string `yaml:"Subnet,omitempty"`
	Version                    string `yaml:"Version,omitempty"`
	AutoRepair                 string `yaml:"Autorepair,omitempty"`
	TuningConfigs              string `yaml:"Tuning configs,omitempty"`
	Message                    string `yaml:"Message,omitempty"`
	ScheduledUpgrade           string `yaml:"Scheduled upgrade,omitempty"`
	AdditionalSecurityGroupIDs string `yaml:"Additional security group IDs,omitempty"`
	NodeDrainGracePeriod       string `yaml:"Node drain grace period,omitempty"`
}

type NodePoolList 

type NodePoolList struct {
	NodePools []NodePool `json:"NodePools,omitempty"`
}

func (NodePoolList) Nodepool 

func (npl NodePoolList) Nodepool(id string) (np *NodePool)

Get specified nodepool by nodepool id

type OCMResourceService 

type OCMResourceService interface {
	ResourcesCleaner

	ListRegion(flags ...string) ([]*CloudRegion, bytes.Buffer, error)
	ReflectRegionList(result bytes.Buffer) (regions []*CloudRegion, err error)

	ListUserRole() (UserRoleList, bytes.Buffer, error)
	DeleteUserRole(flags ...string) (bytes.Buffer, error)
	LinkUserRole(flags ...string) (bytes.Buffer, error)
	UnlinkUserRole(flags ...string) (bytes.Buffer, error)
	CreateUserRole(flags ...string) (bytes.Buffer, error)
	ReflectUserRoleList(result bytes.Buffer) (url UserRoleList, err error)

	Whoami() (bytes.Buffer, error)
	ReflectAccountsInfo(result bytes.Buffer) *AccountsInfo
	UserInfo() (res *AccountsInfo, err error)

	CreateAccountRole(flags ...string) (bytes.Buffer, error)
	ReflectAccountRoleList(result bytes.Buffer) (arl AccountRoleList, err error)
	DeleteAccountRole(flags ...string) (bytes.Buffer, error)
	ListAccountRole() (AccountRoleList, bytes.Buffer, error)
	UpgradeAccountRole(flags ...string) (bytes.Buffer, error)

	ListOCMRole() (OCMRoleList, bytes.Buffer, error)
	DeleteOCMRole(flags ...string) (bytes.Buffer, error)
	LinkOCMRole(flags ...string) (bytes.Buffer, error)
	UnlinkOCMRole(flags ...string) (bytes.Buffer, error)
	CreateOCMRole(flags ...string) (bytes.Buffer, error)
	ReflectOCMRoleList(result bytes.Buffer) (orl OCMRoleList, err error)

	ListOIDCConfig() (OIDCConfigList, bytes.Buffer, error)
	ListInstanceTypes() (InstanceTypesList, bytes.Buffer, error)
	DeleteOIDCConfig(flags ...string) (bytes.Buffer, error)
	CreateOIDCConfig(flags ...string) (bytes.Buffer, error)
	ReflectOIDCConfigList(result bytes.Buffer) (oidclist OIDCConfigList, err error)
	GetOIDCIdFromList(providerURL string) (string, error)
	GetOIDCConfigFromList(oidcConfigID string) (OIDCConfig, error)
	ListOperatorRoles(flags ...string) (bytes.Buffer, error)
	DeleteOperatorRoles(flags ...string) (bytes.Buffer, error)
	CreateOperatorRoles(flags ...string) (bytes.Buffer, error)
	ReflectOperatorRoleList(result bytes.Buffer) (opl OperatorRoleList, err error)

	CreateOIDCProvider(flags ...string) (bytes.Buffer, error)
	DeleteOIDCProvider(flags ...string) (bytes.Buffer, error)

	Token(flags ...string) (bytes.Buffer, error)
}

func NewOCMResourceService 

func NewOCMResourceService(client *Client) OCMResourceService

type OCMRole 

type OCMRole struct {
	RoleName   string `json:"ROLE NAME,omitempty"`
	RoleArn    string `json:"ROLE ARN,omitempty"`
	Linded     string `json:"LINKED,omitempty"`
	Admin      string `json:"ADMIN,omitempty"`
	AwsManaged string `json:"AWS MANAGED,omitempty"`
}

Struct for the 'rosa list ocm-role' output

type OCMRoleList 

type OCMRoleList struct {
	OCMRoleList []OCMRole `json:"OCMRoleList,omitempty"`
}

func (OCMRoleList) FindLinkedOCMRole 

func (url OCMRoleList) FindLinkedOCMRole() (userRoles OCMRole)

Get the ocm-role which is linked to org

func (OCMRoleList) OCMRole 

func (url OCMRoleList) OCMRole(prefix string, ocmOrganizationExternalID string) (userRoles OCMRole)

Get specified ocm-role by ocm-role prefix and ocmOUsername

type OIDCConfig 

type OIDCConfig struct {
	ID        string `json:"ID,omitempty"`
	Managed   string `json:"MANAGED,omitempty"`
	IssuerUrl string `json:"ISSUER URL,omitempty"`
	SecretArn string `json:"SECRET ARN,omitempty"`
}

type OIDCConfigList 

type OIDCConfigList struct {
	OIDCConfigList []OIDCConfig `json:"OIDCConfigList,omitempty"`
}

func (OIDCConfigList) OIDCConfig 

func (oidcl OIDCConfigList) OIDCConfig(id string) (oidc OIDCConfig)

Get specified oidc-config by oidc-config-id

type OpenShiftVersionJsonOutput added in v1.2.39 

type OpenShiftVersionJsonOutput struct {
	ID                string   `json:"VERSION,omitempty"`
	RAWID             string   `json:"raw_id,omitempty"`
	ChannelGroup      string   `json:"channel_group,omitempty"`
	HCPDefault        bool     `json:"hosted_control_plane_default,omitempty"`
	HCPEnabled        bool     `json:"hosted_control_plane_enabled,omitempty"`
	Default           bool     `json:"default,omitempty"`
	AvailableUpgrades []string `json:"available_upgrades,omitempty"`
}

type OpenShiftVersionTableList added in v1.2.39 

type OpenShiftVersionTableList struct {
	OpenShiftVersions []*OpenShiftVersionTableOutput `json:"OpenShiftVersions,omitempty"`
}

func (*OpenShiftVersionTableList) DefaultVersion added in v1.2.41 

func (vl *OpenShiftVersionTableList) DefaultVersion() (defaultVersion *OpenShiftVersionTableOutput)

func (*OpenShiftVersionTableList) FilterVersionsLowerThan added in v1.2.39 

func (vl *OpenShiftVersionTableList) FilterVersionsLowerThan(version string) (nvl *OpenShiftVersionTableList, err error)

FilterVersionsByMajorMinor filter the version list for all lower versions than the given one

func (*OpenShiftVersionTableList) FilterVersionsSameMajorAndEqualOrLowerThanMinor added in v1.2.39 

func (vl *OpenShiftVersionTableList) FilterVersionsSameMajorAndEqualOrLowerThanMinor(major int64, minor int64, strict bool) (nvl *OpenShiftVersionTableList, err error)

FilterVersionsByMajorMinor filter the version list for all major/minor corresponding and returns a new `OpenShiftVersionList` struct `strict` will find only the `Major.minor` ones

func (*OpenShiftVersionTableList) FindNearestBackwardMinorVersion added in v1.2.39 

func (vl *OpenShiftVersionTableList) FindNearestBackwardMinorVersion(version string, minorSub int64, strict bool, upgradable ...bool) (vs *OpenShiftVersionTableOutput, err error)

This function will find the nearest lower OCP version which version is under `Major.{minor-sub}`. `strict` will find only the `Major.{minor-sub}` ones

func (*OpenShiftVersionTableList) FindNearestBackwardOptionalVersion added in v1.2.40 

func (vl *OpenShiftVersionTableList) FindNearestBackwardOptionalVersion(version string, optionalsub int, strict bool) (vs *OpenShiftVersionTableOutput, err error)

This function will find the nearest lower OCP version which version is under `Major.minor.{optional-sub}`. `strict` will find only the `Major.monior,{optional-sub}` ones

func (*OpenShiftVersionTableList) Latest added in v1.2.39 

func (vl *OpenShiftVersionTableList) Latest() (*OpenShiftVersionTableOutput, error)

func (*OpenShiftVersionTableList) Len added in v1.2.39 

func (vl *OpenShiftVersionTableList) Len() int

func (*OpenShiftVersionTableList) Sort added in v1.2.39 

func (vl *OpenShiftVersionTableList) Sort(reverse bool) (nvl *OpenShiftVersionTableList, err error)

Sort sort the version list from lower to higher (or reverse)

type OpenShiftVersionTableOutput added in v1.2.39 

type OpenShiftVersionTableOutput struct {
	Version           string `json:"VERSION,omitempty"`
	Default           string `json:"DEFAULT,omitempty"`
	AvailableUpgrades string `json:"AVAILABLE UPGRADES,omitempty"`
}

func (*OpenShiftVersionTableOutput) MajorMinor added in v1.2.41 

func (vl *OpenShiftVersionTableOutput) MajorMinor() (major int64, minor int64, majorMinorVersion string, err error)

type OperatorRole added in v1.2.39 

type OperatorRole struct {
	AWSManaged        string `json:"AWS Managed,omitempty"`
	ClusterID         string `json:"CLUSTER ID,omitempty"`
	InUse             string `json:"IN USE,omitempty"`
	Operatorname      string `json:"OPERATOR NAME,omitempty"`
	OperatorNamespace string `json:"OPERATOR NAMESPACE,omitempty"`
	Policies          string `json:"POLICIES,omitempty"`
	RoleName          string `json:"ROLE NAME,omitempty"`
	RoleArn           string `json:"ROLE ARN,omitempty"`
	Version           string `json:"VERSION,omitempty"`
}

type OperatorRoleList added in v1.2.39 

type OperatorRoleList struct {
	OperatorRoleList []*OperatorRole `json:"OperatorRoleList,omitempty"`
}

type Parser 

type Parser struct {
	JsonData  *jsonData
	TableData *tableData
	TextData  *textData
}

func NewParser 

func NewParser() *Parser

type PolicyService added in v1.2.41 

type PolicyService interface {
	ResourcesCleaner
	AttachPolicy(roleName string, policyArn []string, flags ...string) (bytes.Buffer, error)
	DetachPolicy(roleName string, policyArn []string, flags ...string) (bytes.Buffer, error)
}

func NewPolicyService added in v1.2.41 

func NewPolicyService(client *Client) PolicyService

type Properties added in v1.2.40 

type Properties struct {
	XMLName  xml.Name   `xml:"properties"`
	Property []Property `xml:"property"`
}

type Property added in v1.2.40 

type Property struct {
	XMLName xml.Name `xml:"property"`
	Name    string   `xml:"name,attr"`
	Value   string   `xml:"value,attr"`
}

type ReportLog added in v1.2.40 

type ReportLog struct {
	TestSuite        string   `json:"testsuite,omitempty"`
	FailureScenarios []string `json:"failure_scenarios,omitempty"`
}

type ReportLogs added in v1.2.40 

type ReportLogs struct {
	Total    int          `json:"total"`
	Passed   int          `json:"passed"`
	Failures int          `json:"failures"`
	Errors   int          `json:"errors"`
	Reports  []*ReportLog `json:"reports,omitempty"`
}

type ResourcesCleaner 

type ResourcesCleaner interface {
	CleanResources(clusterID string) []error
}

type ResourcesService 

type ResourcesService struct {
	// contains filtered or unexported fields
}

type TCResult added in v1.2.40 

type TCResult struct {
	ID      string
	Title   string
	Message string
	Tags    []string
}

func PrintTestCase added in v1.2.40 

func PrintTestCase(tc Testcase) *TCResult

type TCStatus added in v1.2.40 

type TCStatus string
const (
	Passed   TCStatus = "passed"
	Skipped  TCStatus = "skipped"
	Failed   TCStatus = "failed"
	Panicked TCStatus = "panicked"
	Pending  TCStatus = "pending"
)

type Testcase added in v1.2.40 

type Testcase struct {
	XMLName   xml.Name        `xml:"testcase"`
	Name      string          `xml:"name,attr"`
	Classname string          `xml:"classname,attr"`
	Status    string          `xml:"status,attr"`
	Time      string          `xml:"time,attr"`
	FM        *FailureMessage `xml:"failure"`
	EM        *ErrorMessage   `xml:"error"`
}

type Testsuite added in v1.2.40 

type Testsuite struct {
	XMLName    xml.Name   `xml:"testsuite"`
	Name       string     `xml:"name,attr"`
	Package    string     `xml:"package,attr"`
	Tests      int        `xml:"tests,attr"`
	Disabled   int        `xml:"disabled,attr"`
	Skipped    int        `xml:"skipped,attr"`
	Errors     int        `xml:"errors,attr"`
	Failures   int        `xml:"failures,attr"`
	Time       float64    `xml:"time,attr"`
	Timestamp  string     `xml:"timestamp,attr"`
	Properties Properties `xml:"properties"`
	TCs        []Testcase `xml:"testcase"`
}

type Testsuites added in v1.2.40 

type Testsuites struct {
	XMLName  xml.Name     `xml:"testsuites"`
	Tests    int          `xml:"tests,attr"`
	Disabled int          `xml:"disabled,attr"`
	Errors   int          `xml:"errors,attr"`
	Failures int          `xml:"failures,attr"`
	Time     float64      `xml:"time,attr"`
	TS       []*Testsuite `xml:"testsuite"`
}

func ParseJunitXML added in v1.2.40 

func ParseJunitXML(fileName string) (*Testsuites, error)

type TuningConfig 

type TuningConfig struct {
	ID   string `json:"ID,omitempty"`
	Name string `json:"NAME,omitempty"`
}

type TuningConfigDescription 

type TuningConfigDescription struct {
	Name string `yaml:"Name,omitempty"`
	ID   string `yaml:"ID,omitempty"`
	Spec string `yaml:"Spec,omitempty"`
}

Struct for the 'rosa describe cluster' output

type TuningConfigList 

type TuningConfigList struct {
	TuningConfigs []TuningConfig `json:"TuningConfigs,omitempty"`
}

func (TuningConfigList) IsPresent added in v1.2.39 

func (tuningConfigs TuningConfigList) IsPresent(tcName string) (existed bool)

Check the tuningConfig with the name exists in the tuningConfigList

type TuningConfigService 

type TuningConfigService interface {
	ResourcesCleaner

	CreateTuningConfig(clusterID string, tcName string, specContent string, flags ...string) (bytes.Buffer, error)
	EditTuningConfig(clusterID string, tcName string, flags ...string) (bytes.Buffer, error)
	DeleteTuningConfig(clusterID string, tcName string) (bytes.Buffer, error)

	ListTuningConfigs(clusterID string) (bytes.Buffer, error)
	ReflectTuningConfigList(result bytes.Buffer) (mpl *TuningConfigList, err error)
	ListTuningConfigsAndReflect(clusterID string) (*TuningConfigList, error)

	DescribeTuningConfig(clusterID string, tcID string) (bytes.Buffer, error)
	ReflectTuningConfigDescription(result bytes.Buffer) (npd *TuningConfigDescription, err error)
	DescribeTuningConfigAndReflect(clusterID string, tcID string) (*TuningConfigDescription, error)
}

func NewTuningConfigService 

func NewTuningConfigService(client *Client) TuningConfigService

type UserRole 

type UserRole struct {
	RoleName string `json:"ROLE NAME,omitempty"`
	RoleArn  string `json:"ROLE ARN,omitempty"`
	Linded   string `json:"LINKED,omitempty"`
}

Struct for the 'rosa list user-role' output

type UserRoleList 

type UserRoleList struct {
	UserRoleList []UserRole `json:"UserRoleList,omitempty"`
}

func (UserRoleList) UserRole 

func (url UserRoleList) UserRole(prefix string, ocmAccountUsername string) (userRoles UserRole)

Get specified user-role by user-role prefix and ocmAccountUsername

type UserService 

type UserService interface {
	ResourcesCleaner

	ListUsers(clusterID string) (GroupUserList, bytes.Buffer, error)
	ReflectUsersList(result bytes.Buffer) (gul GroupUserList, err error)
	RevokeUser(clusterID string, role string, user string, flags ...string) (bytes.Buffer, error)
	GrantUser(clusterID string, role string, user string, flags ...string) (bytes.Buffer, error)
	CreateAdmin(clusterID string) (bytes.Buffer, error)
	DescribeAdmin(clusterID string) (bytes.Buffer, error)
	DeleteAdmin(clusterID string) (bytes.Buffer, error)
}

func NewUserService 

func NewUserService(client *Client) UserService

type VersionService 

type VersionService interface {
	ResourcesCleaner

	ReflectVersions(result bytes.Buffer) (*OpenShiftVersionTableList, error)
	ListVersions(channelGroup string, hostedCP bool, flags ...string) (bytes.Buffer, error)
	ListAndReflectVersions(channelGroup string, hostedCP bool, flags ...string) (*OpenShiftVersionTableList, error)
}

func NewVersionService 

func NewVersionService(client *Client) VersionService

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.