util

Documentation

Index

• Constants
• Variables
• func CheckDynamicPV(name string) (bool, error)
• func CheckExpectValue(m map[string]string, key string, targetValue string) bool
• func ContainSubString(slice []string, s string) bool
• func ContainsEnv(envs []corev1.EnvVar, key string) bool
• func ContainsPrefix(slice []string, s string) bool
• func ContainsString(slice []string, s string) bool
• func ContainsVolumeDevices(vds []corev1.VolumeDevice, name string) bool
• func ContainsVolumeMounts(vms []corev1.VolumeMount, name string) bool
• func ContainsVolumes(volumes []corev1.Volume, name string) bool
• func DevMinor(dev uint64) uint32
• func DevMinorTableDelete(k any)
• func DevMinorTableLoad(k any) (uint32, bool)
• func DevMinorTableStore(k any, dev uint64)
• func DoWithContext(ctx context.Context, f func() error) error
• func DoWithTimeout(parent context.Context, timeout time.Duration, f func() error) error
• func Exists(path string) bool
• func GenLog(ctx context.Context, log klog.Logger, name string) klog.Logger
• func GetDiskUsage(path string) (uint64, uint64, uint64, uint64)
• func GetMountDeviceRefs(pathname string, corrupted bool) ([]string, error)
• func GetMountOptionsOfPod(pod *corev1.Pod) []string
• 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 ImageResol(image string) (hasCE, hasEE bool)
• func ImageSupportBinary(image string) bool
• func NewPrometheus(nodeName string) (prometheus.Registerer, *prometheus.Registry)
• func ParseEndpoint(endpoint string) (string, string, error)
• func ParseToBytes(value string) (uint64, error)
• func QuoteForShell(cmd string) string
• func RandStringRunes(n int) string
• func StripPasswd(uri string) string
• func StripReadonlyOption(options []string) []string
• func SupportFusePass(image string) bool
• func SupportUpgradeBinary(ce bool, version string) bool
• func SupportUpgradeRecreate(ce bool, version string) bool
• func UmountPath(ctx context.Context, sourcePath string)
• func WithLog(parentCtx context.Context, log klog.Logger) context.Context
• type ClientVersion
  • func (v ClientVersion) LessThan(o ClientVersion) bool
• type JuiceConf
  • func ParseConfig(conf []byte) (*JuiceConf, error)
• type LoggerType

Constants

const LogKey = "jfs-logger"

Variables

var (
	MountPointDevMinorTable sync.Map
)

Functions

func CheckDynamicPV

func CheckDynamicPV(name string) (bool, error)

func CheckExpectValue

func CheckExpectValue(m map[string]string, key string, targetValue string) bool

CheckExpectValue Check if the key has the expected value

func ContainSubString

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

func ContainsEnv

func ContainsEnv(envs []corev1.EnvVar, key string) bool

func ContainsPrefix

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

ContainsPrefix String checks if a string slice contains a string with a given prefix

func ContainsString

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

ContainsString checks if a string is in a string slice.

func ContainsVolumeDevices

func ContainsVolumeDevices(vds []corev1.VolumeDevice, name string) bool

func ContainsVolumeMounts

func ContainsVolumeMounts(vms []corev1.VolumeMount, name string) bool

func ContainsVolumes

func ContainsVolumes(volumes []corev1.Volume, name string) bool

func DevMinor

func DevMinor(dev uint64) uint32

DevMinor returns the minor component of a Linux device number.

func DevMinorTableDelete

func DevMinorTableDelete(k any)

func DevMinorTableLoad

func DevMinorTableLoad(k any) (uint32, bool)

func DevMinorTableStore

func DevMinorTableStore(k any, dev uint64)

func DoWithContext

func DoWithContext(ctx context.Context, f func() error) error

func DoWithTimeout

func DoWithTimeout(parent context.Context, timeout time.Duration, f func() error) error

func Exists

func Exists(path string) bool

func GenLog

func GenLog(ctx context.Context, log klog.Logger, name string) klog.Logger

func GetDiskUsage

func GetDiskUsage(path string) (uint64, uint64, uint64, uint64)

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 GetMountOptionsOfPod

func GetMountOptionsOfPod(pod *corev1.Pod) []string

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 ImageResol

func ImageResol(image string) (hasCE, hasEE bool)

ImageResol check if image contains CE or EE ce image starts with "ce-" (latest image is CE) ee image starts with "ee-" Compatible with previous images: has both ce and ee

func ImageSupportBinary

func ImageSupportBinary(image string) bool

func NewPrometheus

func NewPrometheus(nodeName string) (prometheus.Registerer, *prometheus.Registry)

func ParseEndpoint

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

func ParseToBytes

func ParseToBytes(value string) (uint64, error)

ParseToBytes parses a string with a unit suffix (e.g. "1M", "2G") to bytes. default unit is M

func QuoteForShell

func QuoteForShell(cmd string) string

func RandStringRunes

func RandStringRunes(n int) string

func StripPasswd

func StripPasswd(uri string) string

func StripReadonlyOption

func StripReadonlyOption(options []string) []string

func SupportFusePass

func SupportFusePass(image string) bool

func SupportUpgradeBinary

func SupportUpgradeBinary(ce bool, version string) bool

func SupportUpgradeRecreate

func SupportUpgradeRecreate(ce bool, version string) bool

func UmountPath

func UmountPath(ctx context.Context, sourcePath string)

func WithLog

func WithLog(parentCtx context.Context, log klog.Logger) context.Context

Types

type ClientVersion

type ClientVersion struct {
	IsCe  bool
	Dev   bool
	Major int
	Minor int
	Patch int
}

func (ClientVersion) LessThan

func (v ClientVersion) LessThan(o ClientVersion) bool

type JuiceConf

type JuiceConf struct {
	Meta struct {
		Sid uint64
	}
	Pid  int
	PPid int
}

func ParseConfig

func ParseConfig(conf []byte) (*JuiceConf, error)

type LoggerType

type LoggerType string