- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 126 for updatepan (0.36 sec)
-
pkg/kubelet/pod/pod_manager.go
// SetPods replaces the internal pods with the new pods. // It is currently only used for testing. SetPods(pods []*v1.Pod) // AddPod adds the given pod to the manager. AddPod(pod *v1.Pod) // UpdatePod updates the given pod in the manager. UpdatePod(pod *v1.Pod) // RemovePod deletes the given pod from the manager. For mirror pods, // this means deleting the mappings related to mirror pods. For non-
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
schema/model_test.go
DeletedAt *mytime Active mybool Admin *mybool } type BaseModel struct { ID uint CreatedAt time.Time CreatedBy *int Created *VersionUser `gorm:"foreignKey:CreatedBy"` UpdatedAt time.Time DeletedAt gorm.DeletedAt `gorm:"index"` } type VersionModel struct { BaseModel Version int } type VersionUser struct { VersionModel Name string Age uint
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Thu Jan 06 07:02:53 UTC 2022 - 1.1K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/PluginTests.java
return requestBody; } @Override protected Map<String, Object> getUpdateMap() { final Map<String, Object> updateMap = new HashMap<>(); return updateMap; } @AfterEach protected void tearDown() { // do nothing } protected String getInstalledEndpointSuffix() { return INSTALLED_ENDPOINT_SUFFIX;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6K bytes - Viewed (0) -
association.go
} for _, ref := range rel.References { updateMap[ref.ForeignKey.DBName] = nil } association.Error = association.DB.UpdateColumns(updateMap).Error } if association.Unscope && oldBelongsToExpr != nil {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
prev := *pod1 fakeResourceVersion(pod1) ssc.updatePod(logger, &prev, pod1) key, done := ssc.queue.Get() if key == "" || done { t.Error("failed to enqueue StatefulSet") } else if expectedKey, _ := controller.KeyFunc(set1); expectedKey != key { t.Errorf("expected StatefulSet key %s found %s", expectedKey, key) } prev = *pod2 fakeResourceVersion(pod2) ssc.updatePod(logger, &prev, pod2) key, done = ssc.queue.Get()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pkg/scheduler/internal/cache/interface.go
// If added back, the pod's information would be added again. AddPod(logger klog.Logger, pod *v1.Pod) error // UpdatePod removes oldPod's information and adds newPod's information. UpdatePod(logger klog.Logger, oldPod, newPod *v1.Pod) error // RemovePod removes a pod. The pod's information would be subtracted from assigned node. RemovePod(logger klog.Logger, pod *v1.Pod) error
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/kubelet/pod_workers.go
// will be called until it exits successfully, and after that all further // UpdatePod() calls will be ignored for that pod until it has been forgotten // due to significant time passing. A pod that is terminated will never be // restarted. UpdatePod(options UpdatePodOptions) // SyncKnownPods removes workers for pods that are not in the desiredPods set
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers.go
return } // Check if bucket exists. if _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } config, updatedAt, err := globalBucketMetadataSys.GetLifecycleConfig(bucket) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
if err := cache.UpdatePod(logger, tc.pod, tc.podToUpdate); err == nil { t.Error("expected error, no error found") } if err := tc.handler(logger, cache, tc.pod); err != nil { t.Fatalf("unexpected err: %v", err) } if !tc.assumePod { if err := cache.UpdatePod(logger, tc.pod, tc.podToUpdate); err != nil { t.Fatalf("UpdatePod failed: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0) -
tests/serializer_test.go
createdAt := time.Date(2020, 1, 1, 0, 0, 0, 0, time.UTC) updatedAt := createdAt.Unix() data := SerializerStruct{ Name: []byte("jinzhu"), Roles: []string{"r1", "r2"}, Contracts: map[string]interface{}{"name": "jinzhu", "age": 10}, EncryptedString: EncryptedString("pass"), CreatedTime: createdAt.Unix(), UpdatedTime: &updatedAt, JobInfo: Job{ Title: "programmer",
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Fri Apr 21 14:09:38 UTC 2023 - 7.6K bytes - Viewed (0)