- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 395 for GetOptions (0.22 sec)
-
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) -
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/controller/nodelifecycle/node_lifecycle_controller_test.go
node0, err := fakeNodeHandler.Get(ctx, "node0", metav1.GetOptions{}) if err != nil { t.Errorf("Can't get current node0...") return } if !taintutils.TaintExists(node0.Spec.Taints, UnreachableTaintTemplate) { t.Errorf("Can't find taint %v in %v", originalTaint, node0.Spec.Taints) } node2, err := fakeNodeHandler.Get(ctx, "node2", metav1.GetOptions{}) if err != nil { t.Errorf("Can't get current node2...")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K 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) -
pkg/istio-agent/xds_proxy_test.go
}) }) } type fakeAckCache struct{} func (f *fakeAckCache) Get(string, wasmcache.GetOptions) (string, error) { return "test", nil } func (f *fakeAckCache) Cleanup() {} type fakeNackCache struct{} func (f *fakeNackCache) Get(string, wasmcache.GetOptions) (string, error) { return "", errors.New("error") } func (f *fakeNackCache) Cleanup() {}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 18.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go
} func (ic *serviceImportCacheImpl) updateKubeService(t *testing.T) { t.Helper() svc, _ := ic.client.Kube().CoreV1().Services(serviceImportNamespace).Get(context.TODO(), serviceImportName, metav1.GetOptions{}) if svc == nil { t.Fatalf("failed to find k8s service: %s/%s", serviceImportNamespace, serviceImportName) } // Just add a new label. svc.Labels = map[string]string{ "foo": "bar", }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 15.2K 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) -
cmd/kubeadm/app/discovery/file/file.go
true, func(_ context.Context) (bool, error) { clusterinfoCM, lastError = client.CoreV1().ConfigMaps(metav1.NamespacePublic).Get(context.TODO(), bootstrapapi.ConfigMapClusterInfo, metav1.GetOptions{}) if lastError != nil { if apierrors.IsForbidden(lastError) { // If the request is unauthorized, the cluster admin has not granted access to the cluster info configmap for unauthenticated users
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:55 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_utils.go
if i >= statusUpdateRetries { break } // Update the ReplicaSet with the latest resource version for the next poll if rs, getErr = c.Get(context.TODO(), rs.Name, metav1.GetOptions{}); getErr != nil { // If the GET fails we can't trust status.Replicas anymore. This error // is bound to be more interesting than the update failure. return nil, getErr } } return nil, updateErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:51 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/volume/flexvolume/driver-call.go
volSourceFSType, err := getFSType(spec) if err != nil { return nil, err } readOnly, err := getReadOnly(spec) if err != nil { return nil, err } volSourceOptions, err := getOptions(spec) if err != nil { return nil, err } options := map[string]string{} options[optionFSType] = volSourceFSType if readOnly { options[optionReadWrite] = "ro" } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 25 02:39:55 UTC 2021 - 7.5K bytes - Viewed (0)