Affected by 
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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ContainsCrt ¶
func ContainsCrt(bundle []byte, containedCrt []byte) bool
func EnsurePodsCertIsSynced ¶ added in v1.4.0
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 ¶ added in v1.4.0
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 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)
Source Files
Click to show internal directories.
Click to hide internal directories.