- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 81 for asError (0.15 sec)
-
pkg/scheduler/framework/plugins/podtopologyspread/scoring_test.go
p := pl.(*PodTopologySpread) cs := framework.NewCycleState() if s := p.PreScore(ctx, cs, tt.pod, tf.BuildNodeInfos(tt.nodes)); !s.IsSkip() { t.Fatalf("Expected skip but got %v", s.AsError()) } }) } } func TestPreScoreStateEmptyNodes(t *testing.T) { tests := []struct { name string pod *v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 60K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
} sched.FailureHandler = func(_ context.Context, fwk framework.Framework, p *framework.QueuedPodInfo, status *framework.Status, _ *framework.NominatingInfo, _ time.Time) { gotPod = p.Pod gotError = status.AsError() msg := truncateMessage(gotError.Error()) fwk.EventRecorder().Eventf(p.Pod, nil, v1.EventTypeWarning, "FailedScheduling", "Scheduling", msg) } called := make(chan struct{})
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/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
} res, status := pe.Preempt(ctx, test.pod, nodeToStatusMap) if !status.IsSuccess() && !status.IsRejected() { t.Errorf("unexpected error in preemption: %v", status.AsError()) } if diff := cmp.Diff(test.want, res); diff != "" { t.Errorf("Unexpected status (-want, +got):\n%s", diff) } if len(deletedPodNames) != len(test.expectedPods) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
if s.IsSuccess() { continue } pInfo.UnschedulablePlugins.Insert(pl.Name()) metrics.UnschedulableReason(pl.Name(), pod.Spec.SchedulerName).Inc() if s.Code() == framework.Error { logger.Error(s.AsError(), "Unexpected error running PreEnqueue plugin", "pod", klog.KObj(pod), "plugin", pl.Name()) } else { logger.V(4).Info("Status after running PreEnqueue plugin", "pod", klog.KObj(pod), "plugin", pl.Name(), "status", s) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
src/text/template/parse/parse_test.go
{"undefined variable", "{{$x}}", hasError, ""}, {"variable undefined after end", "{{with $x := 4}}{{end}}{{$x}}", hasError, ""}, {"variable undefined in template", "{{template $v}}", hasError, ""}, {"declare with field", "{{with $x.Y := 4}}{{end}}", hasError, ""}, {"template with field ref", "{{template .X}}", hasError, ""}, {"template with var", "{{template $v}}", hasError, ""},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Feb 24 21:59:12 UTC 2024 - 24K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexResponse.java
hasError = false; } else { hasError = true; errors.forEach(this.errors::add); } } public int getNumberOfSuggestDocs() { return numberOfSuggestDocs; } public int getNumberOfInputDocs() { return numberOfInputDocs; } public boolean hasError() { return hasError; }
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync_test.go
t.Errorf("%v, %v; fake.events = %#v, want %#v", tc.desc, tc.mode, tc.fake.events, tc.events) } var hasError bool for _, r := range tc.fake.results { hasError = hasError || (r != nil) } if hasError != tc.wantError { t.Errorf("%v, %v; hasError = %t, errors = %v, want %t", tc.desc, tc.mode, hasError, tc.fake.events, tc.wantError) } } } func TestNodeSyncResync(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3_test.go
) func Test_atomicLastError(t *testing.T) { aError := &atomicLastError{err: fmt.Errorf("initial error")} // no timestamp is always updated aError.Store(errors.New("updated error"), time.Time{}) err := aError.Load() if err.Error() != "updated error" { t.Fatalf("Expected: \"updated error\" got: %s", err.Error()) } // update to current time now := time.Now() aError.Store(errors.New("now error"), now) err = aError.Load()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 29 15:58:10 UTC 2022 - 1.4K bytes - Viewed (0) -
src/internal/oserror/errors.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Package oserror defines errors values used in the os package. // // These types are defined here to permit the syscall package to reference them. package oserror import "errors" var ( ErrInvalid = errors.New("invalid argument") ErrPermission = errors.New("permission denied")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 02 17:57:18 UTC 2019 - 601 bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-core/src/test/kotlin/org/gradle/internal/declarativedsl/analysis/LambdaTest.kt
schema.resolve("lambdaNotAllowed(0) { }").isError(ErrorReason.UnresolvedFunctionCallSignature::class) } private fun ResolutionResult.isSuccessful() { assertTrue { errors.isEmpty() } assertTrue { additions.size == 1 } } private fun ResolutionResult.isError(errorReason: KClass<out ErrorReason>) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 26 12:27:49 UTC 2024 - 2.6K bytes - Viewed (0)