cluster

package

v1.23.1 Latest Latest Go to latest Published: Mar 5, 2021 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/code-ready/crc

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddProxyConfigToCluster(sshRunner *ssh.Runner, ocConfig oc.Config, proxy *network.ProxyConfig) error
func AddProxyToKubeletAndCriO(sshRunner *ssh.Runner, proxy *network.ProxyConfig) error
func ApproveCSRAndWaitForCertsRenewal(sshRunner *ssh.Runner, ocConfig oc.Config, client, server bool) error
func CheckCertsValidity(sshRunner *ssh.Runner) (map[string]bool, error)
func CheckProxySettingsForOperator(ocConfig oc.Config, proxy *network.ProxyConfig, deployment, namespace string) (bool, error)
func DeleteOpenshiftAPIServerPods(ocConfig oc.Config) error
func EnsureClusterIDIsNotEmpty(ocConfig oc.Config) error
func EnsurePullSecretPresentInTheCluster(ocConfig oc.Config, pullSec PullSecretLoader) error
func EnsurePullSecretPresentOnInstanceDisk(sshRunner *ssh.Runner, pullSecret PullSecretLoader) error
func ForgetPullSecret() error
func GetRootPartitionUsage(sshRunner *ssh.Runner) (int64, int64, error)
func StartMonitoring(ocConfig oc.Config) error
func WaitForAPIServer(ocConfig oc.Config) error
func WaitForClusterStable(ocConfig oc.Config, monitoringEnabled bool) error
func WaitForOpenshiftResource(ocConfig oc.Config, resource string) error
func WaitForRequestHeaderClientCaFile(sshRunner *ssh.Runner) error
func WaitForSSH(sshRunner *ssh.Runner) error
type PullSecretLoader
- func NewInteractivePullSecretLoader(config crcConfig.Storage) PullSecretLoader
- func NewNonInteractivePullSecretLoader(config crcConfig.Storage, path string) PullSecretLoader
type PullSecretMemoizer
- func (p *PullSecretMemoizer) Value() (string, error)
type Status
- func GetClusterOperatorStatus(ocConfig oc.Config, operator string) (*Status, error)
- func GetClusterOperatorsStatus(ocConfig oc.Config, monitoringEnabled bool) (*Status, error)
- func (status *Status) IsReady() bool
- func (status *Status) String() string

Constants ¶

View Source

const (
	KubeletServerCert = "/var/lib/kubelet/pki/kubelet-server-current.pem"
	KubeletClientCert = "/var/lib/kubelet/pki/kubelet-client-current.pem"

	AggregatorClientCert = "/etc/kubernetes/static-pod-resources/kube-apiserver-certs/configmaps/aggregator-client-ca/ca-bundle.crt"
)

Variables ¶

This section is empty.

Functions ¶

func AddProxyConfigToCluster ¶

func AddProxyConfigToCluster(sshRunner *ssh.Runner, 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 ApproveCSRAndWaitForCertsRenewal ¶ added in v1.20.0

func ApproveCSRAndWaitForCertsRenewal(sshRunner *ssh.Runner, ocConfig oc.Config, client, server bool) error

func CheckCertsValidity ¶

func CheckCertsValidity(sshRunner *ssh.Runner) (map[string]bool, error)

func CheckProxySettingsForOperator ¶

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

func DeleteOpenshiftAPIServerPods ¶ added in v1.14.0

func DeleteOpenshiftAPIServerPods(ocConfig oc.Config) error

func EnsureClusterIDIsNotEmpty ¶ added in v1.20.0

func EnsureClusterIDIsNotEmpty(ocConfig oc.Config) error

func EnsurePullSecretPresentInTheCluster ¶ added in v1.20.0

func EnsurePullSecretPresentInTheCluster(ocConfig oc.Config, pullSec PullSecretLoader) error

func EnsurePullSecretPresentOnInstanceDisk ¶ added in v1.20.0

func EnsurePullSecretPresentOnInstanceDisk(sshRunner *ssh.Runner, pullSecret PullSecretLoader) error

func ForgetPullSecret ¶ added in v1.23.0

func ForgetPullSecret() error

func GetRootPartitionUsage ¶

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

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

func StartMonitoring ¶ added in v1.21.0

func StartMonitoring(ocConfig oc.Config) error

func WaitForAPIServer ¶ added in v1.21.0

func WaitForAPIServer(ocConfig oc.Config) error

func WaitForClusterStable ¶ added in v1.23.0

func WaitForClusterStable(ocConfig oc.Config, monitoringEnabled bool) error

WaitForClusterStable checks that the cluster is running a number of consecutive times

func WaitForOpenshiftResource ¶ added in v1.13.0

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

func WaitForRequestHeaderClientCaFile ¶ added in v1.20.0

func WaitForRequestHeaderClientCaFile(sshRunner *ssh.Runner) error

func WaitForSSH ¶ added in v1.14.0

func WaitForSSH(sshRunner *ssh.Runner) error

Types ¶

type PullSecretLoader ¶ added in v1.23.0

type PullSecretLoader interface {
	Value() (string, error)
}

func NewInteractivePullSecretLoader ¶ added in v1.23.0

func NewInteractivePullSecretLoader(config crcConfig.Storage) PullSecretLoader

func NewNonInteractivePullSecretLoader ¶ added in v1.23.0

func NewNonInteractivePullSecretLoader(config crcConfig.Storage, path string) PullSecretLoader

type PullSecretMemoizer ¶ added in v1.23.0

type PullSecretMemoizer struct {
	Getter PullSecretLoader
	// contains filtered or unexported fields
}

func (*PullSecretMemoizer) Value ¶ added in v1.23.0

func (p *PullSecretMemoizer) Value() (string, error)

type Status ¶ added in v1.14.0

type Status struct {
	Available   bool
	Degraded    bool
	Progressing bool
	Disabled    bool
	// contains filtered or unexported fields
}

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

func GetClusterOperatorStatus ¶ added in v1.13.0

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

func GetClusterOperatorsStatus ¶ added in v1.14.0

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

func (*Status) IsReady ¶ added in v1.23.0

func (status *Status) IsReady() bool

func (*Status) String ¶ added in v1.23.0

func (status *Status) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL