Documentation ¶
Index ¶
- Constants
- Variables
- func AddRecoveryToPod(pod *v1.Pod, clusterName, token string, m *etcdutil.Member, ...)
- func AtomicUpdateClusterTPRObject(restcli rest.Interface, name, namespace string, maxRetries int, ...) (*spec.Cluster, error)
- func AttachOperatorS3ToPodSpec(ps *v1.PodSpec, s3Ctx s3config.S3Context)
- func AttachS3ToPodSpec(ps *v1.PodSpec, ss spec.S3Source)
- func BackupServiceAddr(clusterName string) string
- func BackupSidecarLabels(clusterName string) map[string]string
- func BackupSidecarName(clusterName string) string
- func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions
- func ClientServiceName(clusterName string) string
- func ClonePod(p *v1.Pod) *v1.Pod
- func ClusterListOpt(clusterName string) metav1.ListOptions
- func CopyVolume(kubecli kubernetes.Interface, fromClusterName, toClusterName, ns string) error
- func CreateAndWaitPVC(kubecli kubernetes.Interface, clusterName, ns, pvProvisioner string, ...) error
- func CreateAndWaitPod(kubecli kubernetes.Interface, ns string, pod *v1.Pod, timeout time.Duration) (*v1.Pod, 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 CreateStorageClass(kubecli kubernetes.Interface, pvProvisioner string) error
- func DeletePVC(kubecli kubernetes.Interface, clusterName, ns string) error
- func GetClusterList(restcli rest.Interface, ns string) (*spec.ClusterList, error)
- func GetClusterTPRObject(restcli rest.Interface, ns, name string) (*spec.Cluster, error)
- func GetEtcdVersion(pod *v1.Pod) string
- func GetPodNames(pods []*v1.Pod) []string
- func ImageName(baseImage, version string) string
- func InClusterConfig() (*rest.Config, error)
- func IsKubernetesResourceAlreadyExistError(err error) bool
- func IsKubernetesResourceNotFoundError(err error) bool
- func IsPodReady(pod *v1.Pod) bool
- func LabelsForCluster(clusterName string) map[string]string
- func MustNewKubeClient() kubernetes.Interface
- func NewBackupDeploymentManifest(name string, dplSel map[string]string, pl v1.PodTemplateSpec, ...) *appsv1beta1.Deployment
- func NewBackupPodTemplate(clusterName, account string, sp spec.ClusterSpec) v1.PodTemplateSpec
- func NewBackupServiceManifest(clusterName string, owner metav1.OwnerReference) *v1.Service
- func NewEtcdPod(m *etcdutil.Member, initialCluster []string, clusterName, state, token string, ...) *v1.Pod
- func NewSelfHostedEtcdPod(m *etcdutil.Member, initialCluster, endpoints []string, ...) *v1.Pod
- func NewTPRClient() (*rest.RESTClient, error)
- func PatchDeployment(kubecli kubernetes.Interface, namespace, name string, ...) error
- func PodSpecToPrettyJSON(pod *v1.Pod) (string, error)
- func PodSpecWithPV(ps *v1.PodSpec, clusterName string)
- func PodWithAntiAffinity(pod *v1.Pod, clusterName string) *v1.Pod
- func PodWithNodeSelector(p *v1.Pod, ns map[string]string) *v1.Pod
- func SetEtcdVersion(pod *v1.Pod, version string)
- func UpdateClusterTPRObject(restcli rest.Interface, ns string, c *spec.Cluster) (*spec.Cluster, error)
- func WaitEtcdTPRReady(restcli rest.Interface, interval, timeout time.Duration, ns string) error
- func WatchClusters(host, ns string, httpClient *http.Client, resourceVersion string) (*http.Response, error)
- type ClusterTPRUpdateFunc
- type TLSData
Constants ¶
View Source
const ( BackupPodSelectorAppField = "etcd_backup_tool" PVBackupV1 = "v1" // TODO: refactor and combine this with pkg/backup.PVBackupV1 )
View Source
const TolerateUnreadyEndpointsAnnotation = "service.alpha.kubernetes.io/tolerate-unready-endpoints"
Variables ¶
View Source
var BackupImage = "quay.io/coreos/etcd-operator:latest"
Functions ¶
func AddRecoveryToPod ¶
func AtomicUpdateClusterTPRObject ¶ added in v0.2.6
func AtomicUpdateClusterTPRObject(restcli rest.Interface, name, namespace string, maxRetries int, updateFunc ClusterTPRUpdateFunc) (*spec.Cluster, error)
AtomicUpdateClusterTPRObject will get the latest result of a cluster, let user modify it, and update the cluster with modified result The entire process would be retried if there is a conflict of resource version
func AttachOperatorS3ToPodSpec ¶ added in v0.3.0
func BackupServiceAddr ¶ added in v0.2.1
func BackupSidecarLabels ¶ added in v0.2.6
func BackupSidecarName ¶ added in v0.2.6
func CascadeDeleteOptions ¶ added in v0.3.1
func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions
func ClientServiceName ¶ added in v0.2.5
func ClusterListOpt ¶ added in v0.2.0
func ClusterListOpt(clusterName string) metav1.ListOptions
We are using internal api types for cluster related.
func CopyVolume ¶ added in v0.2.0
func CopyVolume(kubecli kubernetes.Interface, fromClusterName, toClusterName, ns string) error
func CreateAndWaitPVC ¶ added in v0.2.0
func CreateAndWaitPVC(kubecli kubernetes.Interface, clusterName, ns, pvProvisioner string, volumeSizeInMB int) error
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 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 CreatePeerService ¶ added in v0.2.5
func CreatePeerService(kubecli kubernetes.Interface, clusterName, ns string, owner metav1.OwnerReference) error
func CreateStorageClass ¶
func CreateStorageClass(kubecli kubernetes.Interface, pvProvisioner string) error
func DeletePVC ¶ added in v0.2.0
func DeletePVC(kubecli kubernetes.Interface, clusterName, ns string) error
func GetClusterList ¶ added in v0.2.0
func GetClusterTPRObject ¶ added in v0.2.0
func GetEtcdVersion ¶
func GetPodNames ¶
func InClusterConfig ¶ added in v0.2.2
func IsPodReady ¶ added in v0.3.3
IsPodReady returns false if the Pod Status is nil
func LabelsForCluster ¶ added in v0.2.6
func MustNewKubeClient ¶ added in v0.2.1
func MustNewKubeClient() kubernetes.Interface
func NewBackupDeploymentManifest ¶ added in v0.2.6
func NewBackupDeploymentManifest(name string, dplSel map[string]string, pl v1.PodTemplateSpec, owner metav1.OwnerReference) *appsv1beta1.Deployment
func NewBackupPodTemplate ¶ added in v0.2.6
func NewBackupPodTemplate(clusterName, account string, sp spec.ClusterSpec) v1.PodTemplateSpec
func NewBackupServiceManifest ¶ added in v0.2.0
func NewBackupServiceManifest(clusterName string, owner metav1.OwnerReference) *v1.Service
func NewEtcdPod ¶ added in v0.2.1
func NewEtcdPod(m *etcdutil.Member, initialCluster []string, clusterName, state, token string, cs spec.ClusterSpec, owner metav1.OwnerReference) *v1.Pod
func NewSelfHostedEtcdPod ¶ added in v0.2.1
func NewSelfHostedEtcdPod(m *etcdutil.Member, initialCluster, endpoints []string, clusterName, state, token string, cs spec.ClusterSpec, owner metav1.OwnerReference) *v1.Pod
func NewTPRClient ¶ added in v0.2.1
func NewTPRClient() (*rest.RESTClient, error)
func PatchDeployment ¶ added in v0.3.0
func PatchDeployment(kubecli kubernetes.Interface, namespace, name string, updateFunc func(*appsv1beta1.Deployment)) error
func PodSpecWithPV ¶ added in v0.2.0
func PodWithAntiAffinity ¶ added in v0.2.0
func SetEtcdVersion ¶
func UpdateClusterTPRObject ¶ added in v0.2.0
func WaitEtcdTPRReady ¶
Types ¶
type ClusterTPRUpdateFunc ¶ added in v0.2.6
ClusterTPRUpdateFunc is a function to be used when atomically updating a Cluster TPR.
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package election implements leader election of a set of endpoints.
|
Package election implements leader election of a set of endpoints. |
Click to show internal directories.
Click to hide internal directories.