@@ -22,7 +22,7 @@ import (
22
22
"sync"
23
23
"time"
24
24
25
- gochache "github.com/patrickmn/go-cache"
25
+ gocache "github.com/patrickmn/go-cache"
26
26
corev1 "k8s.io/api/core/v1"
27
27
"k8s.io/apimachinery/pkg/api/resource"
28
28
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -82,9 +82,9 @@ type PodGroupManager struct {
82
82
// If podgroup's scheduleTimeoutSeconds is set, it will be used.
83
83
scheduleTimeout * time.Duration
84
84
// permittedPG stores the podgroup name which has passed the pre resource check.
85
- permittedPG * gochache .Cache
85
+ permittedPG * gocache .Cache
86
86
// backedOffPG stores the podgorup name which failed scheudling recently.
87
- backedOffPG * gochache .Cache
87
+ backedOffPG * gocache .Cache
88
88
// podLister is pod lister
89
89
podLister listerv1.PodLister
90
90
sync.RWMutex
@@ -97,8 +97,8 @@ func NewPodGroupManager(client client.Client, snapshotSharedLister framework.Sha
97
97
snapshotSharedLister : snapshotSharedLister ,
98
98
scheduleTimeout : scheduleTimeout ,
99
99
podLister : podInformer .Lister (),
100
- permittedPG : gochache .New (3 * time .Second , 3 * time .Second ),
101
- backedOffPG : gochache .New (10 * time .Second , 10 * time .Second ),
100
+ permittedPG : gocache .New (3 * time .Second , 3 * time .Second ),
101
+ backedOffPG : gocache .New (10 * time .Second , 10 * time .Second ),
102
102
}
103
103
return pgMgr
104
104
}
0 commit comments