Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 126 for updatepan (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top