libinfra

package

v1.2.0 Latest Latest Go to latest Published: Feb 26, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubevirt/kubevirt

Links

Open Source Insights

Documentation ¶

Index ¶

func ContainsCrt(bundle []byte, containedCrt []byte) bool
func ExpectResumingNodeLabellerToSucceed(nodeName string, virtClient kubecli.KubevirtClient) *k8sv1.Node
func ExpectStoppingNodeLabellerToSucceed(nodeName string, virtClient kubecli.KubevirtClient) *k8sv1.Node
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 GetNewLeaderPod(virtClient kubecli.KubevirtClient) *v12.Pod
func GetSupportedIP(ips []string, family v1.IPFamily) 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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ContainsCrt ¶

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

func ExpectResumingNodeLabellerToSucceed ¶

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

func ExpectStoppingNodeLabellerToSucceed ¶

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

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 GetNewLeaderPod ¶

func GetNewLeaderPod(virtClient kubecli.KubevirtClient) *v12.Pod

func GetSupportedIP ¶

func GetSupportedIP(ips []string, family v1.IPFamily) 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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL