k8sutil

Documentation

Overview

Package k8sutil for Kubernetes helpers.

Package k8sutil for Kubernetes helpers.

Package k8sutil for Kubernetes helpers.

Package k8sutil for Kubernetes helpers.

Package k8sutil for Kubernetes helpers.

Package k8sutil for Kubernetes helpers.

Index

• Constants
• func ConfigDirEnvVar() v1.EnvVar
• func ConfigOverrideEnvVar() v1.EnvVar
• func ConfigOverrideMount() v1.VolumeMount
• func ConfigOverrideVolume() v1.Volume
• func DeleteDaemonset(clientset kubernetes.Interface, namespace, name string) error
• func DeleteDeployment(clientset kubernetes.Interface, namespace, name string) error
• func GetContainerImage(clientset kubernetes.Interface) (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 MakeRookImage(version string) string
• func MergeResourceRequirements(first, second v1.ResourceRequirements) v1.ResourceRequirements
• func NameEnvVar() v1.EnvVar
• func NamespaceEnvVar() v1.EnvVar
• func NodeConfigURI() (string, error)
• func NodeEnvVar() v1.EnvVar
• func PathToVolumeName(path string) string
• func PodIPEnvVar(property string) v1.EnvVar
• type ConfigMapKVStore
  • 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

Constants

const (
	// Namespace for rook
	Namespace = "rook"
	// DefaultNamespace for the cluster
	DefaultNamespace = "default"
	// DataDirVolume data dir volume
	DataDirVolume = "rook-data"
	// DataDir folder
	DataDir = "/var/lib/rook"
	// RookType for the CRD
	RookType = "kubernetes.io/rook"
	// PodNameEnvVar is the env variable for getting the pod name via downward api
	PodNameEnvVar = "POD_NAME"
	// PodNamespaceEnvVar is the env variable for getting the pod namespace via downward api
	PodNamespaceEnvVar = "POD_NAMESPACE"
	// NodeNameEnvVar is the env variable for getting the node via downward api
	NodeNameEnvVar = "NODE_NAME"
	// FirstCRDVersion is the first K8s version with CRDs to replace TPRs
	FirstCRDVersion = "v1.7.0"
)

const (
	// AppAttr app label
	AppAttr = "app"
	// ClusterAttr cluster label
	ClusterAttr = "rook_cluster"
	// PublicIPEnvVar public IP env var
	PublicIPEnvVar = "ROOK_PUBLIC_IPV4"
	// PrivateIPEnvVar pod IP env var
	PrivateIPEnvVar = "ROOK_PRIVATE_IPV4"

	// DefaultRepoPrefix repo prefix
	DefaultRepoPrefix = "rook"
	// ConfigOverrideName config override name
	ConfigOverrideName = "rook-config-override"
	// ConfigOverrideVal config override value
	ConfigOverrideVal = "config"
)

Functions

func ConfigDirEnvVar

func ConfigDirEnvVar() v1.EnvVar

ConfigDirEnvVar config dir env var

func ConfigOverrideEnvVar

func ConfigOverrideEnvVar() v1.EnvVar

ConfigOverrideEnvVar config override env var

func ConfigOverrideMount

func ConfigOverrideMount() v1.VolumeMount

ConfigOverrideMount is an override mount

func ConfigOverrideVolume

func ConfigOverrideVolume() v1.Volume

ConfigOverrideVolume is an override volume

func DeleteDaemonset

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

DeleteDaemonset makes a best effort at deleting a daemonset and its pods, then waits for them to be deleted

func DeleteDeployment

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

DeleteDeployment makes a best effort at deleting a deployment and its pods, then waits for them to be deleted

func GetContainerImage

func GetContainerImage(clientset kubernetes.Interface) (string, error)

func GetK8SVersion

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

GetK8SVersion gets the version of the running K8S cluster

func MakeClusterRole

func MakeClusterRole(clientset kubernetes.Interface, namespace, name string, rules []v1beta1.PolicyRule, ownerRef *metav1.OwnerReference) error

func MakeRole

func MakeRole(clientset kubernetes.Interface, namespace, name string, rules []v1beta1.PolicyRule, ownerRef metav1.OwnerReference) error

func MakeRookImage

func MakeRookImage(version string) string

MakeRookImage formats the container name

func MergeResourceRequirements

func MergeResourceRequirements(first, second v1.ResourceRequirements) v1.ResourceRequirements

func NameEnvVar

func NameEnvVar() v1.EnvVar

NameEnvVar pod name env var

func NamespaceEnvVar

func NamespaceEnvVar() v1.EnvVar

NamespaceEnvVar namespace env var

func NodeConfigURI

func NodeConfigURI() (string, error)

NodeConfigURI returns the node config URI path for this node

func NodeEnvVar

func NodeEnvVar() v1.EnvVar

NodeEnvVar node env var

func PathToVolumeName

func PathToVolumeName(path string) string

PathToVolumeName converts a path to a valid volume name

func PodIPEnvVar

func PodIPEnvVar(property string) v1.EnvVar

PodIPEnvVar private ip env var

Types

type ConfigMapKVStore

type ConfigMapKVStore struct {
	// contains filtered or unexported fields
}

func NewConfigMapKVStore

func NewConfigMapKVStore(namespace string, clientset kubernetes.Interface, ownerRef metav1.OwnerReference) *ConfigMapKVStore

func (*ConfigMapKVStore) ClearStore

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

func (*ConfigMapKVStore) GetStore

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

func (*ConfigMapKVStore) GetValue

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

func (*ConfigMapKVStore) SetValue

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