mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-17 15:50:10 +00:00
Fix gofmt issues
This commit is contained in:
parent
7622a794da
commit
b3baef5e05
@ -34,11 +34,10 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
eventRetryPeriod = 1 * time.Second
|
eventRetryPeriod = 1 * time.Second
|
||||||
eventRetryTimeout = 1 * time.Minute
|
eventRetryTimeout = 1 * time.Minute
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
// Action is a function to be performed by the system.
|
// Action is a function to be performed by the system.
|
||||||
type Action func() error
|
type Action func() error
|
||||||
|
|
||||||
@ -205,19 +204,19 @@ func eventOccurred(c clientset.Interface, namespace, eventSelector, msg string)
|
|||||||
}
|
}
|
||||||
|
|
||||||
func deleteEventCollection(f *framework.Framework, label string) func() (bool, error) {
|
func deleteEventCollection(f *framework.Framework, label string) func() (bool, error) {
|
||||||
return func() (bool, error) {
|
return func() (bool, error) {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
framework.Logf("requesting DeleteCollection of events")
|
framework.Logf("requesting DeleteCollection of events")
|
||||||
|
|
||||||
err = f.ClientSet.CoreV1().Events(f.Namespace.Name).DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{
|
err = f.ClientSet.CoreV1().Events(f.Namespace.Name).DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{
|
||||||
LabelSelector: label})
|
LabelSelector: label})
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return false, err
|
return false, err
|
||||||
} else {
|
} else {
|
||||||
return true, nil
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user