- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for setCondition (0.17 sec)
-
pilot/pkg/model/kstatus/helper_test.go
}, }, condition: "", want: metav1.Condition{}, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if got := GetCondition(tt.conditions, tt.condition); !reflect.DeepEqual(got, tt.want) { t.Errorf("GetCondition got %v, want %v", got, tt.want) } }) } } func TestCreateCondition(t *testing.T) { transitionTime := metav1.Now() tests := []struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 18:11:40 UTC 2023 - 9K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/util.go
// condition. func HasHealthCondition(wle *config.Config) bool { if wle == nil { return false } s, ok := wle.Status.(*v1alpha1.IstioStatus) if !ok { return false } return status.GetCondition(s.Conditions, status.ConditionHealthy) != nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 11 07:04:17 UTC 2023 - 1.7K 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) -
pilot/pkg/autoregistration/internal/state/store.go
if !s.cb.IsControllerOf(cfg) { return nil } // check if the existing health status is newer than this one wleStatus, ok := cfg.Status.(*v1alpha1.IstioStatus) if ok { healthCondition := status.GetCondition(wleStatus.Conditions, status.ConditionHealthy) if healthCondition != nil { if healthCondition.LastProbeTime.AsTime().After(condition.LastProbeTime.AsTime()) { return nil } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.3K bytes - Viewed (0) -
pilot/pkg/model/kstatus/helper.go
if !reflect.DeepEqual(old, w.Status) { w.Dirty = true } } func (w *WrappedStatus) Unwrap() config.Status { return w.Status } var EmptyCondition = metav1.Condition{} func GetCondition(conditions []metav1.Condition, condition string) metav1.Condition { for _, cond := range conditions { if cond.Type == condition { return cond } } return EmptyCondition }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 3.7K 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) -
platforms/native/platform-native/src/testFixtures/groovy/org/gradle/ide/visualstudio/fixtures/ProjectFile.groovy
} private Node getConfiguration() { projectXml.PropertyGroup.find({ it.'@Label' == 'Configuration' && it.'@Condition' == condition}) as Node } private String getCondition() { "'\$(Configuration)|\$(Platform)'=='${name}|${platformName}'" } } void assertHasComponentSources(TestNativeComponent component, String basePath) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 5.7K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
return fmt.Sprintf("container failed to start: %v: %v", cs.State.Waiting.Reason, cs.State.Waiting.Message) } } if c := getCondition(pod.Status.Conditions, corev1.PodReady); c != nil && c.Status == corev1.ConditionFalse { return fmt.Sprintf(c.Message) } } return "" } func getCondition(conditions []corev1.PodCondition, condition corev1.PodConditionType) *corev1.PodCondition { for _, cond := range conditions {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/converter_gen.cc
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Dec 19 15:05:28 UTC 2023 - 23.7K bytes - Viewed (0)