utils

Documentation

Index

• 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 NewStorageClass(sc *storagev1.StorageClass, scAllowedTopology []corev1.TopologySelectorTerm) (*storagev1.StorageClass, error)
• func PVCDecorator(config *discoblocksondatiov1.DiskConfig, prefix string, driver *drivers.Driver, ...)
• func ParseCapacity(capacity string) (uint16, string, error)
• func ReadFileOrDie(path string) []byte
• func RenderFinalizer(name string, extras ...string) string
• func RenderMetricsProxySidecar(name, namespace string) (*corev1.Container, error)
• func RenderMetricsSidecar() (*corev1.Container, error)
• func RenderMountJob(podName, pvcName, pvName, namespace, nodeName, fs, mountPoint string, ...) (*batchv1.Job, error)
• func RenderMountPoint(pattern, name string, index int) string
• func RenderResizeJob(...) (*batchv1.Job, error)
• func RenderResourceName(prefix bool, elems ...string) (string, error)
• func RenderUniqueLabel(id string) string
• func WaitForSemaphore(ctx context.Context, sem Semaphore) (func(), error)
• type EventService
  • func NewEventService(controllerID string, k8sClient client.Client) EventService
• type Semaphore
  • func CreateSemaphore(concurrency int, wait time.Duration) Semaphore

Functions

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 NewStorageClass

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

NewStorageClass constructs a new StorageClass

func PVCDecorator

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

PVCDecorator decorates new PVC instance

func ParseCapacity

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

func ReadFileOrDie

func ReadFileOrDie(path string) []byte

ReadFileOrDie reads the file or die

func RenderFinalizer

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

RenderFinalizer calculates finalizer name

func RenderMetricsProxySidecar

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

RenderMetricsProxySidecar returns the metrics sidecar

func RenderMetricsSidecar

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

RenderMetricsSidecar returns the metrics sidecar

func RenderMountJob

func RenderMountJob(podName, 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(podName, 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 WaitForSemaphore

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

WaitForSemaphore waits until context cancel

Types

type EventService

type EventService interface {
	SendWarning(string, string, string, string, string, client.Object, client.Object) error
	SendNormal(string, string, string, string, string, client.Object, client.Object) error
}

EventService main interface of event service

func NewEventService

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

NewEventService creates a new event service

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