Versions in this module Expand all Collapse all v0 v0.1.0 Nov 2, 2016 Changes in this version + const BackupPodSelectorAppField + var BackupImage = "quay.io/coreos/etcd-operator:latest" + func AddRecoveryToPod(pod *api.Pod, clusterName, name, token string, cs *spec.ClusterSpec) + func CreateAndWaitPod(kclient *unversioned.Client, ns string, pod *api.Pod, timeout time.Duration) error + func CreateBackupReplicaSetAndService(kubecli *unversioned.Client, clusterName, ns string, policy spec.BackupPolicy) error + func CreateEtcdNodePortService(kclient *unversioned.Client, etcdName, clusterName, ns string) (*api.Service, error) + func CreateEtcdService(kclient *unversioned.Client, etcdName, clusterName, ns string) (*api.Service, error) + func CreateStorageClass(kubecli *unversioned.Client, pvProvisioner string) error + func DeleteBackupReplicaSetAndService(kubecli *unversioned.Client, clusterName, ns string, cleanup bool) error + func EtcdPodListOpt(clusterName string) api.ListOptions + func GetEtcdVersion(pod *api.Pod) string + func GetNodePortString(srv *api.Service) string + func GetPodNames(pods []*api.Pod) []string + func IsKubernetesResourceAlreadyExistError(err error) bool + func IsKubernetesResourceNotFoundError(err error) bool + func ListETCDCluster(host, ns string, httpClient *http.Client) (*http.Response, error) + func MakeBackupHostPort(clusterName string) string + func MakeBackupName(clusterName string) string + func MakeEtcdImage(version string) string + func MakeEtcdPod(m *etcdutil.Member, initialCluster []string, clusterName, state, token string, ...) *api.Pod + func MustCreateClient(host string, tlsInsecure bool, tlsConfig *restclient.TLSClientConfig) *unversioned.Client + func MustGetInClusterMasterHost() string + func PodWithAddMemberInitContainer(p *api.Pod, name string, peerURLs []string, cs *spec.ClusterSpec) *api.Pod + func PodWithNodeSelector(p *api.Pod, ns map[string]string) *api.Pod + func SetEtcdVersion(pod *api.Pod, version string) + func WaitEtcdTPRReady(httpClient *http.Client, interval, timeout time.Duration, host, ns string) error + func WatchETCDCluster(host, ns string, httpClient *http.Client, resourceVersion string) (*http.Response, error)
Go to main page