util

Documentation

Index

• func CheckDynamicPV(name string) (bool, error)
• func ConsistentRead(filename string, attempts int) ([]byte, error)
• func ContainsString(slice []string, s string) bool
• func DeleteResourceOfPod(pod *corev1.Pod)
• func DoWithinTime(ctx context.Context, timeout time.Duration, cmd *exec.Cmd, f func() error) (out []byte, err error)
• 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 RandStringRunes(n int) string
• func RemoveFinalizer(client *k8sclient.K8sClient, pod *corev1.Pod, finalizer string) error
• 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 CheckDynamicPV

func CheckDynamicPV(name string) (bool, error)

func ConsistentRead

func ConsistentRead(filename string, attempts int) ([]byte, error)

ConsistentRead repeatedly reads a file until it gets the same content twice. This is useful when reading files in /proc that are larger than page size and kernel may modify them between individual read() syscalls.

func ContainsString

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

func DeleteResourceOfPod

func DeleteResourceOfPod(pod *corev1.Pod)

func DoWithinTime

func DoWithinTime(ctx context.Context, timeout time.Duration, cmd *exec.Cmd, f func() error) (out []byte, err error)

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 RandStringRunes

func RandStringRunes(n int) string

func RemoveFinalizer

func RemoveFinalizer(client *k8sclient.K8sClient, pod *corev1.Pod, finalizer string) error

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