cluster

Documentation

Index

• func AddProxyConfigToCluster(ocConfig oc.Config, proxy *network.ProxyConfig) error
• func AddProxyToKubeletAndCriO(sshRunner *ssh.Runner, proxy *network.ProxyConfig) error
• func AddPullSecret(sshRunner *ssh.Runner, ocConfig oc.Config, pullSec string) error
• func ApproveNodeCSR(ocConfig oc.Config) error
• func CheckProxySettingsForOperator(ocConfig oc.Config, proxy *network.ProxyConfig, deployment, namespace string) (bool, error)
• func DeleteOpenshiftAPIServerPods(ocConfig oc.Config) error
• func GetRootPartitionUsage(sshRunner *ssh.Runner) (int64, int64, error)
• func RegenerateCertificates(sshRunner *ssh.Runner, ocConfig oc.Config) error
• func UpdateClusterID(ocConfig oc.Config) error
• func WaitForOpenshiftResource(ocConfig oc.Config, resource string) error
• func WaitForSSH(sshRunner *ssh.Runner) error
• func WaitforRequestHeaderClientCaFile(ocConfig oc.Config) error
• type CertExpiryState
  • func CheckCertsValidity(sshRunner *ssh.Runner) (CertExpiryState, error)
• type K8sResource
• type Status
  • func GetClusterOperatorStatus(ocConfig oc.Config, operator string) (*Status, error)
  • func GetClusterOperatorsStatus(ocConfig oc.Config) (*Status, error)

Functions

func AddProxyConfigToCluster

func AddProxyConfigToCluster(ocConfig oc.Config, proxy *network.ProxyConfig) error

func AddProxyToKubeletAndCriO

func AddProxyToKubeletAndCriO(sshRunner *ssh.Runner, proxy *network.ProxyConfig) error

AddProxyToKubeletAndCriO adds the systemd drop-in proxy configuration file to the instance, both services (kubelet and crio) need to be restarted after this change. Since proxy operator is not able to make changes to in the kubelet/crio side, this is the job of machine config operator on the node and for crc this is not possible so we do need to put it here.

func AddPullSecret

func AddPullSecret(sshRunner *ssh.Runner, ocConfig oc.Config, pullSec string) error

func ApproveNodeCSR

func ApproveNodeCSR(ocConfig oc.Config) error

ApproveNodeCSR approves the certificate for the node.

func CheckProxySettingsForOperator

func CheckProxySettingsForOperator(ocConfig oc.Config, proxy *network.ProxyConfig, deployment, namespace string) (bool, error)

func DeleteOpenshiftAPIServerPods

func DeleteOpenshiftAPIServerPods(ocConfig oc.Config) error

func GetRootPartitionUsage

func GetRootPartitionUsage(sshRunner *ssh.Runner) (int64, int64, error)

Return size of disk, used space in bytes and the mountpoint

func RegenerateCertificates

func RegenerateCertificates(sshRunner *ssh.Runner, ocConfig oc.Config) error

func UpdateClusterID

func UpdateClusterID(ocConfig oc.Config) error

func WaitForOpenshiftResource

func WaitForOpenshiftResource(ocConfig oc.Config, resource string) error

func WaitForSSH

func WaitForSSH(sshRunner *ssh.Runner) error

func WaitforRequestHeaderClientCaFile

func WaitforRequestHeaderClientCaFile(ocConfig oc.Config) error

Types

type CertExpiryState

type CertExpiryState int

const (
	Unknown CertExpiryState = iota
	CertNotExpired
	CertExpired
)

func CheckCertsValidity

func CheckCertsValidity(sshRunner *ssh.Runner) (CertExpiryState, error)

CheckCertsValidity checks if the cluster certs have expired or going to expire in next 7 days

type K8sResource

type K8sResource struct {
	Items []struct {
		Metadata struct {
			Name string `json:"name"`
		} `json:"metadata"`
		Status struct {
			Conditions []struct {
				LastTransitionTime time.Time `json:"lastTransitionTime"`
				Reason             string    `json:"reason"`
				Status             string    `json:"status"`
				Type               string    `json:"type"`
			} `json:"conditions"`
		} `json:"status,omitempty"`
	} `json:"items"`
}

type Status

type Status struct {
	Available   bool
	Degraded    bool
	Progressing bool
	Disabled    bool
}

https://github.com/openshift/cluster-version-operator/blob/master/docs/dev/clusteroperator.md#what-should-an-operator-report-with-clusteroperator-custom-resource

func GetClusterOperatorStatus

func GetClusterOperatorStatus(ocConfig oc.Config, operator string) (*Status, error)

func GetClusterOperatorsStatus

func GetClusterOperatorsStatus(ocConfig oc.Config) (*Status, error)