- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 395 for GetOptions (0.26 sec)
-
cmd/kubeadm/app/util/apiclient/clientbacked_dryrun.go
unstructuredObj, err := clg.dynamicClient.Resource(action.GetResource()).Namespace(action.GetNamespace()).Get(context.TODO(), action.GetName(), metav1.GetOptions{}) if err != nil { // Inform the user that the requested object wasn't found. printIfNotExists(err) return true, nil, err } newObj, err := decodeUnstructuredIntoAPIObject(action, unstructuredObj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 16 10:29:45 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/test/framework/components/istio/ca.go
} func FetchRootCert(c kubernetes.Interface) (string, error) { cm, err := c.CoreV1().ConfigMaps("istio-system").Get(context.TODO(), "istio-ca-root-cert", metav1.GetOptions{}) if err != nil { return "", err } return cm.Data["root-cert.pem"], nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.5K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/main/java/org/gradle/api/internal/tasks/testing/testng/TestNGTestFramework.java
// or preferably use test suites where the dependencies are automatically managed. return false; } @Override public TestNGOptions getOptions() { return options; } @Override public TestNGDetector getDetector() { return detector; } @Override public void close() throws IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 22:42:49 UTC 2024 - 5.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/configmaplock.go
var record LeaderElectionRecord var err error cml.cm, err = cml.Client.ConfigMaps(cml.ConfigMapMeta.Namespace).Get(ctx, cml.ConfigMapMeta.Name, metav1.GetOptions{}) if err != nil { return nil, nil, err } if cml.cm.Annotations == nil { cml.cm.Annotations = make(map[string]string) } recordStr, found := cml.cm.Annotations[LeaderElectionRecordAnnotationKey]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 4K bytes - Viewed (0) -
pkg/registry/networking/ingress/storage/storage.go
// we don't destroy it here explicitly. } // Get retrieves the object from the storage. It is required to support Patch. func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { return r.store.Get(ctx, name, options) } // Update alters the status subset of an object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 4.1K bytes - Viewed (0) -
pkg/registry/autoscaling/horizontalpodautoscaler/storage/storage_test.go
if err != nil { t.Fatalf("Unexpected error: %v", err) } obj, err := storage.Get(ctx, "foo", &metav1.GetOptions{}) if err != nil { t.Fatalf("Unexpected error: %v", err) } autoscalerOut := obj.(*autoscaling.HorizontalPodAutoscaler) // only compare the meaningful update b/c we can't compare due to metadata
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 6.4K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
client := exClient.Dynamic() gvr := schema.GroupVersionResource{ Group: "hub.gke.io", Version: "v1", Resource: "memberships", } u, err := client.Resource(gvr).Get(ctx, "membership", metav1.GetOptions{}) if err != nil { return nil, err } spec, ok := u.Object["spec"].(map[string]any) if !ok { return nil, errors.New(`field "spec" is not a map`) } var mem hubMembership
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 3.4K bytes - Viewed (0) -
tests/integration/telemetry/util.go
func GetTrustDomain(cluster cluster.Cluster, istioNamespace string) string { meshConfigMap, err := cluster.Kube().CoreV1().ConfigMaps(istioNamespace).Get(context.Background(), "istio", metav1.GetOptions{}) defaultTrustDomain := mesh.DefaultMeshConfig().TrustDomain if err != nil { return defaultTrustDomain } configYaml, ok := meshConfigMap.Data["mesh"] if !ok { return defaultTrustDomain }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 16:30:22 UTC 2022 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go
Delete(ctx context.Context, name string, opts v1.DeleteOptions) error DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta1.CustomResourceDefinition, error) List(ctx context.Context, opts v1.ListOptions) (*v1beta1.CustomResourceDefinitionList, error) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12.1K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
client := t.Clusters().Default().GatewayAPI().GatewayV1beta1().GatewayClasses() check := func() error { gwc, _ := client.Get(context.Background(), constants.WaypointGatewayClassName, metav1.GetOptions{}) if gwc == nil { return fmt.Errorf("failed to find GatewayClass %v", constants.WaypointGatewayClassName) } cond := kstatus.GetCondition(gwc.Status.Conditions, string(k8s.GatewayClassConditionStatusAccepted))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0)