k8sutil

package

Go to main page

Versions in this module

v1

v1.3.9

Jul 17, 2020

Changes in this version

+ const BinariesMountPath

+ const Created

+ const FailedStatus

+ const ProcessingStatus

+ const ReadyStatus

+ const ReconcileFailedStatus

+ const ReconcilingStatus

+ const RookVersionLabelKey

+ const TopologyLabelPrefix

+ var WellKnownTaints = []string

+ func AddLabelToDeployment(key, value string, d *v1.Deployment)

+ func AddLabelToJob(key, value string, b *batchv1.Job)

+ func AddLabelToPod(key, value string, p *corev1.PodTemplateSpec)

+ func AddRookVersionLabelToDaemonSet(d *v1.DaemonSet)

+ func AddRookVersionLabelToDeployment(d *v1.Deployment)

+ func AddRookVersionLabelToJob(j *batch.Job)

+ func AddRookVersionLabelToObjectMeta(meta *metav1.ObjectMeta)

+ func AddRookVersionLabelToStatefulSet(ss *apps.StatefulSet)

+ func AddUnreachableNodeToleration(podSpec *v1.PodSpec)

+ func ApplyMultus(net rookv1.NetworkSpec, objectMeta *metav1.ObjectMeta) error

+ func BaseKubernetesDeleteOptions() *metav1.DeleteOptions

+ func BinariesMountInfo() (v1.EnvVar, v1.Volume, v1.VolumeMount)

+ func CreateDaemonSet(name, namespace string, clientset kubernetes.Interface, ds *apps.DaemonSet) error

+ func CreateDeployment(clientset kubernetes.Interface, name, namespace string, dep *apps.Deployment) error

+ func CreateOrUpdateEndpoint(clientset kubernetes.Interface, namespace string, ...) (*v1.Endpoints, error)

+ func CreateOrUpdatePrometheusRule(prometheusRule *monitoringv1.PrometheusRule) (*monitoringv1.PrometheusRule, error)

+ func CreateOrUpdateService(clientset kubernetes.Interface, namespace string, ...) (*v1.Service, error)

+ func CreateOrUpdateServiceMonitor(serviceMonitorDefinition *monitoringv1.ServiceMonitor) (*monitoringv1.ServiceMonitor, error)

+ func CreateStatefulSet(clientset kubernetes.Interface, name, namespace string, ss *apps.StatefulSet) error

+ func DeleteConfigMap(clientset kubernetes.Interface, cmName, namespace string, opts *DeleteOptions) error

+ func DeleteResource(delete func() error, verify func() error, resource string, opts *DeleteOptions, ...) error

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

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

+ func ExtractTopologyFromLabels(labels map[string]string, additionalTopologyIDs []string) map[string]string

+ func ForceDeletePodIfStuck(context *clusterd.Context, pod v1.Pod) error

+ func GenerateNodeAffinity(nodeAffinity string) (*v1.NodeAffinity, error)

+ func GetDaemonsets(clientset kubernetes.Interface, namespace, labelSelector string) (*apps.DaemonSetList, error)

+ func GetKubernetesNodesMatchingRookNodes(rookNodes []rookv1.Node, clientset kubernetes.Interface) ([]v1.Node, error)

+ func GetMultusIfName(selector string) (string, error)

+ func GetNodeHostName(clientset kubernetes.Interface, nodeName string) (string, error)

+ func GetNodeHostNameLabel(node *v1.Node) (string, error)

+ func GetNodeSchedulable(node v1.Node) bool

+ func GetOperatorSetting(clientset kubernetes.Interface, ...) (string, error)

+ func GetPrometheusRule(ruleFilePath string) (*monitoringv1.PrometheusRule, error)

+ func GetServiceMonitor(filePath string) (*monitoringv1.ServiceMonitor, error)

+ func NodeIsReady(node v1.Node) bool

+ func NodeIsTolerable(node v1.Node, tolerations []v1.Toleration, ignoreWellKnownTaints bool) bool

+ func NodeMeetsAffinityTerms(node v1.Node, affinity *v1.NodeAffinity) (bool, error)

+ func NodeMeetsPlacementTerms(node v1.Node, placement rookv1.Placement, ignoreWellKnownTaints bool) (bool, error)

+ func ParseServiceType(serviceString string) v1.ServiceType

+ func RookNodesMatchingKubernetesNodes(rookStorage rookv1.StorageScopeSpec, kubernetesNodes []v1.Node) []rookv1.Node

+ func SetNodeAntiAffinityForPod(pod *v1.PodSpec, p rookv1.Placement, ...)

