Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

k8sutil

package

Go to main page

Versions in this module

v0

v0.2.4

Mar 16, 2017

v0.2.3

Mar 13, 2017

v0.2.2

Mar 10, 2017

Changes in this version

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

v0.2.1

Feb 23, 2017

Changes in this version

+ func BackupServiceAddr(clusterName string) string

+ func BackupServiceName(clusterName string) string

+ func EtcdImageName(version string) string

+ func MustNewKubeClient() kubernetes.Interface

+ func NewBackupPodSpec(clusterName, account string, policy *spec.BackupPolicy) (*v1.PodSpec, error)

+ func NewEtcdPod(m *etcdutil.Member, initialCluster []string, clusterName, state, token string, ...) *v1.Pod

+ func NewSelfHostedEtcdPod(name string, initialCluster []string, clusterName, state, token string, ...) *v1.Pod

+ func NewTPRClient() (*rest.RESTClient, error)

v0.2.0

Feb 11, 2017

Changes in this version

+ const PVBackupV1

+ func ClusterListOpt(clusterName string) api.ListOptions

+ func CopyVolume(kubecli kubernetes.Interface, fromClusterName, toClusterName, ns string) error

+ func CreateAndWaitPVC(kubecli kubernetes.Interface, clusterName, ns, pvProvisioner string, ...) error

+ func CreateMemberService(kubecli kubernetes.Interface, ns string, svc *v1.Service) (*v1.Service, error)

+ func DeletePVC(kubecli kubernetes.Interface, clusterName, ns string) error

+ func GetClusterList(restcli *rest.RESTClient, ns string) (*spec.EtcdClusterList, error)

+ func GetClusterTPRObject(restcli *rest.RESTClient, ns, name string) (*spec.EtcdCluster, error)

+ func MakeBackupPodSpec(clusterName string, policy *spec.BackupPolicy) (*v1.PodSpec, error)

+ func MakeSelfHostedEtcdPod(name string, initialCluster []string, clusterName, state, token string, ...) *v1.Pod

+ func NewBackupReplicaSetManifest(clusterName string, ps v1.PodSpec, owner metatypes.OwnerReference) *v1beta1extensions.ReplicaSet

+ func NewBackupServiceManifest(clusterName string, owner metatypes.OwnerReference) *v1.Service

+ func NewMemberServiceManifest(etcdName, clusterName string, owner metatypes.OwnerReference) *v1.Service

+ func PodSpecWithPV(ps *v1.PodSpec, clusterName string) *v1.PodSpec

+ func PodSpecWithS3(ps *v1.PodSpec, s3Ctx s3config.S3Context) *v1.PodSpec

+ func PodWithAntiAffinity(pod *v1.Pod, clusterName string) *v1.Pod

+ func UpdateClusterTPRObject(restcli *rest.RESTClient, ns string, e *spec.EtcdCluster) (*spec.EtcdCluster, error)

+ func UpdateClusterTPRObjectUnconditionally(restcli *rest.RESTClient, ns string, e *spec.EtcdCluster) (*spec.EtcdCluster, error)

+ func WatchClusters(host, ns string, httpClient *http.Client, resourceVersion string) (*http.Response, error)

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)