utils

Documentation

Index

• func FetchDiskInfo(addr string) (map[string]float64, error)
• func GetNamePrefix(am discoblocksondatiov1.AvailabilityMode, configUID, nodeName string) string
• func GetTargetNodeByAffinity(affinit *corev1.Affinity) string
• func Hash(s string) (uint32, error)
• func IsContainsAll(a, b map[string]string) bool
• func IsOwnedByDaemonSet(pod *corev1.Pod) bool
• func NewPVC(config *discoblocksondatiov1.DiskConfig, prefix string, driver *drivers.Driver) (*corev1.PersistentVolumeClaim, error)
• func NewStorageClass(sc *storagev1.StorageClass, scAllowedTopology []corev1.TopologySelectorTerm) (*storagev1.StorageClass, error)
• func ParseCapacity(capacity string) (uint16, string, error)
• func RenderFinalizer(name string, extras ...string) string
• func RenderMetricsSidecar() (*corev1.Container, error)
• func RenderMountJob(pvcName, pvName, namespace, nodeName, fs, mountPoint string, ...) (*batchv1.Job, error)
• func RenderMountPoint(pattern, name string, index int) string
• func RenderResizeJob(pvcName, pvName, namespace, nodeName, fs, preResizeCommand, volumeMeta string, ...) (*batchv1.Job, error)
• func RenderResourceName(prefix bool, elems ...string) (string, error)
• func RenderUniqueLabel(id string) string
• func Telnet(addr string) (lines []string, err error)
• func WaitForSemaphore(ctx context.Context, sem Semaphore) (func(), error)
• type Semaphore
  • func CreateSemaphore(concurrency int, wait time.Duration) Semaphore

Functions

func FetchDiskInfo

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

FetchDiskInfo calls 'df' on the remote address

func GetNamePrefix

func GetNamePrefix(am discoblocksondatiov1.AvailabilityMode, configUID, nodeName string) string

GetNamePrefix returns the prefix by availability type

func GetTargetNodeByAffinity

func GetTargetNodeByAffinity(affinit *corev1.Affinity) string

GetTargetNodeByAffinity tries to find node by affinity

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 IsOwnedByDaemonSet

func IsOwnedByDaemonSet(pod *corev1.Pod) bool

IsOwnedByDaemonSet detects is parent DaemonSet

func NewPVC

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

NewPVC constructs a new PVC instance

func NewStorageClass

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

NewStorageClass constructs a new StorageClass

func ParseCapacity

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

func RenderFinalizer

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

RenderFinalizer calculates finalizer name

func RenderMetricsSidecar

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

RenderMetricsSidecar returns the metrics sidecar

func RenderMountJob

func RenderMountJob(pvcName, pvName, namespace, nodeName, fs, mountPoint string, containerIDs []string, preMountCommand, volumeMeta string, owner metav1.OwnerReference) (*batchv1.Job, error)

RenderMountJob returns the mount job executed on host

func RenderMountPoint

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

RenderMountPoint calculates mount point

func RenderResizeJob

func RenderResizeJob(pvcName, pvName, namespace, nodeName, fs, preResizeCommand, volumeMeta string, owner metav1.OwnerReference) (*batchv1.Job, error)

RenderResizeJob returns the resize job executed on host

func RenderResourceName

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

RenderResourceName calculates resource name

func RenderUniqueLabel

func RenderUniqueLabel(id string) string

RenderUniqueLabel renders DiskConfig label

func Telnet

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

Telnet calls endpoint and reads response

func WaitForSemaphore

func WaitForSemaphore(ctx context.Context, sem Semaphore) (func(), error)

WaitForSemaphore waits until context cancel

Types

type Semaphore

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

Semaphore

func CreateSemaphore

func CreateSemaphore(concurrency int, wait time.Duration) Semaphore

CreateSemaphore creates a new semaphore to limit concurrency