- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 72 for GetSubresource (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go
if err == nil { actions := "" for _, action := range mockClient.Actions() { actions = actions + action.GetVerb() + ":" + action.GetResource().Resource + ":" + action.GetSubresource() + ", " } t.Errorf("expected error returned from admission handler: %v", actions) } // verify create operations in the namespace cause an error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
assert.NoError(t, kubelet.updateNodeStatus(ctx)) actions := kubeClient.Actions() require.Len(t, actions, 2) require.True(t, actions[1].Matches("patch", "nodes")) require.Equal(t, actions[1].GetSubresource(), "status") updatedNode, err := applyNodeStatusPatch(&existingNode, actions[1].(core.PatchActionImpl).GetPatch()) assert.NoError(t, err) for i, cond := range updatedNode.Status.Conditions {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/rbac_test.go
func (d *defaultAttributes) GetNamespace() string { return d.namespace } func (d *defaultAttributes) GetResource() string { return d.resource } func (d *defaultAttributes) GetSubresource() string { return d.subresource } func (d *defaultAttributes) GetName() string { return "" } func (d *defaultAttributes) GetAPIGroup() string { return d.apiGroup }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 24 15:14:54 UTC 2019 - 21.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
attribute.String("configuration", configurationName), attribute.String("webhook", h.Name), attribute.Stringer("resource", attr.GetResource()), attribute.String("subresource", attr.GetSubresource()), attribute.String("operation", string(attr.GetOperation())), attribute.String("UID", string(uid))) defer span.End(500 * time.Millisecond)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
if err != nil { t.Fatal(err) } var updated *apps.DaemonSet clientset.PrependReactor("update", "daemonsets", func(action core.Action) (handled bool, ret runtime.Object, err error) { if action.GetSubresource() != "status" { return false, nil, nil } if u, ok := action.(core.UpdateAction); ok { updated = u.GetObject().(*apps.DaemonSet) } return false, nil, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission.go
// Also ignores any call that has a subresource defined. func (d *DefaultLimitRangerActions) SupportsAttributes(a admission.Attributes) bool { if a.GetSubresource() != "" { return false } // Since containers and initContainers cannot currently be added, removed, or updated, it is unnecessary
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 13:04:39 UTC 2023 - 25.8K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
var wg sync.WaitGroup wg.Add(2 * len(pods)) bindings := make(map[string]string) client.PrependReactor("create", "pods", func(action clienttesting.Action) (bool, runtime.Object, error) { if action.GetSubresource() != "binding" { return false, nil, nil } binding := action.(clienttesting.CreateAction).GetObject().(*v1.Binding) bindings[binding.Name] = binding.Target.Name wg.Done() return true, binding, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
} for i := 0; i < len(actions); i++ { e := expectedActions[i] a := actions[i] if !a.Matches(e.GetVerb(), e.GetResource().Resource) || a.GetSubresource() != e.GetSubresource() { t.Errorf("unexpected actions: %s", cmp.Diff(expectedActions, actions)) } } } func verifyUpdates(t *testing.T, manager *manager, expectedUpdates int) { t.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller_test.go
} actionSet := sets.NewString() for _, action := range kubeClient.Actions() { actionSet.Insert(strings.Join([]string{action.GetVerb(), action.GetResource().Resource, action.GetSubresource()}, "-")) } if !actionSet.IsSuperset(testCase.expectedActionSet) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K bytes - Viewed (0)