k8sutil

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, cs *spec.ClusterSpec) *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)