util

Documentation

Index

• func ContainsString(slice []string, s string) bool
• func DeleteResourceOfPod(pod *corev1.Pod)
• func GetMountDeviceRefs(pathname string, corrupted bool) ([]string, error)
• func GetMountPathOfPod(pod corev1.Pod) (string, string, error)
• func GetReferenceKey(target string) string
• func GetTime(str string) (time.Time, error)
• func GetTimeAfterDelay(delayStr string) (string, error)
• func IsJobCompleted(job *batchv1.Job) bool
• func IsJobFailed(job *batchv1.Job) bool
• func IsPodError(pod *corev1.Pod) bool
• func IsPodHasResource(pod corev1.Pod) bool
• func IsPodReady(pod *corev1.Pod) bool
• func IsPodResourceError(pod *corev1.Pod) bool
• func ParseEndpoint(endpoint string) (string, string, error)
• func ParseMntPath(cmd string) (string, string, error)
• func PatchPodAnnotation(client *k8s.K8sClient, pod *corev1.Pod, annotation map[string]string) error
• func QuoteForShell(cmd string) string
• func ShouldDelay(pod *corev1.Pod, Client *k8s.K8sClient) (shouldDelay bool, err error)
• func StripPasswd(uri string) string
• type PVCMetadata
  • func NewPVCMeta(pvc v1.PersistentVolumeClaim) *PVCMetadata
  • func (meta *PVCMetadata) StringParser(str string) string

Functions

func ContainsString

func ContainsString(slice []string, s string) bool

func DeleteResourceOfPod

func DeleteResourceOfPod(pod *corev1.Pod)

func GetMountDeviceRefs

func GetMountDeviceRefs(pathname string, corrupted bool) ([]string, error)

GetMountDeviceRefs Get all mountpoints whose source is the device of `pathname` mountpoint, the `pathname` will be excluded. The `pathname` must be a mountpoint, and if the `corrupted` is true, the `pathname` is a corrupted mountpoint.

func GetMountPathOfPod

func GetMountPathOfPod(pod corev1.Pod) (string, string, error)

func GetReferenceKey

func GetReferenceKey(target string) string

func GetTime

func GetTime(str string) (time.Time, error)

func GetTimeAfterDelay

func GetTimeAfterDelay(delayStr string) (string, error)

GetTimeAfterDelay get time which after delay

func IsJobCompleted

func IsJobCompleted(job *batchv1.Job) bool

func IsJobFailed

func IsJobFailed(job *batchv1.Job) bool

func IsPodError

func IsPodError(pod *corev1.Pod) bool

func IsPodHasResource

func IsPodHasResource(pod corev1.Pod) bool

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

func IsPodResourceError

func IsPodResourceError(pod *corev1.Pod) bool

func ParseEndpoint

func ParseEndpoint(endpoint string) (string, string, error)

func ParseMntPath

func ParseMntPath(cmd string) (string, string, error)

ParseMntPath return mntPath, volumeId (/jfs/volumeId, volumeId err)

func PatchPodAnnotation

func PatchPodAnnotation(client *k8s.K8sClient, pod *corev1.Pod, annotation map[string]string) error

func QuoteForShell

func QuoteForShell(cmd string) string

func ShouldDelay

func ShouldDelay(pod *corev1.Pod, Client *k8s.K8sClient) (shouldDelay bool, err error)

func StripPasswd

func StripPasswd(uri string) string

Types

type PVCMetadata

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

func NewPVCMeta

func NewPVCMeta(pvc v1.PersistentVolumeClaim) *PVCMetadata

func (*PVCMetadata) StringParser

func (meta *PVCMetadata) StringParser(str string) string