Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for isCreate (0.17 sec)

  1. cmd/iam-etcd-store.go

    						isCreateEvent := event.IsModify() || event.IsCreate()
    						isDeleteEvent := event.Type == etcd.EventTypeDelete
    
    						switch {
    						case isCreateEvent:
    							ch <- iamWatchEvent{
    								isCreated: true,
    								keyPath:   string(event.Kv.Key),
    							}
    						case isDeleteEvent:
    							ch <- iamWatchEvent{
    								isCreated: false,
    								keyPath:   string(event.Kv.Key),
    							}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. subprojects/core/src/main/java/org/gradle/internal/build/AbstractBuildState.java

            BuildProjectRegistry projectsForThisBuild = getProjectStateRegistry().findProjectsFor(getBuildIdentifier());
            return projectsForThisBuild != null && projectsForThisBuild.getRootProject().isCreated();
        }
    
        @Override
        public void ensureProjectsConfigured() {
            getBuildController().configureProjects();
        }
    
        @Override
        public GradleInternal getMutableModel() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 22 23:08:20 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set_control.go

    }
    
    func computeReplicaStatus(pods []*v1.Pod, minReadySeconds int32, currentRevision, updateRevision *apps.ControllerRevision) replicaStatus {
    	status := replicaStatus{}
    	for _, pod := range pods {
    		if isCreated(pod) {
    			status.replicas++
    		}
    
    		// count the number of running and ready replicas
    		if isRunningAndReady(pod) {
    			status.readyReplicas++
    			// count the number of running and available replicas
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  4. pkg/controller/statefulset/stateful_set_utils.go

    }
    
    func isRunningAndAvailable(pod *v1.Pod, minReadySeconds int32) bool {
    	return podutil.IsPodAvailable(pod, minReadySeconds, metav1.Now())
    }
    
    // isCreated returns true if pod has been created and is maintained by the API server
    func isCreated(pod *v1.Pod) bool {
    	return pod.Status.Phase != ""
    }
    
    // isPending returns true if pod has a Phase of PodPending
    func isPending(pod *v1.Pod) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  5. cmd/iam-store.go

    		d.Policy = doc.Policy
    		return nil
    	}
    	*d = doc
    	return nil
    }
    
    // key options
    type options struct {
    	ttl int64 // expiry in seconds
    }
    
    type iamWatchEvent struct {
    	isCreated bool // !isCreated implies a delete event.
    	keyPath   string
    }
    
    // iamCache contains in-memory cache of IAM data.
    type iamCache struct {
    	updatedAt time.Time
    
    	// map of policy names to policy definitions
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  6. pkg/controller/statefulset/stateful_set_control_test.go

    		t.Error(err)
    	}
    	recreatedPod := findPodByOrdinal(pods, terminalPodOrdinal)
    	// new recreated pod should have empty phase
    	if recreatedPod == nil || isCreated(recreatedPod) {
    		t.Error("StatefulSet did not recreate failed Pod")
    	}
    	expectedNumberOfCreateRequests := 2
    	if monotonic := !allowsBurst(set); !monotonic {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
Back to top