Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for matchesFilter (0.07 sec)

  1. cni/pkg/repair/repaircontroller.go

    	m.With(resultLabel.Value(resultSuccess)).Increment()
    	return nil
    }
    
    // MatchesFilter returns true if the pod matches the repair filter criteria
    func (c *Controller) matchesFilter(pod *corev1.Pod) bool {
    	// Helper function; checks that a container's termination message matches filter
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. cni/pkg/repair/repair_test.go

    				InitContainerStatus: &corev1.ContainerStatus{},
    			}),
    			false,
    		},
    	}
    	for _, tt := range cases {
    		t.Run(tt.name, func(t *testing.T) {
    			c := &Controller{cfg: tt.config}
    			assert.Equal(t, c.matchesFilter(tt.pod), tt.want)
    		})
    	}
    }
    
    func fakeClient(pods ...*corev1.Pod) kube.Client {
    	var csPods []runtime.Object
    
    	for _, pod := range pods {
    		csPods = append(csPods, pod.DeepCopy())
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    				continue
    			}
    
    			prevObj = result.Item
    			matchedFilter = match
    			versionsCount = 1
    			// Include the latest version
    			if matchedFilter.Purge.RetainVersions == 0 {
    				toDel = append(toDel, expireObjInfo{
    					ObjectInfo: result.Item,
    					ExpireAll:  true,
    				})
    				continue
    			}
    		} else if prevObj.Name == result.Item.Name {
    			if matchedFilter.Purge.RetainVersions == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
Back to top