Versions in this module Expand all Collapse all v0 v0.9.4 Feb 28, 2019 Changes in this version + const AnnotationClusterWide + const AnnotationScope + const EtcdClientPort + const MaxNameLength + const TolerateUnreadyEndpointsAnnotation + func AddEtcdVolumeToPod(pod *v1.Pod, pvc *v1.PersistentVolumeClaim) + func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions + func ClientServiceName(clusterName string) string + func ClusterListOpt(clusterName string) metav1.ListOptions + func CreateAndWaitPod(kubecli kubernetes.Interface, ns string, pod *v1.Pod, timeout time.Duration) (*v1.Pod, error) + func CreateCRD(clientset apiextensionsclient.Interface, ...) error + func CreateClientService(kubecli kubernetes.Interface, clusterName, ns string, ...) error + func CreatePatch(o, n, datastruct interface{}) ([]byte, error) + func CreatePeerService(kubecli kubernetes.Interface, clusterName, ns string, ...) error + func GetClusterList(restcli rest.Interface, ns string) (*api.EtcdClusterList, error) + func GetEtcdVersion(pod *v1.Pod) string + func GetPodNames(pods []*v1.Pod) []string + func ImageName(repo, version string) string + func InClusterConfig() (*rest.Config, error) + func IsKubernetesResourceAlreadyExistError(err error) bool + func IsKubernetesResourceNotFoundError(err error) bool + func IsNodeReady(n v1.Node) bool + func IsPodReady(pod *v1.Pod) bool + func LabelsForCluster(clusterName string) map[string]string + func MemberRemoveEvent(memberName string, cl *api.EtcdCluster) *v1.Event + func MemberUpgradedEvent(memberName, oldVersion, newVersion string, cl *api.EtcdCluster) *v1.Event + func MustNewKubeClient() kubernetes.Interface + func MustNewKubeExtClient() apiextensionsclient.Interface + func NewEtcdPod(m *etcdutil.Member, initialCluster []string, clusterName, state, token string, ...) *v1.Pod + func NewEtcdPodPVC(m *etcdutil.Member, pvcSpec v1.PersistentVolumeClaimSpec, ...) *v1.PersistentVolumeClaim + func NewMemberAddEvent(memberName string, cl *api.EtcdCluster) *v1.Event + func NewSeedMemberPod(clusterName string, ms etcdutil.MemberSet, m *etcdutil.Member, ...) *v1.Pod + func PVCNameFromMember(memberName string) string + func PatchDeployment(kubecli kubernetes.Interface, namespace, name string, ...) error + func PodSpecToPrettyJSON(pod *v1.Pod) (string, error) + func PodWithNodeSelector(p *v1.Pod, ns map[string]string) *v1.Pod + func ReplacingDeadMemberEvent(memberName string, cl *api.EtcdCluster) *v1.Event + func SetEtcdVersion(pod *v1.Pod, version string) + func UniqueMemberName(clusterName string) string + func WaitCRDReady(clientset apiextensionsclient.Interface, crdName string) error + type EtcdClusterCRUpdateFunc func(*api.EtcdCluster) + type TLSData struct + CAData []byte + CertData []byte + KeyData []byte + func GetTLSDataFromSecret(kubecli kubernetes.Interface, ns, se string) (*TLSData, error)
Go to main page