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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.