- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for action1 (0.15 sec)
-
pkg/kubelet/kubelet_node_status_test.go
var savedNode *v1.Node t.Logf("actions: %v: %+v", len(actions), actions) action := actions[tc.savedNodeIndex] if action.GetVerb() == "create" { createAction := action.(core.CreateAction) obj := createAction.GetObject() require.IsType(t, &v1.Node{}, obj) savedNode = obj.(*v1.Node) } else if action.GetVerb() == "patch" { patchAction := action.(core.PatchActionImpl) var err error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
"cmd/internal/sys" ) const DefaultCFlags = "-O2 -g" // actionList returns the list of actions in the dag rooted at root // as visited in a depth-first post-order traversal. func actionList(root *Action) []*Action { seen := map[*Action]bool{} all := []*Action{} var walk func(*Action) walk = func(a *Action) { if seen[a] { return } seen[a] = true for _, a1 := range a.Deps { walk(a1) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
fakeClock.Step(time.Second) } for _, action := range test.actions { switch { case action.podPopped != nil: popPod(t, logger, q, action.podPopped) case action.eventHappens != nil: q.MoveAllToActiveOrBackoffQueue(logger, *action.eventHappens, nil, nil, nil) case action.podEnqueued != nil: err := q.AddUnschedulableIfNotPresent(logger, action.podEnqueued, q.SchedulingCycle()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
cmd/admin-handlers.go
} type serviceResult struct { Action madmin.ServiceAction `json:"action"` DryRun bool `json:"dryRun"` Results []servicePeerResult `json:"results,omitempty"` } // ServiceV2Handler - POST /minio/admin/v3/service?action={action}&type=2 // ---------- // Supports following actions: // - restart (restarts all the MinIO instances in a setup)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
state.SetRecordPluginMetrics(true) tests := []struct { name string action func(f framework.Framework) inject injectedResult wantExtensionPoint string wantStatus framework.Code }{ { name: "PreFilter - Success", action: func(f framework.Framework) { f.RunPreFilterPlugins(context.Background(), state, pod) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K 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/controller/job/job_controller_test.go
}, }, } onExitCodeRules := []batch.PodFailurePolicyRule{ { Action: batch.PodFailurePolicyActionIgnore, OnExitCodes: &batch.PodFailurePolicyOnExitCodesRequirement{ Operator: batch.PodFailurePolicyOnExitCodesOpIn, Values: []int32{1, 2, 3}, }, }, { Action: batch.PodFailurePolicyActionFailJob, OnExitCodes: &batch.PodFailurePolicyOnExitCodesRequirement{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
var savedNode *v1.Node if test.isPatchingNeeded { actions := kubeClient.Actions() if len(actions) == 0 { t.Logf("No action yet") return false, nil } for _, action := range actions { if action.GetVerb() == "patch" { var ( err error patchAction = action.(core.PatchActionImpl) patchContent = patchAction.GetPatch()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/config/validation/validation.go
} } } if in.GetProvider() != nil && in.Action != security_beta.AuthorizationPolicy_CUSTOM { errs = appendErrors(errs, fmt.Errorf("`provider` must not be with non CUSTOM action, found %s", in.Action)) } if in.Action == security_beta.AuthorizationPolicy_DENY && in.Rules == nil { errs = appendErrors(errs, fmt.Errorf("DENY action without `rules` is meaningless as it will never be triggered, "+
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
cmd/object-handlers.go
return } event := evalActionFromLifecycle(ctx, *lc, rcfg, replcfg, objInfo) if event.Action.Delete() { // apply whatever the expiry rule is. applyExpiryRule(event, lcEventSrc_s3GetObject, objInfo) if !event.Action.DeleteRestored() { // If the ILM action is not on restored object return error. writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrNoSuchKey), r.URL) return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0)