utils

Jan 11, 2023

Changes in this version

+ func ReadFileOrDie(path string) []byte

+ func RenderMetricsProxySidecar(name, namespace string) (*corev1.Container, error)

Dec 7, 2022

Changes in this version

+ func FetchDiskInfo(addr string) (map[string]float64, error)

+ func GetTargetNodeByAffinity(affinit *corev1.Affinity) string

+ func IsOwnedByDaemonSet(pod *corev1.Pod) bool

+ func NewStorageClass(sc *storagev1.StorageClass, scAllowedTopology []corev1.TopologySelectorTerm) (*storagev1.StorageClass, error)

+ func PVCDecorator(config *discoblocksondatiov1.DiskConfig, prefix string, driver *drivers.Driver, ...)

+ func RenderMountJob(podName, pvcName, pvName, namespace, nodeName, fs, mountPoint string, ...) (*batchv1.Job, error)

+ func RenderResizeJob(...) (*batchv1.Job, error)

+ func RenderUniqueLabel(id string) string

+ func Telnet(addr string) (lines []string, err error)

+ type EventService interface

+ SendNormal func(string, string, string, string, string, client.Object, client.Object) error

+ SendWarning func(string, string, string, string, string, client.Object, client.Object) error

+ func NewEventService(controllerID string, k8sClient client.Client) EventService

Sep 22, 2022

Changes in this version

+ func CompareStringNaturalOrder(a, b string) bool

+ func GetMountPointIndex(pattern, name, mountPoint string) int

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

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

+ func RenderDiskConfigLabel(name string) string

+ func RenderHostJob(pvcName, namespace, nodeName, dev, fs, mountPoint string, ...) (*batchv1.Job, error)

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

May 13, 2022

Changes in this version

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

+ func ParsePrometheusMetricValue(metric string) (float64, error)

+ func RenderManagerSidecar() (*corev1.Container, error)

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

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

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

+ type Semaphore func() (bool, func())

May 5, 2022

Changes in this version

+ func CreateSemaphore(concurrency int, timeout time.Duration) func() (bool, func())

+ func Hash(s string) uint32

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

+ func IsContainsString(s string, arr []string) bool

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

+ func RenderFinalizer(id string) string

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

+ func RenderPVCName(pod string, config *discoblocksondatiov1.DiskConfig) string

+ func RenderSidecar() (*corev1.Container, error)