+ func SetOwnerRefsWithoutBlockOwner(object *metav1.ObjectMeta, ownerRefs []metav1.OwnerReference)

+ func StartOperatorSettingsWatch(context *clusterd.Context, ...)

+ func TaintIsWellKnown(t v1.Taint) bool

+ func UpdateService(clientset kubernetes.Interface, namespace string, ...) (*v1.Service, error)

+ func ValidNodeNoSched(node v1.Node, placement rookv1.Placement) (bool, error)

+ func WatchCR(resource CustomResource, namespace string, ...) error

+ func YamlToTolerations(raw string) ([]v1.Toleration, error)

+ type ContainerResource struct

+ Name string

+ Resource v1.ResourceRequirements

+ func YamlToContainerResource(raw string) ([]ContainerResource, error)

+ type CustomResource struct

+ APIVersion string

+ Group string

+ Kind string

+ Name string

+ Plural string

+ Version string

+ type DeleteOptions struct

+ MustDelete bool

+ type NetworkAttachmentConfig struct

+ CniVersion string

+ Ipam struct{ ... }

+ Master string

+ Mode string

+ Type string

+ func GetNetworkAttachmentConfig(n netapi.NetworkAttachmentDefinition) (NetworkAttachmentConfig, error)

+ type Patcher struct

+ func NewPatcher(object runtime.Object, crclient client.Client) (*Patcher, error)

+ func (p *Patcher) Patch(ctx context.Context, object runtime.Object) error

+ type WaitOptions struct

+ ErrorOnTimeout bool

+ RetryCount uint

+ RetryInterval time.Duration

+ Wait bool

v0

v0.9.2

Jan 26, 2019

v0.9.1

Jan 1, 2019

v0.9.0

Dec 8, 2018

Changes in this version

+ func ClusterDaemonEnvVars() []v1.EnvVar

+ func DeleteBatchJob(clientset kubernetes.Interface, namespace, name string, wait bool) error

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

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

+ func GetDeploymentSpecImage(clientset kubernetes.Interface, d extensions.Deployment, container string) (string, error)

+ func GetDeployments(clientset kubernetes.Interface, namespace, labelSelector string) (*extensions.DeploymentList, error)

+ func GetPodLog(clientset kubernetes.Interface, namespace string, labelSelector string) (string, error)

+ func IndexToName(index int) string

+ func NameToIndex(name string) (int, error)

+ func PodsRunningWithLabel(clientset kubernetes.Interface, namespace, label string) (int, error)

+ func RunReplaceableJob(clientset kubernetes.Interface, job *batch.Job) error

+ func WaitForDeploymentImage(clientset kubernetes.Interface, ...) error

+ func WaitForJobCompletion(clientset kubernetes.Interface, job *batch.Job, timeout time.Duration) error

v0.8.3

Oct 1, 2018

Changes in this version

+ func GetNodeHostNames(clientset kubernetes.Interface) (map[string]string, error)

+ func GetNodeNameFromHostname(clientset kubernetes.Interface, hostName string) (string, error)

v0.8.2

Sep 18, 2018

v0.8.1

Aug 1, 2018

Changes in this version

+ func GetSpecContainerImage(spec v1.PodSpec, name string) (string, error)

+ func GetValidNodes(rookNodes []rookalpha.Node, clientset kubernetes.Interface, ...) []rookalpha.Node

+ func Hash(s string) string

+ func TruncateNodeName(format, nodeName string) string

+ func UpdateDeploymentAndWait(context *clusterd.Context, deployment *v1beta1.Deployment, namespace string) error

+ func ValidNode(node v1.Node, placement rookalpha.Placement) (bool, error)

v0.8.0

Jul 18, 2018

Changes in this version

+ func GetMatchingContainer(containers []v1.Container, name string) (v1.Container, error)

+ func GetPodPhaseMap(pods *v1.PodList) map[v1.PodPhase][]string

+ func GetRunningPod(clientset kubernetes.Interface) (*v1.Pod, error)

+ func SetOwnerRef(clientset kubernetes.Interface, namespace string, object *metav1.ObjectMeta, ...)

+ func SetOwnerRefs(clientset kubernetes.Interface, namespace string, object *metav1.ObjectMeta, ...)

type ConfigMapKVStore

+ func (kv *ConfigMapKVStore) SetValueWithLabels(storeName, key, value string, labels map[string]string) error

v0.7.1

Mar 9, 2018

v0.7.0

Feb 21, 2018

Changes in this version

+ const FirstCRDVersion

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

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

v0.6.2

Dec 12, 2017

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()

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