- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for PodUpdate (0.3 sec)
-
pkg/scheduler/internal/queue/events.go
// ForceActivate is the event when a pod is moved from unschedulablePods/backoffQ // to activeQ. Usually it's triggered by plugin implementations. ForceActivate = "ForceActivate" // PodUpdate is the event when a pod is updated PodUpdate = "PodUpdate" ) var ( // AssignedPodAdd is the event when a pod is added that causes pods with matching affinity terms // to be more schedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kubelet/config/file_test.go
ch := make(chan interface{}, 1) lw := newSourceFile(dirName, "localhost", time.Millisecond, ch) err = lw.listConfig() if err != nil { t.Fatalf("unexpected error: %v", err) } update, ok := (<-ch).(kubetypes.PodUpdate) if !ok { t.Fatalf("unexpected type: %#v", update) } expected := CreatePodUpdate(kubetypes.SET, kubetypes.FileSource) if !apiequality.Semantic.DeepEqual(expected, update) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 2.1K bytes - Viewed (0) -
pkg/kubelet/types/pod_update.go
// AllSource identifies updates from all sources. AllSource = "*" ) // NamespaceDefault is a string representing the default namespace. const NamespaceDefault = metav1.NamespaceDefault // PodUpdate defines an operation sent on the channel. You can add or remove single services by // sending an array of size one and Op == ADD|REMOVE (with REMOVE, only the ID is required).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/kubelet/config/file_linux.go
_, err := os.Stat(s.path) if err != nil { if !os.IsNotExist(err) { return err } // Emit an update with an empty PodList to allow FileSource to be marked as seen s.updates <- kubetypes.PodUpdate{Pods: []*v1.Pod{}, Op: kubetypes.SET, Source: kubetypes.FileSource} return &retryableError{"path does not exist, ignoring"} } w, err := fsnotify.NewWatcher() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 17:27:26 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/kubelet/runonce.go
type RunPodResult struct { Pod *v1.Pod Err error } // RunOnce polls from one configuration update and run the associated pods. func (kl *Kubelet) RunOnce(updates <-chan kubetypes.PodUpdate) ([]RunPodResult, error) { ctx := context.Background() // Setup filesystem directories. if err := kl.setupDataDirs(); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0)