- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 345 for GetOptions (0.18 sec)
-
pkg/registry/policy/poddisruptionbudget/storage/storage_test.go
if err := storage.Storage.Create(ctx, key, validPodDisruptionBudget, nil, 0, false); err != nil { t.Fatalf("unexpected error: %v", err) } obj, err := storage.Get(ctx, "foo", &metav1.GetOptions{}) if err != nil { t.Fatalf("failed to get pdb: %v", err) } obtainedPdb := obj.(*policy.PodDisruptionBudget) minAvailable := intstr.FromInt32(8) update := policy.PodDisruptionBudget{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:45 UTC 2023 - 5.3K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/external/javadoc/internal/JavadocOptionFileWriter.java
@Override protected void doExecute(BufferedWriter writer) throws Exception { final Map<String, JavadocOptionFileOption<?>> options = new TreeMap<String, JavadocOptionFileOption<?>>(optionFile.getOptions()); JavadocOptionFileWriterContext writerContext = new JavadocOptionFileWriterContext(writer); JavadocOptionFileOption<?> localeOption = options.remove("locale");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 2.1K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/serializer/SelectOptionPromptEventSerializer.java
encoder.writeLong(value.getTimestamp()); encoder.writeString(value.getQuestion()); optionsSerializer.write(encoder, value.getOptions()); encoder.writeSmallInt(value.getDefaultOption()); } @Override public SelectOptionPromptEvent read(Decoder decoder) throws Exception {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 05:02:18 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/registry/core/componentstatus/rest_test.go
} } func TestGet_NoError(t *testing.T) { r := NewTestREST(testResponse{result: probe.Success, data: "ok"}) got, err := r.Get(genericapirequest.NewContext(), "test1", &metav1.GetOptions{}) if err != nil { t.Fatalf("Unexpected error: %v", err) } expect := createTestStatus("test1", api.ConditionTrue, "ok", "") if e, a := expect, got; !reflect.DeepEqual(e, a) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 13 08:10:29 UTC 2023 - 5.3K bytes - Viewed (0) -
pkg/registry/apps/deployment/storage/storage_test.go
}, Status: autoscaling.ScaleStatus{ Replicas: validDeployment.Status.Replicas, Selector: selector.String(), }, } obj, err := storage.Scale.Get(ctx, name, &metav1.GetOptions{}) if err != nil { t.Fatalf("error fetching scale for %s: %v", name, err) } got := obj.(*autoscaling.Scale) if !apiequality.Semantic.DeepEqual(want, got) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:45 UTC 2023 - 19.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 12 17:35:34 UTC 2024 - 33.2K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
Get(context.Background(), "managed-owner-istio", metav1.GetOptions{}) assert.NoError(t, err) assert.Equal(t, dep.Labels[constants.ManagedGatewayLabel], "") assert.Equal(t, dep.Spec.Template.Spec.Containers[0].Image, image) svc, err := t.Clusters().Default().Kube().CoreV1().Services(apps.Namespace.Name()). Get(context.Background(), "managed-owner-istio", metav1.GetOptions{}) assert.NoError(t, err)
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/jvm/language-java/src/main/java/org/gradle/api/tasks/compile/JavaCompile.java
} private void validateForkOptionsMatchToolchain() { if (!getOptions().isFork()) { return; } JavaCompiler javaCompilerTool = getJavaCompiler().get(); File toolchainJavaHome = javaCompilerTool.getMetadata().getInstallationPath().getAsFile(); ForkOptions forkOptions = getOptions().getForkOptions(); File customJavaHome = forkOptions.getJavaHome();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:33:35 UTC 2024 - 15.3K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
} return client.Kube().CoreV1().Secrets(secretNamespace).Get(context.TODO(), secretName, metav1.GetOptions{}) } func getOrCreateServiceAccount(client kube.CLIClient, opt RemoteSecretOptions) (*v1.ServiceAccount, error) { if sa, err := client.Kube().CoreV1().ServiceAccounts(opt.Namespace).Get( context.TODO(), opt.ServiceAccountName, metav1.GetOptions{}); err == nil { return sa, nil } else if !opt.CreateServiceAccount {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 11 01:43:17 UTC 2023 - 24K bytes - Viewed (0) -
tests/integration/pilot/mcs/autoexport/autoexport_test.go
retry.UntilSuccessOrFail(ctx, func() error { serviceExport, err := cluster.Dynamic().Resource(serviceExportGVR).Namespace(echos.Namespace.Name()).Get( context.TODO(), common.ServiceB, metav1.GetOptions{}) if err != nil { return err } if serviceExport == nil { return fmt.Errorf("serviceexport %s/%s not found in cluster %s",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.9K bytes - Viewed (0)