libinfra

Documentation

Index

• func ContainsCrt(bundle []byte, containedCrt []byte) bool
• func EnsurePodsCertIsSynced(labelSelector string, namespace string, port string) []byte
• func ExpectResumingNodeLabellerToSucceed(nodeName string, virtClient kubecli.KubevirtClient) *k8sv1.Node
• func ExpectStoppingNodeLabellerToSucceed(nodeName string, virtClient kubecli.KubevirtClient) *k8sv1.Node
• func GetBundleFromConfigMap(ctx context.Context, configMapName string) ([]byte, []*x509.Certificate)
• func GetDownwardMetricsDisk(vmi *v1.VirtualMachineInstance) (*api.Metrics, error)
• func GetDownwardMetricsVirtio(vmi *v1.VirtualMachineInstance) (*api.Metrics, error)
• func GetHostnameFromMetrics(metrics *api.Metrics) string
• func GetKeysFromMetrics(metrics map[string]float64) []string
• func GetLeader() string
• func GetMetricKeyForVmiDisk(keys []string, vmiName string, diskName string) string
• func GetTimeFromMetrics(metrics *api.Metrics) int
• func ParseMetricsToMap(lines []string) (map[string]float64, error)
• func TakeMetricsWithPrefix(output, prefix string) []string
• func ValidatedHTTPResponses(errorsChan chan error, concurrency int) error
• func WakeNodeLabellerUp(virtClient kubecli.KubevirtClient)
• type MetricsGetter

Functions

func ContainsCrt

func ContainsCrt(bundle []byte, containedCrt []byte) bool

func EnsurePodsCertIsSynced

func EnsurePodsCertIsSynced(labelSelector string, namespace string, port string) []byte

EnsurePodsCertIsSynced waits until new certificates are rolled out to all pods that are matching the specified labelselector. Once all certificates are in sync, the final secret is returned

func ExpectResumingNodeLabellerToSucceed

func ExpectResumingNodeLabellerToSucceed(nodeName string, virtClient kubecli.KubevirtClient) *k8sv1.Node

func ExpectStoppingNodeLabellerToSucceed

func ExpectStoppingNodeLabellerToSucceed(nodeName string, virtClient kubecli.KubevirtClient) *k8sv1.Node

func GetBundleFromConfigMap

func GetBundleFromConfigMap(ctx context.Context, configMapName string) ([]byte, []*x509.Certificate)

func GetDownwardMetricsDisk

func GetDownwardMetricsDisk(vmi *v1.VirtualMachineInstance) (*api.Metrics, error)

func GetDownwardMetricsVirtio

func GetDownwardMetricsVirtio(vmi *v1.VirtualMachineInstance) (*api.Metrics, error)

func GetHostnameFromMetrics

func GetHostnameFromMetrics(metrics *api.Metrics) string

func GetKeysFromMetrics

func GetKeysFromMetrics(metrics map[string]float64) []string

func GetLeader

func GetLeader() string

func GetMetricKeyForVmiDisk

func GetMetricKeyForVmiDisk(keys []string, vmiName string, diskName string) string

func GetTimeFromMetrics

func GetTimeFromMetrics(metrics *api.Metrics) int

func ParseMetricsToMap

func ParseMetricsToMap(lines []string) (map[string]float64, error)

func TakeMetricsWithPrefix

func TakeMetricsWithPrefix(output, prefix string) []string

func ValidatedHTTPResponses

func ValidatedHTTPResponses(errorsChan chan error, concurrency int) error

ValidatedHTTPResponses checks the HTTP responses. It expects timeout errors, due to the throttling on the producer side. In case of unexpected errors or no errors at all it would fail, returning the first unexpected error if any, or a custom error in case there were no errors at all.

func WakeNodeLabellerUp

func WakeNodeLabellerUp(virtClient kubecli.KubevirtClient)

Types

type MetricsGetter

type MetricsGetter func(vmi *v1.VirtualMachineInstance) (*api.Metrics, error)