v0.7.2 Latest Latest

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

Go to latest
Published: Dec 7, 2017 License: Apache-2.0 Imports: 26 Imported by: 0




View Source
const (
	// EtcdClientPort is the client port on client service and etcd nodes.
	EtcdClientPort = 2379
View Source
const TolerateUnreadyEndpointsAnnotation = "service.alpha.kubernetes.io/tolerate-unready-endpoints"


This section is empty.


func CascadeDeleteOptions added in v0.3.1

func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions

func ClientServiceName added in v0.2.5

func ClientServiceName(clusterName string) string

func ClusterListOpt added in v0.2.0

func ClusterListOpt(clusterName string) metav1.ListOptions

We are using internal api types for cluster related.

func CreateAndWaitPod

func CreateAndWaitPod(kubecli kubernetes.Interface, ns string, pod *v1.Pod, timeout time.Duration) (*v1.Pod, error)

CreateAndWaitPod is a workaround for self hosted and util for testing. We should eventually get rid of this in critical code path and move it to test util.

func CreateCRD added in v0.5.0

func CreateCRD(clientset apiextensionsclient.Interface, crdName, rkind, rplural, shortName string) error

func CreateClientService added in v0.2.5

func CreateClientService(kubecli kubernetes.Interface, clusterName, ns string, owner metav1.OwnerReference) error

func CreatePatch added in v0.2.5

func CreatePatch(o, n, datastruct interface{}) ([]byte, error)

func CreatePeerService added in v0.2.5

func CreatePeerService(kubecli kubernetes.Interface, clusterName, ns string, owner metav1.OwnerReference) error

func GetClusterList added in v0.2.0

func GetClusterList(restcli rest.Interface, ns string) (*api.EtcdClusterList, error)

func GetEtcdVersion

func GetEtcdVersion(pod *v1.Pod) string

func GetPodNames

func GetPodNames(pods []*v1.Pod) []string

func ImageName added in v0.3.3

func ImageName(repo, version string) string

func InClusterConfig added in v0.2.2

func InClusterConfig() (*rest.Config, error)

func IsKubernetesResourceAlreadyExistError

func IsKubernetesResourceAlreadyExistError(err error) bool

func IsKubernetesResourceNotFoundError

func IsKubernetesResourceNotFoundError(err error) bool

func IsNodeReady added in v0.5.0

func IsNodeReady(n v1.Node) bool

IsNodeReady checks if the Node condition is ready.

func IsPodReady added in v0.3.3

func IsPodReady(pod *v1.Pod) bool

IsPodReady returns false if the Pod Status is nil

func LabelsForCluster added in v0.2.6

func LabelsForCluster(clusterName string) map[string]string

func MemberRemoveEvent added in v0.6.0

func MemberRemoveEvent(memberName string, cl *api.EtcdCluster) *v1.Event

func MemberUpgradedEvent added in v0.6.0

func MemberUpgradedEvent(memberName, oldVersion, newVersion string, cl *api.EtcdCluster) *v1.Event

func MustNewKubeClient added in v0.2.1

func MustNewKubeClient() kubernetes.Interface

func MustNewKubeExtClient added in v0.5.0

func MustNewKubeExtClient() apiextensionsclient.Interface

func NewEtcdPod added in v0.2.1

func NewEtcdPod(m *etcdutil.Member, initialCluster []string, clusterName, state, token string, cs api.ClusterSpec, owner metav1.OwnerReference) *v1.Pod

func NewMemberAddEvent added in v0.6.0

func NewMemberAddEvent(memberName string, cl *api.EtcdCluster) *v1.Event

func NewSeedMemberPod added in v0.6.1

func NewSeedMemberPod(clusterName string, ms etcdutil.MemberSet, m *etcdutil.Member, cs api.ClusterSpec, owner metav1.OwnerReference, backupURL *url.URL) *v1.Pod

NewSeedMemberPod returns a Pod manifest for a seed member. It's special that it has new token, and might need recovery init containers

func NewSelfHostedEtcdPod added in v0.2.1

func NewSelfHostedEtcdPod(m *etcdutil.Member, initialCluster, endpoints []string, clusterName, state, token string, cs api.ClusterSpec, owner metav1.OwnerReference) *v1.Pod

func PatchDeployment added in v0.3.0

func PatchDeployment(kubecli kubernetes.Interface, namespace, name string, updateFunc func(*appsv1beta1.Deployment)) error

func PodSpecToPrettyJSON added in v0.4.2

func PodSpecToPrettyJSON(pod *v1.Pod) (string, error)

func PodWithNodeSelector

func PodWithNodeSelector(p *v1.Pod, ns map[string]string) *v1.Pod

func ReplacingDeadMemberEvent added in v0.6.0

func ReplacingDeadMemberEvent(memberName string, cl *api.EtcdCluster) *v1.Event

func SetEtcdVersion

func SetEtcdVersion(pod *v1.Pod, version string)

func WaitCRDReady added in v0.5.0

func WaitCRDReady(clientset apiextensionsclient.Interface, crdName string) error


type EtcdClusterCRUpdateFunc added in v0.5.0

type EtcdClusterCRUpdateFunc func(*api.EtcdCluster)

EtcdClusterCRUpdateFunc is a function to be used when atomically updating a Cluster CR.

type TLSData added in v0.2.6

type TLSData struct {
	CertData []byte
	KeyData  []byte
	CAData   []byte

func GetTLSDataFromSecret added in v0.2.6

func GetTLSDataFromSecret(kubecli kubernetes.Interface, ns, se string) (*TLSData, error)

GetTLSDataFromSecret retrives the kubernete secret that contain etcd tls certs and put them into TLSData.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL