- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for setCondition (0.3 sec)
-
pkg/controller/podautoscaler/horizontal.go
if invalidMetricsCount >= len(metricSpecs) || (invalidMetricsCount > 0 && replicas < specReplicas) { setCondition(hpa, invalidMetricCondition.Type, invalidMetricCondition.Status, invalidMetricCondition.Reason, invalidMetricCondition.Message) return -1, "", statuses, time.Time{}, invalidMetricError }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
} if !podutil.UpdatePodCondition(&pod.Status, &condition) { t.Fatal("failed to update pod") } // TODO: workaround UpdatePodCondition calling time.Now() directly setCondition := podutil.GetPodReadyCondition(pod.Status) setCondition.LastTransitionTime.Time = dsc.failedPodsBackoff.Clock.Now() logger.Info("marked pod ready", "pod", pod.Name, "ready", ready) count-- } if count > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
cond: condReplicaFailure2(), expectedStatus: &apps.ReplicaSetStatus{Conditions: []apps.ReplicaSetCondition{condReplicaFailure2()}}, }, } for _, test := range tests { SetCondition(test.status, test.cond) if !reflect.DeepEqual(test.status, test.expectedStatus) { t.Errorf("%s: expected status: %v, got: %v", test.name, test.expectedStatus, test.status) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/apis/storagemigration/validation/validation.go
func isSuccessful(svm *storagemigration.StorageVersionMigration) bool { successCondition := getCondition(svm, storagemigration.MigrationSucceeded) if successCondition != nil && successCondition.Status == corev1.ConditionTrue { return true } return false } func isFailed(svm *storagemigration.StorageVersionMigration) bool { failedCondition := getCondition(svm, storagemigration.MigrationFailed)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 9.5K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conditions.go
// the status inverted error *ConfigError // setOnce, if enabled, will only set the condition if it is not yet present or set to this reason setOnce string } // setConditions sets the existingConditions with the new conditions func setConditions(generation int64, existingConditions []metav1.Condition, conditions map[string]*condition) []metav1.Condition { // Sort keys for deterministic ordering
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 13:05:41 UTC 2024 - 14.4K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils_test.go
} } } }() return client } func approved(csr *cert.CertificateSigningRequest) bool { return GetCondition(csr.Status.Conditions, cert.CertificateApproved).Status == corev1.ConditionTrue } func GetCondition(conditions []cert.CertificateSigningRequestCondition, condition cert.RequestConditionType) cert.CertificateSigningRequestCondition { for _, cond := range conditions {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 03:58:11 UTC 2024 - 13K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
check := func() error { gw, _ := client.Get(context.Background(), "managed-owner", metav1.GetOptions{}) if gw == nil { return fmt.Errorf("failed to find gateway") } cond := kstatus.GetCondition(gw.Status.Conditions, string(k8sv1.GatewayConditionProgrammed)) if cond.Status != metav1.ConditionTrue { return fmt.Errorf("failed to find programmed condition: %+v", cond) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.7K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
if gwc == nil { return fmt.Errorf("failed to find GatewayClass %v", constants.WaypointGatewayClassName) } cond := kstatus.GetCondition(gwc.Status.Conditions, string(k8s.GatewayClassConditionStatusAccepted)) if cond.Status != metav1.ConditionTrue { return fmt.Errorf("failed to find accepted condition: %+v", cond) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
t.Error("Missing .status.startTime") } // validate conditions if !getCondition(actual, tc.expectedCondition, v1.ConditionTrue, tc.expectedConditionReason) { t.Errorf("Expected fail condition. Got %#v", actual.Status.Conditions) } }) } } func getCondition(job *batch.Job, condition batch.JobConditionType, status v1.ConditionStatus, reason string) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
if cfg == nil { return fmt.Errorf("expected WorkloadEntry %s/%s to exist", proxy.Metadata.Namespace, name) } if cfg.Status == nil { return nil } s := cfg.Status.(*v1alpha1.IstioStatus) if status.GetCondition(s.Conditions, "Healthy") != nil { return fmt.Errorf("expected WorkloadEntry %s/%s not to have %q condition", proxy.Metadata.Namespace, name, "Healthy") } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0)