cluster

package
v1.36.0 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2021 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

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(ctx context.Context, sshRunner *ssh.Runner, ocConfig oc.Config, proxy *network.ProxyConfig) error

func ApproveCSRAndWaitForCertsRenewal added in v1.20.0 

func ApproveCSRAndWaitForCertsRenewal(ctx context.Context, 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 DeleteMCOLeaderLease added in v1.31.0 

func DeleteMCOLeaderLease(ctx context.Context, ocConfig oc.Config) error

func DeleteOpenshiftAPIServerPods added in v1.14.0 

func DeleteOpenshiftAPIServerPods(ctx context.Context, ocConfig oc.Config) error

func EnsureClusterIDIsNotEmpty added in v1.20.0 

func EnsureClusterIDIsNotEmpty(ctx context.Context, ocConfig oc.Config) error

func EnsureGeneratedClientCAPresentInTheCluster added in v1.29.0 

func EnsureGeneratedClientCAPresentInTheCluster(ctx context.Context, ocConfig oc.Config, sshRunner *ssh.Runner, selfSignedCACert *x509.Certificate, adminCert string) error

func EnsurePullSecretPresentInTheCluster added in v1.20.0 

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

func EnsurePullSecretPresentOnInstanceDisk added in v1.20.0 

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

func EnsureSSHKeyPresentInTheCluster added in v1.29.0 

func EnsureSSHKeyPresentInTheCluster(ctx context.Context, ocConfig oc.Config, sshPublicKeyPath string) error

func ForgetPullSecret added in v1.23.0 

func ForgetPullSecret() error

func GenerateKubeAdminUserPassword added in v1.28.0 

func GenerateKubeAdminUserPassword() error

GenerateKubeAdminUserPassword creates and put updated kubeadmin password to ~/.crc/machine/crc/kubeadmin-password

func GenerateRandomPasswordHash added in v1.24.0 

func GenerateRandomPasswordHash(length int) (string, error)

generateRandomPasswordHash generates a hash of a random ASCII password 5char-5char-5char-5char Copied from openshift/installer https://github.com/openshift/installer/blob/master/pkg/asset/password/password.go

func GetKubeadminPassword added in v1.25.0 

func GetKubeadminPassword() (string, error)

func GetRootPartitionUsage 

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

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

func RemoveOldRenderedMachineConfig added in v1.30.0 

func RemoveOldRenderedMachineConfig(ocConfig oc.Config) error

func RemovePullSecretFromCluster added in v1.26.0 

func RemovePullSecretFromCluster(ctx context.Context, ocConfig oc.Config, sshRunner *ssh.Runner) error

func StartMonitoring added in v1.21.0 

func StartMonitoring(ocConfig oc.Config) error

func StoreInKeyring added in v1.28.0 

func StoreInKeyring(pullSecret string) error

func UpdateKubeAdminUserPassword added in v1.24.0 

func UpdateKubeAdminUserPassword(ctx context.Context, ocConfig oc.Config, newPassword string) error

UpdateKubeAdminUserPassword updates the htpasswd secret

func WaitForAPIServer added in v1.21.0 

func WaitForAPIServer(ctx context.Context, ocConfig oc.Config) error

func WaitForClusterStable added in v1.23.0 

func WaitForClusterStable(ctx context.Context, ip string, kubeconfigFilePath string, proxy *network.ProxyConfig) error

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

func WaitForOpenshiftResource added in v1.13.0 

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

func WaitForPullSecretPresentOnInstanceDisk added in v1.30.0 

func WaitForPullSecretPresentOnInstanceDisk(ctx context.Context, sshRunner *ssh.Runner) error

func WaitForRequestHeaderClientCaFile added in v1.20.0 

func WaitForRequestHeaderClientCaFile(ctx context.Context, 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 GetClusterOperatorsStatus added in v1.14.0 

func GetClusterOperatorsStatus(ctx context.Context, ip string, kubeconfigFilePath string) (*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

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.