- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 608 for perror (0.14 sec)
-
pkg/volume/flexvolume/plugin.go
return &flexVolumeAttacher{plugin}, nil } func (plugin *flexVolumeAttachablePlugin) NewDeviceMounter() (volume.DeviceMounter, error) { return plugin.NewAttacher() } // NewDetacher is part of the volume.AttachableVolumePlugin interface. func (plugin *flexVolumeAttachablePlugin) NewDetacher() (volume.Detacher, error) { return &flexVolumeDetacher{plugin}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/util/coverage/fake_test_deps.go
return nil } //nolint:unused // U1000 see comment above, we know it's unused normally. func (fakeTestDeps) RunFuzzWorker(func(corpusEntry) error) error { return nil } //nolint:unused // U1000 see comment above, we know it's unused normally. func (fakeTestDeps) ReadCorpus(string, []reflect.Type) ([]corpusEntry, error) { return nil, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 15:31:22 UTC 2024 - 3.5K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
t.Errorf("pc.closed = %#v, %v; want errServerClosedIdle or transportReadFromServerError, or nothingWrittenError", err, err) } } func isNothingWrittenError(err error) bool { _, ok := err.(nothingWrittenError) return ok } func isTransportReadFromServerError(err error) bool { _, ok := err.(transportReadFromServerError) return ok }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
cmd/batch-job-common-types.go
// BatchJobYamlErr can be used to return yaml validation errors with line, // column information guiding user to fix syntax errors type BatchJobYamlErr struct { line, col int msg string } // message returns the error message excluding line, col information. // Intended to be used in unit tests. func (b BatchJobYamlErr) message() string { return b.msg } // Error implements Error interface func (b BatchJobYamlErr) Error() string {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 7.9K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
ConstructInitialSnapshot(ambientPods []*corev1.Pod) error Start(ctx context.Context) // IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error Stop() } type Server struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/volume/secret/secret.go
unmounter, unmountCreateErr := b.plugin.NewUnmounter(b.volName, b.podUID) if unmountCreateErr != nil { klog.Errorf("error cleaning up mount %s after failure. Create unmounter failed with %v", b.volName, unmountCreateErr) return } tearDownErr := unmounter.TearDown() if tearDownErr != nil { klog.Errorf("error tearing down volume %s with : %v", b.volName, tearDownErr) } } }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.1K bytes - Viewed (0) -
internal/grid/stream.go
package grid import ( "context" "errors" ) // A Stream is a two-way stream. // All responses *must* be read by the caller. // If the call is canceled through the context, // the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
analysis/analysis-api-impl-base/tests/org/jetbrains/kotlin/analysis/api/impl/base/test/SymbolByFqName.kt
return listOf(symbol) } } data class ClassData(val classId: ClassId) : SymbolData() { override fun KaSession.toSymbols(ktFile: KtFile): List<KaSymbol> { val symbol = getClassOrObjectSymbolByClassId(classId) ?: error("Class $classId is not found") return listOf(symbol)
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 29 17:43:55 UTC 2024 - 8K bytes - Viewed (0) -
internal/cachevalue/cache.go
// If the Update function returns an error the value is forwarded as is and not cached. func (t *Cache[T]) GetWithCtx(ctx context.Context) (T, error) { v := t.val.Load() ttl := t.ttl vTime := t.lastUpdateMs.Load() tNow := time.Now().UnixMilli() if v != nil && tNow-vTime < ttl.Milliseconds() { return *v, nil } // Fetch new value asynchronously, while we do not return an error // if v != nil value or
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
if err != nil { log.Errorf("Failed to process CNI event payload: %v", err) http.Error(w, err.Error(), http.StatusBadRequest) return } if err := s.ReconcileCNIAddEvent(req.Context(), msg); err != nil { log.Errorf("Failed to handle add event: %v", err) http.Error(w, err.Error(), http.StatusInternalServerError) return } } func processAddEvent(body []byte) (CNIPluginAddEvent, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 6.7K bytes - Viewed (0)