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.6.1

Dec 4, 2017

v0.6.0

Nov 8, 2017

Changes in this version

+ const NodeNameEnvVar

+ const PodNameEnvVar

+ const PodNamespaceEnvVar

+ func DeleteDaemonset(clientset kubernetes.Interface, namespace, name string) error

+ func DeleteDeployment(clientset kubernetes.Interface, namespace, name string) error

+ func GetK8SVersion(clientset kubernetes.Interface) (*version.Version, error)

+ func MakeClusterRole(clientset kubernetes.Interface, namespace, name string, ...) error

+ func MakeRole(clientset kubernetes.Interface, namespace, name string, ...) error

+ func NameEnvVar() v1.EnvVar

+ func NodeConfigURI() (string, error)

+ func NodeEnvVar() v1.EnvVar

+ type ConfigMapKVStore struct

+ func NewConfigMapKVStore(namespace string, clientset kubernetes.Interface) *ConfigMapKVStore

+ func (kv *ConfigMapKVStore) ClearStore(storeName string) error

+ func (kv *ConfigMapKVStore) GetStore(storeName string) (map[string]string, error)

+ func (kv *ConfigMapKVStore) GetValue(storeName, key string) (string, error)

+ func (kv *ConfigMapKVStore) SetValue(storeName, key, value string) error

type Placement

+ PodAffinity *v1.PodAffinity

+ PodAntiAffinity *v1.PodAntiAffinity

v0.5.1

Aug 15, 2017

v0.5.0

Aug 8, 2017

Changes in this version

+ const ConfigOverrideName

+ const ConfigOverrideVal

+ const CustomResourceGroup

+ const PrivateIPEnvVar

+ const PublicIPEnvVar

+ const V1

+ const V1Alpha1

+ const V1Beta1

+ func ConfigOverrideEnvVar() v1.EnvVar

+ func ConfigOverrideMount() v1.VolumeMount

+ func ConfigOverrideVolume() v1.Volume

+ type Placement struct

+ NodeAffinity *v1.NodeAffinity

+ Tolerations []v1.Toleration

+ func (p Placement) ApplyToPodSpec(t *v1.PodSpec)

+ func (p Placement) Merge(with Placement) Placement

v0.4.0

May 3, 2017

Changes in this version

+ func ConfigDirEnvVar() v1.EnvVar

+ func PathToVolumeName(path string) string

+ func RepoPrefixEnvVar() v1.EnvVar

+ type Context struct

+ Clientset kubernetes.Interface

+ Factory client.ConnectionFactory

+ KubeHttpCli *http.Client

+ MasterHost string

+ MaxRetries int

+ RetryDelay int

v0.3.1

Mar 28, 2017

v0.3.0

Mar 3, 2017

Changes in this version

+ const AppAttr

+ const ClusterAttr

+ const DataDir

+ const DataDirVolume

+ const DefaultNamespace

+ const DefaultRepoPrefix

+ const Namespace

+ const PodIPEnvVar

+ const RbdType

+ const RookType

+ const VersionAttr

+ func GetPodNames(pods []*api.Pod) []string

+ func IsKubernetesResourceAlreadyExistError(err error) bool

+ func IsKubernetesResourceNotFoundError(err error) bool

+ func MakeRookImage(version string) string

+ func MakeRookOperatorImage(version string) string

+ func NamespaceEnvVar() v1.EnvVar

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

+ func RepoPrefix() string

+ func Retry(interval time.Duration, maxRetries int, f ConditionFunc) error

+ func SetPodVersion(pod *v1.Pod, key, version string)

+ type ConditionFunc func() (bool, error)

+ type PanicTimer struct

+ func NewPanicTimer(d time.Duration, msg string) *PanicTimer

+ func (pt *PanicTimer) Start()

+ func (pt *PanicTimer) Stop()