Documentation ¶
Index ¶
- Constants
- func AddEtcdMember(ctx context.Context, toAddEtcdHost *hosts.Host, etcdHosts []*hosts.Host, ...) error
- func DownloadEtcdSnapshotFromBackupServer(ctx context.Context, etcdHost *hosts.Host, ...) error
- func GetEtcdConnString(hosts []*hosts.Host) string
- func GetEtcdInitialCluster(hosts []*hosts.Host) string
- func GetEtcdSnapshotChecksum(ctx context.Context, etcdHost *hosts.Host, ...) (string, error)
- func GetHealthCheckURL(useTLS bool, port int) string
- func GetProcessConfig(process types.Process) (*container.Config, *container.HostConfig, string)
- func IsEtcdMember(ctx context.Context, etcdHost *hosts.Host, etcdHosts []*hosts.Host, ...) (bool, error)
- func ReloadEtcdCluster(ctx context.Context, readyEtcdHosts []*hosts.Host, newHost *hosts.Host, ...) error
- func RemoveControlPlane(ctx context.Context, controlHosts []*hosts.Host, force bool) error
- func RemoveEtcdMember(ctx context.Context, etcdHost *hosts.Host, etcdHosts []*hosts.Host, ...) error
- func RemoveEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, force bool) error
- func RemoveWorkerPlane(ctx context.Context, workerHosts []*hosts.Host, force bool) error
- func RestartControlPlane(ctx context.Context, controlHosts []*hosts.Host) error
- func RestartEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host) error
- func RestartKubeAPI(ctx context.Context, host *hosts.Host) error
- func RestartKubeController(ctx context.Context, host *hosts.Host) error
- func RestartKubelet(ctx context.Context, host *hosts.Host) error
- func RestartKubeproxy(ctx context.Context, host *hosts.Host) error
- func RestartNginxProxy(ctx context.Context, host *hosts.Host) error
- func RestartScheduler(ctx context.Context, host *hosts.Host) error
- func RestartWorkerPlane(ctx context.Context, workerHosts []*hosts.Host) error
- func RestoreEtcdSnapshot(ctx context.Context, etcdHost *hosts.Host, ...) error
- func RunControlPlane(ctx context.Context, controlHosts []*hosts.Host, ...) error
- func RunEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, ...) error
- func RunEtcdSnapshotSave(ctx context.Context, etcdHost *hosts.Host, ...) error
- func RunWorkerPlane(ctx context.Context, allHosts []*hosts.Host, ...) error
- func StartBackupServer(ctx context.Context, etcdHost *hosts.Host, ...) error
- type RestartFunc
Constants ¶
View Source
const ( EtcdSnapshotPath = "/opt/zke/etcd-snapshots/" EtcdRestorePath = "/opt/zke/etcd-snapshots-restore/" EtcdDataDir = "/var/lib/zcloud/etcd/" EtcdInitWaitTime = 10 EtcdSnapshotWaitTime = 5 )
View Source
const ( HealthzAddress = "localhost" HealthzEndpoint = "/healthz" HTTPProtoPrefix = "http://" HTTPSProtoPrefix = "https://" )
View Source
const ( ETCDRole = "etcd" ControlRole = "controlplane" WorkerRole = "worker" EdgeRole = "edge" StorageRole = "storage" SidekickServiceName = "sidekick" RBACAuthorizationMode = "rbac" KubeAPIContainerName = "kube-apiserver" KubeletContainerName = "kubelet" KubeproxyContainerName = "kube-proxy" KubeControllerContainerName = "kube-controller-manager" SchedulerContainerName = "kube-scheduler" EtcdContainerName = "etcd" EtcdSnapshotContainerName = "etcd-rolling-snapshots" EtcdSnapshotOnceContainerName = "etcd-snapshot-once" EtcdRestoreContainerName = "etcd-restore" EtcdDownloadBackupContainerName = "etcd-download-backup" EtcdServeBackupContainerName = "etcd-Serve-backup" EtcdChecksumContainerName = "etcd-checksum-checker" NginxProxyContainerName = "nginx-proxy" SidekickContainerName = "service-sidekick" LogLinkContainerName = "zke-log-linker" LogCleanerContainerName = "zke-log-cleaner" KubeAPIPort = 6443 SchedulerPort = 10251 KubeControllerPort = 10252 KubeletPort = 10250 KubeproxyPort = 10256 )
View Source
const (
NginxProxyEnvName = "CP_HOSTS"
)
Variables ¶
This section is empty.
Functions ¶
func AddEtcdMember ¶
func GetEtcdConnString ¶
func GetEtcdInitialCluster ¶
func GetEtcdSnapshotChecksum ¶
func GetHealthCheckURL ¶
func GetProcessConfig ¶
func IsEtcdMember ¶
func ReloadEtcdCluster ¶
func RemoveControlPlane ¶
func RemoveEtcdMember ¶
func RemoveEtcdPlane ¶
func RemoveWorkerPlane ¶
func RestartControlPlane ¶
func RestartKubeController ¶
func RestartWorkerPlane ¶
func RestoreEtcdSnapshot ¶
func RunControlPlane ¶
func RunControlPlane(ctx context.Context, controlHosts []*hosts.Host, prsMap map[string]types.PrivateRegistry, cpNodePlanMap map[string]types.ZKENodePlan, alpineImage string, certMap map[string]pki.CertificatePKI) error
func RunEtcdPlane ¶
func RunEtcdPlane( ctx context.Context, etcdHosts []*hosts.Host, etcdNodePlanMap map[string]types.ZKENodePlan, prsMap map[string]types.PrivateRegistry, alpineImage string, es types.ETCDService, certMap map[string]pki.CertificatePKI) error
func RunEtcdSnapshotSave ¶
func RunWorkerPlane ¶
func RunWorkerPlane(ctx context.Context, allHosts []*hosts.Host, prsMap map[string]types.PrivateRegistry, workerNodePlanMap map[string]types.ZKENodePlan, certMap map[string]pki.CertificatePKI, alpineImage string) error
Types ¶
Click to show internal directories.
Click to hide internal directories.