- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 141 for GetOptions (0.18 sec)
-
cmd/kubeadm/app/util/apiclient/wait.go
constants.KubernetesAPICallRetryInterval, w.timeout, true, func(_ context.Context) (bool, error) { _, err := w.client.CoreV1().Pods(metav1.NamespaceSystem).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil && apierrors.IsNotFound(err) { fmt.Printf("[apiclient] The old Pod %q is now removed (which is desired)\n", podName) return true, nil } return false, nil }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/storage_test.go
// When more test cases are added, this getter will need extending/replacing to have a real test implementation. type panicGetter struct{} func (f panicGetter) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { panic("not implemented") } var _ rest.Getter = panicGetter{} func validNewServiceAccount(name string) *api.ServiceAccount { return &api.ServiceAccount{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
if err != nil { return nil, err } pod := pods[0] svc, err := cls.Kube().CoreV1().Services(cfg.TelemetryNamespace).Get(context.TODO(), serviceName, metav1.GetOptions{}) if err != nil { return nil, err } port := uint16(svc.Spec.Ports[0].Port) forwarder, err := cls.NewPortForwarder(pod.Name, pod.Namespace, "", 0, int(port)) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleJavadocsPlugin.java
.withPropertyName("stylesheetFile") .withPathSensitivity(PathSensitivity.NAME_ONLY); StandardJavadocDocletOptions options = (StandardJavadocDocletOptions) task.getOptions(); options.setEncoding("utf-8"); options.setDocEncoding("utf-8"); options.setCharSet("utf-8"); options.addBooleanOption("-allow-script-in-comments", true);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 04:10:18 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go
if err != nil { t.Fatalf("Expected no error, but got: %v", err) } plGot, err := client.Get(context.TODO(), test.bootstrap.Name, metav1.GetOptions{}) switch { case test.expected == nil: if !apierrors.IsNotFound(err) { t.Fatalf("Expected GET to return an %q error, but got: %v", metav1.StatusReasonNotFound, err) } case err != nil:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 19.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/fake_example.go
// Get takes name of the example, and returns the corresponding example object, and an error if there is any. func (c *FakeExamples) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.Example, err error) { emptyResult := &v1.Example{} obj, err := c.Fake. Invokes(testing.NewGetAction(examplesResource, c.ns, name), emptyResult) if obj == nil { return emptyResult, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { out := &example.Pod{} // reset // verify that kv pair is empty before set key := computePodKey(tt.inputObj) if err := store.Get(ctx, key, storage.GetOptions{}, out); !storage.IsNotFound(err) { t.Fatalf("expecting empty result on key %s, got %v", key, err) } err := store.Create(ctx, key, tt.inputObj, out, 0) if !errors.Is(err, tt.expectedError) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
platforms/extensibility/plugin-development/src/integTest/groovy/org/gradle/plugin/devel/tasks/RuntimePluginValidationIntegrationTest.groovy
public abstract class MyTask extends DefaultTask { @Inject protected abstract ObjectFactory getObjects(); @Nested public Options getOptions() { return new Options(); } @Nested public List<Options> getOptionsList() { return Arrays.asList(new Options());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 14:30:05 UTC 2024 - 11.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/fake/fake_customresourcedefinition.go
// Get takes name of the customResourceDefinition, and returns the corresponding customResourceDefinition object, and an error if there is any. func (c *FakeCustomResourceDefinitions) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.CustomResourceDefinition, err error) { emptyResult := &v1beta1.CustomResourceDefinition{} obj, err := c.Fake. Invokes(testing.NewRootGetAction(customresourcedefinitionsResource, name), emptyResult)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/dns/dns.go
func GetCoreDNSInfo(client clientset.Interface) (*v1.ConfigMap, string, string, error) { coreDNSConfigMap, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get(context.TODO(), kubeadmconstants.CoreDNSConfigMap, metav1.GetOptions{}) if err != nil { if apierrors.IsNotFound(err) { return nil, "", "", nil } return nil, "", "", err } corefile, ok := coreDNSConfigMap.Data["Corefile"] if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 16.1K bytes - Viewed (0)