k8sutil

Documentation

Index

• func GetPodLogStream(pod corev1.Pod, opts *corev1.PodLogOptions, clientset kubernetes.Interface) (io.ReadCloser, error)
• func GetXrootdLabelSelector(component types.ComponentName, instanceName string) (labels.Selector, error)
• func UpdatePodCondition(pod *corev1.Pod, condType corev1.PodConditionType, ...) error
• func UpdatePodConditionWithBool(pod *corev1.Pod, condType corev1.PodConditionType, condStatus *bool, ...) error

Functions

func GetPodLogStream

func GetPodLogStream(pod corev1.Pod, opts *corev1.PodLogOptions, clientset kubernetes.Interface) (io.ReadCloser, error)

GetPodLogStream gives a IO stream of logs of pod with respect to provided options. Source - https://stackoverflow.com/a/53870271/2674983

func GetXrootdLabelSelector

func GetXrootdLabelSelector(component types.ComponentName, instanceName string) (labels.Selector, error)

GetXrootdLabelSelector returns the label selector to match those sub-resources, belonging to given CR instance and given component.

func UpdatePodCondition

func UpdatePodCondition(pod *corev1.Pod, condType corev1.PodConditionType, condStatus corev1.ConditionStatus, reason string, kubeclient client.Client) error

UpdatePodCondition updates the given condition type of the given pod with the new status and reason

func UpdatePodConditionWithBool

func UpdatePodConditionWithBool(pod *corev1.Pod, condType corev1.PodConditionType, condStatus *bool, reason string, kubeclient client.Client) error

UpdatePodConditionWithBool updates the given condition type of the given pod with the new status and reason. It accepts bool conditional status and internally calls UpdatePodCondition with correct status value