- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,123 for Relist (0.1 sec)
-
pkg/kubelet/pleg/generic_test.go
}, }}, } // Relist and drain the events from the channel. for i := 0; i < numRelists; i++ { pleg.Relist() getEventsFromChannel(ch) } // Container c2 was stopped and removed between relists. We should report // the event. runtime.AllPodList = []*containertest.FakePod{} pleg.Relist() expected := []*PodLifecycleEvent{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 24.8K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
// error occurs during the inspection, we want PLEG to retry again // in the next relist. To achieve this, we do not update the // associated podRecord of the pod, so that the change will be // detect again in the next relist. // TODO: If many pods changed during the same relist period, // inspecting the pod and getting the PodStatus to update the cache
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
func (e *EventedPLEG) Watch() chan *PodLifecycleEvent { return e.eventChannel } // Relist relists all containers using GenericPLEG func (e *EventedPLEG) Relist() { e.genericPleg.Relist() } // Start starts the Evented PLEG func (e *EventedPLEG) Start() { e.runningMu.Lock() defer e.runningMu.Unlock() if isEventedPLEGInUse() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
tests/integration/pilot/revisions/uninstall_test.go
usList, _ := cs.Dynamic().Resource(gvr).List(context.TODO(), metav1.ListOptions{LabelSelector: ls}) var remainingResources []unstructured.Unstructured var staleList []string if usList != nil && len(usList.Items) != 0 { for _, item := range usList.Items { // ignore IstioOperator CRD because the operator CR is not in the pruning list if item.GetName() == "istiooperators.install.istio.io" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/kubelet/pleg/pleg.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 26 16:14:26 UTC 2023 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/continue.go
ResourceVersion int64 `json:"rv"` StartKey string `json:"start"` } // DecodeContinue transforms an encoded predicate from into a versioned struct. // TODO: return a typed error that instructs clients that they must relist func DecodeContinue(continueValue, keyPrefix string) (fromKey string, rv int64, err error) { data, err := base64.RawURLEncoding.DecodeString(continueValue) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 17:30:02 UTC 2022 - 3.5K bytes - Viewed (0) -
pkg/scheduler/internal/cache/interface.go
// Cache's operations are pod centric. It does incremental updates based on pod events. // Pod events are sent via network. We don't have guaranteed delivery of all events: // We use Reflector to list and watch from remote. // Reflector might be slow and do a relist, which would lead to missing events. // // State Machine of a pod's events in scheduler's cache: // // +-------------------------------------------+ +----+
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_utils.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:51 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
if err != nil { return err } if scalingEvent { return dc.sync(ctx, d, rsList) } switch d.Spec.Strategy.Type { case apps.RecreateDeploymentStrategyType: return dc.rolloutRecreate(ctx, d, rsList, podMap) case apps.RollingUpdateDeploymentStrategyType: return dc.rolloutRolling(ctx, d, rsList) } return fmt.Errorf("unexpected deployment strategy type: %s", d.Spec.Strategy.Type)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
ResourceVersion: rv, } w.eventHandler(wcEvent) } metrics.RecordResourceVersion(w.groupResource.String(), rv) } // List returns list of pointers to <storeElement> objects. func (w *watchCache) List() []interface{} { return w.store.List() } // waitUntilFreshAndBlock waits until cache is at least as fresh as given <resourceVersion>. // NOTE: This function acquired lock and doesn't release it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0)