utils

func CompareStringNaturalOrder ¶ added in v0.0.5

func CompareStringNaturalOrder(a, b string) bool

CompareStringNaturalOrder compares string in natural order

func GetMountPointIndex ¶ added in v0.0.5

func GetMountPointIndex(pattern, name, mountPoint string) int

GetMountPointIndex calculates index by mount point

func GetNamePrefix ¶ added in v0.0.5

func GetNamePrefix(am discoblocksondatiov1.AvailabilityMode, uniquePerConfig string) string

GetNamePrefix returns the prefix by availability type

func Hash ¶

func Hash(s string) (uint32, error)

Hash calculates has of the given string

func IsContainsAll ¶

func IsContainsAll(a, b map[string]string) bool

IsContainsAll finds for a contains all b

func NewPVC ¶ added in v0.0.5

func NewPVC(config *discoblocksondatiov1.DiskConfig, prefix string, driver *drivers.Driver) (*corev1.PersistentVolumeClaim, error)

NewPVC constructs a new PVC instance

func ParseCapacity ¶

func ParseCapacity(capacity string) (uint16, string, error)

func ParsePrometheusMetric ¶ added in v0.0.2

func ParsePrometheusMetric(metric string) (map[string]*dto.MetricFamily, error)

ParsePrometheusMetric parses Prometheus metrisc details

func ParsePrometheusMetricValue ¶ added in v0.0.2

func ParsePrometheusMetricValue(metric string) (float64, error)

ParsePrometheusMetricValue parses Prometheus metrisc value

func RenderDiskConfigLabel ¶ added in v0.0.5

func RenderDiskConfigLabel(name string) string

RenderDiskConfigLabel renders DiskConfig label

func RenderFinalizer ¶

func RenderFinalizer(name string, extras ...string) string

RenderFinalizer calculates finalizer name

func RenderHostJob ¶ added in v0.0.5

func RenderHostJob(pvcName, namespace, nodeName, dev, fs, mountPoint string, containerIDs []string, getCommand func() (string, error)) (*batchv1.Job, error)

RenderHostJob returns the job executed on host

func RenderMetricsService ¶ added in v0.0.2

func RenderMetricsService(name, namespace string) (*corev1.Service, error)

RenderMetricsService returns the metrics service

func RenderMetricsSidecar ¶ added in v0.0.2

func RenderMetricsSidecar() (*corev1.Container, error)

RenderMetricsSidecar returns the metrics sidecar

func RenderMountPoint ¶

func RenderMountPoint(pattern, name string, index int) string

RenderMountPoint calculates mount point

func RenderResourceName ¶ added in v0.0.5

func RenderResourceName(prefix bool, elems ...string) (string, error)

RenderResourceName calculates resource name

func WaitForSemaphore ¶ added in v0.0.2

func WaitForSemaphore(ctx context.Context, sem Semaphore, errChan chan<- error) (func(), error)

WaitForSemaphore waits until context cancel